presto_jdbc

package com.eshore; /** * Created by ppz on 2019/1/15. */ import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class PrestoJdbcCli { private static Statement statement; private static Connection conn; static Logger logger = LoggerFactory.getLogger(PrestoJdbcCli.class); public static void main(String[] args) throws Exception { String sql = "select * from dwg_yd_cell where yyyymmdd='0' and acc_nbr>'189' limit 100000"; query(sql); } public static Connection createConnection() throws SQLException, ClassNotFoundException { Class.forName("com.facebook.presto.jdbc.PrestoDriver"); return DriverManager.getConnection("jdbc:presto://132.121.94.89:9989/hive/dop2", "hive", "hive"); } public static void query(String sql) throws SQLException, ClassNotFoundException{ conn = createConnection(); statement = conn.createStatement(); long begin = System.currentTimeMillis(); ResultSet rs = statement.executeQuery(sql) ; long end = System.currentTimeMillis(); System.out.println((end - begin) + " ms "); while(rs.next()){ System.out.println(rs.getString("serv_id")+ "," + rs.getString("city_id") + "," + rs.getString("acc_nbr")); } statement.close(); conn.close(); } }