API usage
editAPI usage
editOne can use JDBC through the official java.sql
and javax.sql
packages:
java.sql
editThe former through java.sql.Driver
and DriverManager
:
javax.sql
editAccessible through the javax.sql.DataSource
API:
JdbcDataSource dataSource = new JdbcDataSource(); String address = "jdbc:es://" + elasticsearchAddress; dataSource.setUrl(address); Properties connectionProperties = connectionProperties(); dataSource.setProperties(connectionProperties); Connection connection = dataSource.getConnection();
The server and port on which Elasticsearch is listening for HTTP traffic. By default 9200. |
|
Properties for connecting to Elasticsearch. An empty |
Which one to use? Typically client applications that provide most
configuration parameters in the URL rely on the DriverManager
-style
while DataSource
is preferred when being passed around since it can be
configured in one place and the consumer only has to call getConnection
without having to worry about any other parameters.
To connect to a secured Elasticsearch server the Properties
should look like:
Properties properties = new Properties(); properties.put("user", "test_admin"); properties.put("password", "x-pack-test-password");
Once you have the connection you can use it like any other JDBC connection. For example:
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)); assertTrue(e.getMessage(), e.getMessage().contains("unable to convert column 1 to an int")); assertFalse(results.next()); }