在JAVA中执行cql shell文件或命令

<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 CassandraExample {
    public static void main(String[] args) {
        try (CqlSession session = CqlSession.builder().build()) {
            // 在这里执行CQL命令或脚本文件
        }
    }
}

session.execute("CREATE KEYSPACE IF NOT EXISTS my_keyspace WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1}");

session.executeScript(new File("path/to/script.cql"));

ResultSet resultSet = session.execute("SELECT * FROM my_keyspace.my_table");
for (Row row : resultSet) {
    // 处理每一行的数据
}

try {
    session.execute("INVALID CQL COMMAND");
} catch (Exception e) {
    // 处理异常情况
}