1:引入jar
<!--es sql支持jar-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.0.15</version>
</dependency>
2:引入
elasticsearch-sql-6.2.4.0.jar
3:Spring boot 需要在pom.xml中配置 elasticsearch-sql-6.2.4.0.jar
<!--添加外部依赖-->
<dependency>
<groupId>Ice</groupId>
<artifactId>Ice</artifactId>
<version>1.0</version>
<scope>system</scope>
<systemPath>${basedir}/lib/elasticsearch-sql-6.2.4.0.jar</systemPath>
</dependency>
4:实现
public static void testJDBC() throws Exception {
Connection connection = ConnectionUtils.ConnectionUtils();
String sql = "select emac from [] ";
sql = sql.replaceAll("\\[[^]]*]", "123456_es_mac_v3_201807");
// .replaceAll("\\$begin", begin)
//.replaceAll("\\$end", end);
PreparedStatement ps = connection.prepareStatement(sql);
ResultSet resultSet = ps.executeQuery();
while (resultSet.next()) {
System.out.println(resultSet.getString("emac"));
}
ps.close();
connection.close();
resultSet.close();
}
5:引入的类
public static Connection ConnectionUtils () {
Connection connection=null ;
try {
Properties properties = new Properties();
properties.put("url", "jdbc:elasticsearch://119.188.98.7:10902,119.188.98.7:11930,119.188.98.7:12930/");
DruidDataSource dds = (DruidDataSource) ElasticSearchDruidDataSourceFactory.createDataSource(properties);
dds.setInitialSize(1);
connection = dds.getConnection();
} catch (Exception e) {
e.printStackTrace();
// TODO: handle exception
}
return connection;
}
6:677807540 java开发交流群