如何使用Cassandra的Java连接器从依赖列族中获取数据

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

import com.datastax.oss.driver.api.core.CqlSession;

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

    public static CqlSession connect() {
        return CqlSession.builder()
                .addContactPoint(CONTACT_POINT)
                .withPort(PORT)
                .build();
    }
}

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 DataFetcher {
    public static void main(String[] args) {
        CqlSession session = CassandraConnector.connect();

        String query = "SELECT * FROM keyspace_name.table_name WHERE column_name = 'value'";
        ResultSet resultSet = session.execute(query);

        for (Row row : resultSet) {
            // 处理每一行的数据
            String columnValue = row.getString("column_name");
            System.out.println(columnValue);
        }

        session.close();
    }
}