Java连接与操作Cassandra数据库全攻略

添加 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。

如果你用的是 Maven 项目，可以在 pom.xml 中添加如下依赖：

    com.datastax.oss
    java-driver-core
    4.15.0

如果是 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 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 使用等，都能顺理成章地展开。