使用datastax驱动程序将数据插入cassandra

Question

我们正在尝试使用DataStax驱动程序将CSV文件中的数据插入Cassandra。有哪些方法可以做到这一点？

我们目前使用运行cqlsh从CSV文件加载。

Answer 1

这个问题相当模糊。通常，你应该能够提供代码，并给出一个不太适合你的例子。

话虽如此，我（本周）刚刚为工作中的开发人员讲授了一门关于这个主题的课程。所以我可以给你们举几个简单的例子。

首先，应该构建一个单独的类来处理Cassandra连接对象。我通常用几个构造函数来构建它，这样就可以用几种不同的方式来调用它。但每种方法本质上都调用了一个connect方法，看起来像这样：

public void connect(String[] nodes, String user, String pwd, String dc) {
    QueryOptions qo = new QueryOptions();
    qo.setConsistencyLevel(ConsistencyLevel.LOCAL_ONE);

    cluster = Cluster.builder()
        .addContactPoints(nodes)
        .withCredentials(user,pwd)
        .withQueryOptions(qo)
        .withLoadBalancingPolicy(
            new TokenAwarePolicy(
                DCAwareRoundRobinPolicy.builder()
                .withLocalDc(dc)
                .build()
                )
        )
        .build();
        session = cluster.connect();

在此基础上，我还编写了一些简单的方法来公开会话对象的一些功能：

public ResultSet query(String strCQL) {
    return session.execute(strCQL);
}

public PreparedStatement prepare(String strCQL) {
  return session.prepare(strCQL);
}

public ResultSet query(BoundStatement bStatement) {
  return session.execute(bStatement);
}

有了这些方法，我就可以在服务层内调用这些方法了。一个简单的INSERT（准备一个语句并将值绑定到它）如下所示：

String[] nodes = {"10.6.8.2","10.6.6.4"};
CassandraConnection conn = new CassandraConnection(nodes, "aploetz", "flynnLives", "West-DC");

String userID = "Aaron";
String value = "whatever";
String strINSERT = "INSERT INTO stackoverflow.timestamptest "
    + "(userid, activetime, value) "
    + "VALUES (?,dateof(now()),?)";     

PreparedStatement pIStatement = conn.prepare(strINSERT);
BoundStatement bIStatement = new BoundStatement(pIStatement);
bIStatement.bind(userID, value);
conn.query(bIStatement);

此外，DataStaxJava驱动程序在其Git存储库中有一个名为“示例”的文件夹。这里有一个“基本”示例的链接，我建议进一步阅读。