以下是一个示例代码片段,演示如何使用 Java API 连接 Elasticsearch 并将 Java 对象插入到索引中:

// 创建 Elasticsearch 客户端
TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)
        .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName('localhost'), 9300));

// 创建 Java 对象
Person person = new Person('John', 'Doe', 30);

// 将 Java 对象转换为 JSON 字符串
String json = new Gson().toJson(person);

// 将 JSON 字符串插入到索引中
IndexResponse response = client.prepareIndex('my_index', 'person')
        .setSource(json, XContentType.JSON)
        .get();

// 关闭客户端
client.close();

上述代码假设已经安装并运行了 Elasticsearch 服务器,并且在本地运行在默认端口 9300 上。要使用此代码,您需要将 Person 类替换为您自己的 Java 类,并确保将其转换为 JSON 格式。您还需要将 my_indexperson 替换为您自己的索引和类型名称。

Java 代码连接 Elasticsearch 插入 Java 对象数据

原文地址: https://www.cveoy.top/t/topic/oNmb 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录