正在加载

API 使用

Elastic Stack Serverless

可以使用官方的 java.sql 和 javax.sql 包来使用 JDBC

前者通过 java.sql.Driver 和 DriverManager

String address = "jdbc:es://" + elasticsearchAddress;
Properties connectionProperties = connectionProperties();
Connection connection =
    DriverManager.getConnection(address, connectionProperties);
  1. Elasticsearch 监听 HTTP 流量的服务器和端口。 默认端口为 9200。
  2. 用于连接到 Elasticsearch 的属性。 对于未加密的 Elasticsearch，一个空的 Properties 实例即可。

可以通过 javax.sql.DataSource API 访问

EsDataSource dataSource = new EsDataSource();
String address = "jdbc:es://" + elasticsearchAddress;
dataSource.setUrl(address);
Properties connectionProperties = connectionProperties();
dataSource.setProperties(connectionProperties);
Connection connection = dataSource.getConnection();
  1. Elasticsearch 监听 HTTP 流量的服务器和端口。 默认为 9200。
  2. 用于连接到 Elasticsearch 的属性。 对于未加密的 Elasticsearch，一个空的 Properties 实例即可。

应该使用哪个？ 通常，在 URL 中提供大多数配置属性的客户端应用程序依赖于 DriverManager 样式，而 DataSource 更适合传递，因为它可以在一个地方配置，而使用者只需调用 getConnection，无需担心任何其他属性。

要连接到安全的 Elasticsearch 服务器，Properties 应该如下所示

Properties properties = new Properties();
properties.put("user", "test_admin");
properties.put("password", "x-pack-test-password");

连接建立后，您可以像使用任何其他 JDBC 连接一样使用它。 例如

try (Statement statement = connection.createStatement();
        ResultSet results = statement.executeQuery(
              " SELECT name, page_count"
            + "    FROM library"
            + " ORDER BY page_count DESC"
            + " LIMIT 1")) {
    assertTrue(results.next());
    assertEquals("Don Quixote", results.getString(1));
    assertEquals(1072, results.getInt(2));
    SQLException e = expectThrows(SQLException.class, () ->
        results.getInt(1));
    assertThat(e.getMessage(), containsString("Unable to convert "
            + "value [Don Quixote] of type [TEXT] to [Integer]"));
    assertFalse(results.next());
}
注意

Elasticsearch SQL 不提供连接池机制，因此 JDBC 驱动程序创建的连接不会被池化。 为了实现池化连接，需要第三方连接池机制。 配置和设置第三方提供商不在本文档的范围之内。

© . All rights reserved.