/*
 * Copyright 2013 Jesse Morgan
 */

package com.p4square.grow.backend.db;

import java.io.IOException;

import com.p4square.grow.provider.JsonEncodedProvider;

/**
 * Provider implementation backed by a Cassandra ColumnFamily.
 *
 * @author Jesse Morgan <jesse@jesterpm.net>
 */
public class CassandraProviderImpl<V> extends JsonEncodedProvider<CassandraKey, V> {
    private final CassandraDatabase mDb;

    public CassandraProviderImpl(CassandraDatabase db, Class<V> clazz) {
        super(clazz);

        mDb = db;
    }

    @Override
    public V get(CassandraKey key) throws IOException {
        String blob = mDb.getKey(key.getColumnFamily(), key.getId(), key.getColumn());
        return decode(blob);
    }

    @Override
    public void put(CassandraKey key, V obj) throws IOException {
        String blob = encode(obj);
        mDb.putKey(key.getColumnFamily(), key.getId(), key.getColumn(), blob);
    }
}