cassandra java cql_使用Cassandra CQL Java Driver 访问Lindorm

适用Driver执行操作

DDL操作// 创建keyspace，指定对应strategy， replication factor。

session.execute(

"CREATE KEYSPACE IF NOT EXISTS testKeyspace WITH replication "

+ "= {'class':'SimpleStrategy', 'replication_factor':1};");

// 创建table，给table指定对应的primary key 以及cluster key 和regular key

session.execute(

"CREATE TABLE IF NOT EXISTS testKeyspace.testTable ("

+ "id int PRIMARY KEY,"

+ "name text,"

+ "age int,"

+ "address text"

+ ");");

//清空表

session.execute("TRUNCATE TABLE testKeyspace.testTable;");

//删除表

session.execute("DROP TABLE testKeyspace.testTable ");

DML操作// 执行insert 操作

session.execute(

"INSERT INTO testKeyspace.testTable (id, name, age, address) "

+ "VALUES ("

+ "1,"

+ "'testname',"

+ "11,"

+ "'hangzhou');");

// 执行select 操作，这里select * 表示获取所有列，也可以指定需要select 的列名获取对应列数据

ResultSet res = session.execute(

"SELECT * FROM testKeyspace.testTable ;");

// 如果想要获取每一列对应的数据，可以如下操作

for (Row row : results)

{

int id = row.getInt("id");

String name = row.getString("name");

int age = row.getInt("age");

String address = row.getString("address");

}

// 关闭Session

session.close();

// 关闭Cluster

cluster.close();

cassandra java cql_使用Cassandra CQL Java Driver 访问Lindorm相关推荐

从Java连接到Cassandra
在我的帖子Hello Cassandra中 ,我研究了如何下载Cassandra NoSQL数据库并使用cqlsh连接到Cassandra数据库. 在本文中,我将介绍从Java客户端连接到Cassan ...
java.lang.ClassNotFoundException: com.mysql.jdbc.Driver 解决方法 java.lang.ClassNotFoundException: com.
java.lang.ClassNotFoundException: com.mysql.jdbc.Driver 解决方法 java.lang.ClassNotFoundException: com.m ...
Idea运行web项目时,提示java.lang.ClassNotFoundException: com.mysql.jdbc.Driver解决方法
Idea运行web项目时,提示java.lang.ClassNotFoundException: com.mysql.jdbc.Driver解决方法参考文章: (1)Idea运行web项目时,提示j ...
jsp项目中连接数据库解决java.lang.ClassNotFoundException: com.mysql.jdbc.Driver的问题
jsp项目中连接数据库解决java.lang.ClassNotFoundException: com.mysql.jdbc.Driver的问题参考文章: (1)jsp项目中连接数据库解决java.l ...
idea mysql错误提示_idea提示错误：java.lang.ClassNotFoundException: com.mysql.jdbc.Driver
碰见了一个问题,一直无法解决,希望大家帮帮忙. 这是连接mysql的JdbcUtils代码: public class JdbcUtils { // 配置文件 private static Prope ...
Java文档阅读笔记-JDBC Driver
目录 JDBC Driver JDBC-ODBC bridge driver Native-API driver Network Protocol driver Thin driver JDBC Dr ...
解决maven项目jdbc报错：java.lang.ClassNotFoundException: com.mysql.jdbc.Driver
博主使用flink连接数据库时报错,完整报错是:switched from INITIALIZING to FAILED with failure cause: java.lang.ClassNotF ...
java.lang.UnsupportedClassVersionError: com/mysql/jdbc/Driver : Unsupported major.minor version 52.0
今天用mybatis-generator生成代码的时候,报了java.lang.UnsupportedClassVersionError: com/mysql/jdbc/Driver : Unsupp ...
错误：“java.lang.ClassNotFoundException: com.mysql.jdbc.Driver“ 如何解决？
--运行项目时遇到 java.lang.ClassNotFoundException: com.mysql.jdbc.Driver 问题,解决方案: 错误如下: java.lang.ClassNotF ...

cassandra java cql_使用Cassandra CQL Java Driver 访问Lindorm

cassandra java cql_使用Cassandra CQL Java Driver 访问Lindorm相关推荐

最新文章

热门文章