es-sql_jdbc链接查询使用

aini

　　package org.nlpcn.es4sql;
　　import com.alibaba.druid.pool.DruidDataSource;
　　import com.alibaba.druid.pool.ElasticSearchDruidDataSourceFactory;
　　import org.junit.Assert;
　　import org.junit.Test;
　　import java.math.BigDecimal;
　　import java.sql.*;
　　import java.util.ArrayList;
　　import java.util.Calendar;
　　import java.util.List;
　　import java.util.Properties;
　　/**
　　* Created by allwefantasy on 8/26/16.
　　*/

　　public>　　@Test
　　public void testJDBC() throws Exception {
　　Properties properties = new Properties();
　　properties.put("url", "jdbc:elasticsearch://192.168.1.101:9300/" + TestsConstants.TEST_INDEX);
　　DruidDataSource dds = (DruidDataSource) ElasticSearchDruidDataSourceFactory.createDataSource(properties);
　　Connection connection = dds.getConnection();

　　PreparedStatement ps = connection.prepareStatement("SELECT * from " + TestsConstants.TEST_INDEX + " where>　　Calendar Htime= Calendar.getInstance();
　　double nowtime = Htime.getTime().getTime();
　　ResultSet resultSet = ps.executeQuery();
　　Calendar Ltime= Calendar.getInstance();
　　double endtime = Ltime.getTime().getTime();
　　BigDecimal longtime = new BigDecimal((endtime-nowtime)/1000);
　　double second =longtime.setScale(3,BigDecimal.ROUND_HALF_UP).doubleValue();
　　List result = new ArrayList();
　　while (resultSet.next()) {
　　result.add(resultSet.getInt("id") + "," + resultSet.getString("age") + "," + resultSet.getString("name"));
　　}
　　System.out.println("查询结果："+result);
　　System.out.println("耗时："+second+"秒");
　　ps.close();
　　connection.close();
　　dds.close();
　　}
　　}
　　package org.nlpcn.es4sql;

　　public>　　public static void main(String[] args) {
　　// TODO Auto-generated method stub
　　gotop();
　　}
　　public static void gotop() {
　　JDBCTests server = new JDBCTests();
　　try {
　　server.testJDBC();
　　} catch (Exception e) {
　　// TODO Auto-generated catch block
　　e.printStackTrace();
　　}
　　}
　　}