1

如何从 cassandra 读取文件并将文件写入 cassandra？

从上面的链接，我得到了用 Cassandra 读写文件的方法，但是我不知道表的结构。

下面的代码是将文件插入 Cassandra 的方法。我猜这 是filename两file 列（它是“文件名”主键吗？）。file我们写 . 时的类型是什么CREATE TABLE (...,...,...)。“blob”可以吗？

 ByteBuffer fileByteBuffer = ByteBuffer.wrap( readFileToByteArray( filename ) );
 Statement insertFile = QueryBuilder.insertInto( "files" ).value( "filename", filename ).value( "file", fileByteBuffer );
    session.execute( insertFile );

我创建了 columnfamily ：

            "CREATE TABLE " + columnfamily + " ("
            + PK+ " varchar PRIMARY KEY," 
            + " password varchar ,"
            + " file blob"
            + ");";

我做查询：

 Statement insertFile = QueryBuilder.insertInto(keyspace + "."+columnfamily)
 .value(PK, "LDCR.lua").value("file", fileByteBuffer).value("password", "654321");
 session.execute(insertFile);

但它说：

com.datastax.driver.core.exceptions.InvalidQueryException：未配置的列族

4

0 回答 0