如何使用Java操作CrateDB
要使用Java操作CrateDB，你需要添加以下Maven依赖：
<dependency>
<groupId>io.crate</groupId>
<artifactId>crate-client</artifactId>
<version>VERSION</version>
</dependency>
请将`VERSION`替换为您想要使用的CrateDB版本。
下面是Java实现数据增删改查的样例代码：
import io.crate.action.sql.SQLActionException;
import io.crate.client.CrateClient;
import io.crate.client.CrateClientFactory;
import io.crate.client.ResultReceiver;
import io.crate.data.Row;
import io.crate.data.Row1;
import io.crate.data.RowN;
import io.crate.user.User;
import java.net.InetSocketAddress;
import java.util.List;
import java.util.Map;
public class CrateDBExample {
public static void main(String[] args) {
// 创建CrateDB客户端
CrateClient crateClient = CrateClientFactory.fromHosts(List.of(new InetSocketAddress("localhost", 5432)));
try {
// 创建表
crateClient.execute("CREATE TABLE IF NOT EXISTS my_table (id INT PRIMARY KEY, name STRING)");
// 插入数据
crateClient.execute("INSERT INTO my_table (id, name) VALUES (?, ?)", new Object[]{1, "John Doe"});
// 查询数据
crateClient.execute("SELECT id, name FROM my_table", new ResultReceiver<Row>() {
@Override
public void setNextRow(Row row) {
System.out.println(row);
}
@Override
public void setColumns(List<? extends DataType> dataTypes) {
// 可以根据需要保存列的元数据
}
@Override
public void success(long rowCount) {
System.out.println("Query executed successfully");
}
@Override
public void fail(Throwable throwable) {
System.out.println("Query failed: " + throwable.getMessage());
}
});
// 更新数据
crateClient.execute("UPDATE my_table SET name = ? WHERE id = ?", new Object[]{"Jane Smith", 1});
// 删除数据
crateClient.execute("DELETE FROM my_table WHERE id = ?", new Object[]{1});
} catch (SQLActionException e) {
// 处理SQL操作异常
System.out.println("SQL action failed: " + e.getMessage());
} finally {
// 关闭客户端连接
crateClient.close();
}
}
}
在上面的示例中，我们首先通过`CrateClientFactory.fromHosts()`方法创建了一个CrateDB客户端，并指定了CrateDB的主机地址和端口号。然后，我们可以执行各种SQL操作，如创建表、插入数据、查询数据、更新数据和删除数据。对于查询操作，我们需要提供一个实现了`ResultReceiver`接口的回调对象来处理返回的结果。
请根据实际情况修改主机地址和端口号，并根据您的需求调整示例代码。
