添加 datastax java driver 依赖；2. 使用 cqlsession 建立连接并指定联系点和本地数据中心；3. 通过 session 执行同步或异步查询；4. 使用参数化语句防止注入并提升性能。本文介绍了 java 连接与操作 cassandra 的关键步骤，包括 maven 或 gradle 中引入驱动、创建会话对象、执行 cql 查询以及使用预编译语句绑定参数的方法，帮助开发者快速实现稳定高效的数据库交互。
Java 连接和操作 Cassandra 数据库，其实并不复杂，但对刚上手的人来说，可能容易踩坑。本文直接讲重点：如何使用 Java 正确连接到 Cassandra，并进行基本的查询操作。
下面从几个关键步骤入手，帮助你快速搭建起 Java 与 Cassandra 的通信桥梁。
添加依赖：确保项目有正确的驱动
在开始写代码之前，首先要确认你的项目中已经引入了适用于 Cassandra 的 Java 驱动。目前主流的是 DataStax Java Driver for Apache Cassandra。
立即学习“Java免费学习笔记（深入）”；
如果你用的是 Maven 项目，可以在 pom.xml 中添加如下依赖：
<dependency>
<groupId>com.datastax.oss</groupId>
<artifactId>java-driver-core</artifactId>
<version>4.15.0</version>
</dependency>如果是 Gradle 项目，则添加：
implementation 'com.datastax.oss:java-driver-core:4.15.0'
注意版本号要根据你的 Cassandra 版本选择合适的驱动版本，避免兼容性问题。
建立连接：初始化 Session 对象
Java 操作 Cassandra 的核心是通过 Session 对象来执行语句。建立连接的基本流程如下：
- 创建
CqlSession实例 - 指定集群地址、端口、Keyspace（可选）
示例代码：
CqlSession session = CqlSession.builder()
.addContactPoint(new InetSocketAddress("127.0.0.1", 9042))
.withLocalDatacenter("datacenter1")
.build();几点注意事项：
-
addContactPoint是 Cassandra 节点的地址，可以是多个节点 -
withLocalDatacenter是为了负载均衡，需要和你的集群配置一致 - 如果你在连接时指定了 Keyspace，可以直接加
.withKeyspace("your_keyspace")
连接成功后，就可以通过 session.execute(...) 来运行 CQL 语句了。
执行查询：同步与异步方式的选择
Java Driver 支持同步和异步两种执行方式。大多数情况下，同步方式更简单直观，适合初学者或业务逻辑不复杂的场景。
同步查询示例：
ResultSet rs = session.execute("SELECT * FROM users WHERE id = 1");
Row row = rs.one();
if (row != null) {
System.out.println(row.getString("name"));
}异步查询（简单示例）：
CompletionStage<AsyncResultSet> resultStage = session.executeAsync("SELECT * FROM users");
resultStage.thenAccept(result -> {
result.forEach(row -> System.out.println(row.getString("name")));
});异步更适合高并发、响应式编程场景，但在日常开发中，建议先掌握同步方式。
参数化查询：防止注入攻击并提高性能
直接拼接字符串执行查询不仅容易出错，还存在安全风险。推荐使用参数化查询。
示例：
PreparedStatement ps = session.prepare("INSERT INTO users (id, name) VALUES (?, ?)");
BoundStatement bs = ps.bind(2, "Alice");
session.execute(bs);也可以使用命名参数：
PreparedStatement ps = session.prepare("UPDATE users SET name = :name WHERE id = :id");
BoundStatement bs = ps.bindMap(Map.of("name", "Bob", "id", 3));
session.execute(bs);参数化不仅能提升安全性，还能复用 PreparedStatement，提升效率。
基本上就这些。连接和查询是最基础也是最关键的环节，只要把这一步弄清楚，后续的操作比如批量插入、分页查询、UDT 使用等，都能顺理成章地展开。
