presto jdbc例子

1. 新建maven項目，導入依賴

<dependency>
	 <groupId>com.facebook.presto</groupId>
	 <artifactId>presto-jdbc</artifactId>
	 <version>0.107</version>
</dependency>

 

package org.jdbc.presto;

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 test order by sequence asc limit 10";
		query(sql);
	}
	public static Connection createConnection()
            throws SQLException, ClassNotFoundException
    {
		Class.forName("com.facebook.presto.jdbc.PrestoDriver");
        return DriverManager.getConnection("jdbc:presto://103.126.58.70:5050/hive/default", "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("ip")+ "," + rs.getString("message"));
		}
		statement.close();
		conn.close();
	}
	
}