为了使Java应用程序能够与Apache Cassandra 4.x版本兼容,可以使用最新版本的Java驱动程序。以下是一个简单的代码示例,展示了如何使用Java驱动程序与Cassandra 4.x进行交互。
首先,需要添加以下依赖项到Maven项目中:
com.datastax.oss
java-driver-core
4.10.0
接下来,在Java应用程序中创建一个Cassandra会话并连接到Cassandra集群:
import com.datastax.oss.driver.api.core.CqlSession;
// 创建Cassandra会话
CqlSession session = CqlSession.builder()
.withKeyspace("my_keyspace") // 修改为实际使用的keyspace名称
.addContactPoint("localhost") // 修改为Cassandra集群中任意节点的IP地址或主机名
.withLocalDatacenter("datacenter1") // 修改为实际使用的数据中心名称
.build();
// 使用会话与Cassandra进行交互
session.execute("CREATE TABLE IF NOT EXISTS my_table (id int PRIMARY KEY, name text)");
此示例代码创建了一个名为“my_table”的Cassandra表,其中包含一个ID和名称列。这将确保Java应用程序可以与Cassandra 4.x版本兼容。