R和cassandra连接错误

Question

library(RJDBC)




cassdrv <- JDBC("org.apache.cassandra.cql.jdbc.CassandraDriver",
                    list.files("/home/beyhan/Downloads/jars/",pattern="jar$",full.names=T))

    casscon <- dbConnect(cassdrv, "jdbc:cassandra://localhost:9042")

输出

> cassdrv <- JDBC("org.apache.cassandra.cql.jdbc.CassandraDriver",
+ list.files("/home/beyhan/Downloads/jars/",pattern="jar$",full.names=T))
> casscon <- dbConnect(cassdrv, "jdbc:cassandra://localhost:9042")

错误。jcall(drv@jdrv，“Ljava/sql/Connection；”，“连接”，如图所示。字符（url）[1]，：java。lang.NoClassDefFoundError:org/apache/thrift/transport/ttTransportException

Answer 1

我们针对Cassandra的JDBC驱动程序允许您访问R中的Cassandra数据。更清楚的是，我们的驱动程序为您的Cassandra数据创建了一个关系接口，允许您通过我们的驱动程序向Cassandra提交SQL查询（在内部，我们将SQL转换为CQL，发送请求并将结果作为关系数据库返回）。

我们的知识库中有一篇文章用于连接，但我也会在这里转录。

>

library(RJDBC)

设置驱动程序类和类路径：

driver <- JDBC(driverClass = "cdata.jdbc.cassandra.CassandraDriver", classPath = "MyInstallationDir\lib\cdata.jdbc.cassandra.jar", identifier.quote = "'")

初始化JDBC连接：

conn <- dbConnect(driver,"Database=MyCassandraDB;Port=7000;Server=127.0.0.1;")

（设置服务器、端口和数据库连接属性以连接到Cassandra。）

此时，您可以执行R中可用的标准操作，如：

>

dbListTables(conn)

执行Cassandra API支持的任何SQL查询：

customer <- dbGetQuery(conn,"SELECT City, SUM(TotalDue) FROM Customer GROUP BY City")

查看结果：

View(customer)

欢迎免费下载该驱动程序的测试版！如果您有任何问题，请告诉我们。

Answer 2

好的，ODBC连接器基于THRIFT协议。不建议使用到Cassandra的THRIFT连接。我认为解决方案中的Python是您的最佳方法。这里有一个示例：如何用R从Cassandra读取数据？

下面是一篇关于节俭与CQL的博客：http://www.datastax.com/dev/blog/cassandra-2-1-now-over-50-faster