java连接cassandra数据库

在Java中连接Apache Cassandra数据库，你可以使用官方提供的Cassandra Java驱动，即DataStax Java Driver for Apache Cassandra。以下是简单的步骤：

1. **添加依赖**：
将Cassandra Driver作为Maven项目依赖加入到pom.xml文件中：

   <dependency>
       <groupId>com.datastax.cassandra</groupId>
       <artifactId>cassandra-driver-core</artifactId>
       <version>4.x.x</version> <!-- 最新的稳定版本 -->
   </dependency>

2. **配置连接信息**：
创建`Cluster`实例时，需要提供集群名称、节点地址等信息：

   String clusterName = "your_cluster_name";
   String contactPoint = "node1_ip_address, node2_ip_address, ..."; // 节点列表

   Cluster cluster = Cluster.builder()
       .addContactPoints(contactPoint)
       .withPort(Cassandra.DEFAULT_PORT)
       .build();

3. **创建Session**：
通过`Cluster`获取连接会话，用于执行查询操作：

   Session session = cluster.connect("keyspace_name"); // keyspace是你要在其中操作的数据库

4. **执行操作**：
使用`Session`进行读取（query）、插入（insert）、更新（update）等操作。例如查询数据：

   QueryBuilder queryBuilder = QueryBuilder.select().all().from("table_name");
   ResultSet resultSet = session.execute(queryBuilder.build());

5. **关闭连接**：
执行完操作后记得关闭`Session`和`Cluster`：

   session.close(); // 关闭当前会话
   cluster.close(); // 关闭整个集群连接