2

以前のようにCassandraでこのように作成された列ファミリーがある場合、Thriftベースのクライアントを使用していました..

create column family USER
with comparator = 'UTF8Type'
and key_validation_class = 'UTF8Type'
and default_validation_class = 'BytesType'

次に、非同期/バッチ書き込み機能を備えた Datastax Java ドライバーを使用して、上記の列ファミリーに挿入できますか?

INSERT ステートメントを使用して上記の列ファミリーに挿入しますか? Datastax Java ドライバーを使用してそれは可能ですか?

列ファミリーの設計テーブルではなく、Datastax Java ドライバーを使用して CQL ベースのテーブルにのみ挿入できるという印象を受けました...

4

2 に答える 2

2

TL;DR
並べ替えですが、cql3 ベースのテーブルを作成し、そこから続行することをお勧めします。

まず、何が起こっているかを明確に把握するために、cqlsh で describe コマンドを使用します。

cqlsh> describe COLUMNFAMILY "USER";

CREATE TABLE "USER" (
  key text,
  column1 text,
  value blob,
  PRIMARY KEY (key, column1)
) WITH COMPACT STORAGE AND
  bloom_filter_fp_chance=0.010000 AND
  caching='KEYS_ONLY' AND
  comment='' AND
  dclocal_read_repair_chance=0.000000 AND
  gc_grace_seconds=864000 AND
  index_interval=128 AND
  read_repair_chance=0.100000 AND
  replicate_on_write='true' AND
  populate_io_cache_on_flush='false' AND
  default_time_to_live=0 AND
  speculative_retry='NONE' AND
  memtable_flush_period_in_ms=0 AND
  compaction={'class': 'SizeTieredCompactionStrategy'} AND
  compression={'sstable_compression': 'LZ4Compressor'};

次に、cqlh を使用して挿入ステートメントを作成できます (私は cqlsh を使用しました)。

cqlsh:test> insert into test."USER" (key, column1, value) VALUES ('epickey', 'epic column 1 text', null);

ただし、選択を行うと...

cqlsh:test> SELECT * FROM test."USER" ;

(0 rows)

完了したら、CLI に戻ります。

[default@unknown] use test;
Authenticated to keyspace: test
[default@test] list USER;
Using default limit of 100
Using default cell limit of 100
-------------------
RowKey: epickey

1 Row Returned.
Elapsed time: 260 msec(s).

最後に使用するツールは sstable2json です (sstable からすべてのデータを取得し、それを json 表現に変換します)

上記の USER cf の単一の挿入について、私はこれを取り戻しました：

[
{"key": "657069636b6579","columns": [["epic column 1 text","5257c34b",1381483339315000,"d"]]}
]

したがって、データはそこにありますが、cql 経由で実際にアクセスすることはできません。

注:これはすべて、C* 2.0 および cqlsh 4.0 (cql3) を使用して行われます。

于 2013-10-11T09:28:34.267 に答える
0

はい、以下のコードを使用します。

String query = "INSERT INTO " + keyspace_name + "." + column_family + " (" + column_names + ") VALUES (" + column_values + ");";
statement = session.prepare(query);
boundStatement = new BoundStatement(statement);

boundStatement.setString(0, key);
boundStatement.setString(1, subColNames[k]);
boundStatement.setMap(2, colValues);
session.execute(boundStatement);
于 2013-10-11T09:05:55.433 に答える