如何使用来自Java的身份验证连接到Cassandra 5.1

import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.CqlSessionBuilder;
import com.datastax.oss.driver.api.core.auth.PlainTextAuthProvider;

public class CassandraConnection {
    public static void main(String[] args) {
        String username = "your_username";
        String password = "your_password";
        String contactPoint = "your_contact_point"; // Cassandra节点的IP地址或主机名

        PlainTextAuthProvider authProvider = new PlainTextAuthProvider(username, password);
        CqlSessionBuilder builder = CqlSession.builder()
                .addContactPoint(contactPoint)
                .withAuthCredentials(username, password)
                .withAuthProvider(authProvider);

        CqlSession session = builder.build();
        // 使用session执行Cassandra查询和操作
        session.close();
    }
}