来源:?https://github.com/onefoursix/cloudera-impala-jdbc-example
需要依赖的lib见这篇文章。
http://www.cloudera.com/content/cloudera-content/cloudera-docs/impala/latest/installing-and-using-impala/ciiu_impala_jdbc.html
import java.sql.connection;import java.sql.drivermanager;import java.sql.resultset;import java.sql.sqlexception;import java.sql.statement;?public class clouderaimpalajdbcexample {? // here is an example query based on one of the hue beeswax sample tables private static final string sql_statement = select a from test limit 10;? // set the impalad host private static final string impalad_host = 192.168.1.106;? // port 21050 is the default impalad jdbc port private static final string impalad_jdbc_port = 21050;? private static final string connection_url = jdbc:hive2:// + impalad_host + ':' + impalad_jdbc_port + /;auth=nosasl;? private static final string jdbc_driver_name = org.apache.hive.jdbc.hivedriver;? public static void main(string[] args) {? system.out.println(\n=============================================); system.out.println(cloudera impala jdbc example); system.out.println(using connection url: + connection_url); system.out.println(running query: + sql_statement);? connection con = null;? try {? class.forname(jdbc_driver_name);? con = drivermanager.getconnection(connection_url);? statement stmt = con.createstatement();? resultset rs = stmt.executequery(sql_statement);? system.out.println(\n== begin query results ======================);? // print the results to the console while (rs.next()) { // the example query returns one string column system.out.println(rs.getstring(1)); }? system.out.println(== end query results =======================\n\n);? } catch (sqlexception e) { e.printstacktrace(); } catch (exception e) { e.printstacktrace(); } finally { try { con.close(); } catch (exception e) { // swallow } } }}
原文地址:使用jdbc连接impala例子, 感谢原作者分享。