在Java中连接和使用Cassandra

 <groupId>com.datastax.oss</groupId>
 <artifactId>java-driver-core</artifactId>
 <version>4.13.0</version>
</dependency>

import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.cql.ResultSet;
import com.datastax.oss.driver.api.core.cql.Row;

public class CassandraExample {

  public static void main(String[] args) {
    try (CqlSession session = CqlSession.builder()
        .withKeyspace("your_keyspace")
        .withAuthCredentials("your_username", "your_password")
        .addContactPoint(new InetSocketAddress("your_cassandra_host", 9042))
        .build()) {

      ResultSet resultSet = session.execute("SELECT * FROM your_table");
      for (Row row : resultSet) {
        System.out.println("Column 1: " + row.getString(0));
        System.out.println("Column 2: " + row.getString(1));
      }

    } catch (Exception e) {
      System.err.println("Error connecting to Cassandra: " + e.getMessage());
    }
  }
}