1、集群:CDH-5.7.5
2、impala下载jar地址:https://www.cloudera.com/downloads/connectors/impala/jdbc/2-5-28.html
下载需要用户注册cloudera账户邮箱电话等,随便注册一下就可以了。。。
下载的是一个zip包:impala_jdbc_2.5.36.2056.zip
3、Client代码:
public class Client {
public static void main(String[] args) {
Connection conn=null;
Statement st=null;
ResultSet rs=null;
String sql = "select count(*) from wp04_2013_data";
try {
conn=ImpalaJDBCUtils.getConnnection();
st=conn.createStatement();
rs=st.executeQuery(sql);
//处理数据
while(rs.next()){
System.out.println(rs.getString(1));
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
ImpalaJDBCUtils.release(conn,st,rs);
}
}
}
4、ImpalaJDBCUtils代码:
public class ImpalaJDBCUtils {
private static String driverName ="com.cloudera.impala.jdbc4.Driver";// com.cloudera.impala.jdbc41.Driver
private static String url="jdbc:impala://10.2.45.129:21050/gree_monitorcenter_biz1";//jdbc:impala://10.2.45.129:21050/gree_monitorcenter_biz1
static{
try {
Class.forName(driverName);
} catch (ClassNotFoundException e) {
e.printStackTrace();
System.exit(1);
}
}
//获取链接
public static Connection getConnnection(){
try {
return DriverManager.getConnection(url);
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
//释放资源
public static void release(Connection conn, Statement st, ResultSet rs){
if(rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}finally {
rs=null;
}
}
if(st!=null){
try {
st.close();
} catch (SQLException e) {
e.printStackTrace();
}finally {
st=null;
}
}
if(conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}finally {
conn=null;
}
}
}
}