0

で働き始めましたCassandra database。Datastax APIを使用してupsert/readinto/fromする予定ですCassandra database。私はこれDatastax API（新しいバイナリプロトコルを使用する）にまったく慣れておらず、いくつかの適切な例を含む多くのドキュメントも見つけることができません。

create column family profile
    with key_validation_class = 'UTF8Type'
    and comparator = 'UTF8Type'
    and default_validation_class = 'UTF8Type'
    and column_metadata = [
      {column_name : crd, validation_class : 'DateType'}
      {column_name : lmd, validation_class : 'DateType'}
      {column_name : account, validation_class : 'UTF8Type'}
      {column_name : advertising, validation_class : 'UTF8Type'}
      {column_name : behavior, validation_class : 'UTF8Type'}
      {column_name : info, validation_class : 'UTF8Type'}
      ];

以下は、新しいバイナリ プロトコルを使用Singleton classする Cassandra データベースに接続するために作成したものです。Datastax API

public class CassandraDatastaxConnection {

    private static CassandraDatastaxConnection _instance;
    protected static Cluster cluster;
    protected static Session session;


    public static synchronized CassandraDatastaxConnection getInstance() {
        if (_instance == null) {
            _instance = new CassandraDatastaxConnection();
        }
        return _instance;
    }

    /**
     * Creating Cassandra connection using Datastax API
     *
     */
    private CassandraDatastaxConnection() {

        try{
            cluster = Cluster.builder().addContactPoint("localhost").build();
            session = cluster.connect("my_keyspace");           
        } catch (NoHostAvailableException e) {
            throw new RuntimeException(e);
        }
    }

    public static Cluster getCluster() {
        return cluster;
    }

    public static Session getSession() {
        return session;
    }
}

最初の質問singleton class- 新しい Binary プロトコルを使用する Datastax API を使用して Cassandra データベースに接続しているときに、上記で不足しているものがあれば教えてください。

2 番目の質問upsert and read data- Cassandra データベースに出入りしようとしています -

これらは、上記のシングルトン クラスを使用する DAO のメソッドです。

public Map<String, String> getColumnNames(final String userId, final Collection<String> columnNames) {

    //I am not sure what I am supposed to do here?
    //Given a userId, I need to retrieve those columnNames from the Cassandra database
    //And then put it in the map with column name and its value and then finally return the map

    Map<String, String> attributes = new ConcurrentHashMap<String, String>();

    for(String col : columnNames ) {
        attributes.put(col, colValue);
    }

    return attributes;
}


/**
 * Performs an upsert of the specified attributes for the specified id.
 */
public void upsertAttributes(final String userId, final Map<String, String> columnNameAndValue) {

    //I am not sure what I am supposed to do here to upsert the data in Cassandra database.
    //Given a userId, I need to upsert the columns values into Cassandra database.
    //columnNameAndValue is the map which will have column name as the key and corresponding column value as the value.

}

誰でもこれで私を助けることができますか？私は、新しいバイナリ プロトコルを使用しているこの Datastax API にまったく慣れていないため、これには多くの問題があります。

助けてくれてありがとう。

4

1 に答える 1

2

cassandra.yaml ファイルで、タグstart_native_transportを探します。デフォルトでは無効になっていますが、有効にします。

Datastax Java ドライバーで遊ぶことは、jdbc ドライバーと非常によく似ています。

挿入コード

 String query = "insert into test(key,col1,col2) values('1','value1','value2')";
 session.execute(query);

Cassandra からの読み取り

 String query="select * from test;";
 ResultSet result = session.execute(query);
 for (Row rows: result){
     System.out.println(rows.getString("key"));
 }
于 2013-04-20T04:34:37.487 に答える