使用java模拟到Cassandra的多用户连接

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;

public class CassandraConnectionExample {
    private static final String CONTACT_POINTS = "127.0.0.1"; // Cassandra节点的IP地址
    private static final int PORT = 9042; // Cassandra节点的端口号

    public static void main(String[] args) {
        // 创建一个Cassandra集群对象
        Cluster cluster = Cluster.builder()
                .addContactPoints(CONTACT_POINTS)
                .withPort(PORT)
                .build();

        // 连接到Cassandra集群并打开一个会话
        Session session = cluster.connect();

        // 执行CQL查询语句
        String cqlQuery = "SELECT * FROM keyspace.table;";
        session.execute(cqlQuery);

        // 关闭会话和集群连接
        session.close();
        cluster.close();
    }
}