java impala_Java实现impala操作kudu
packagecn.itcast.impala.impala;import java.sql.*;public classContants {private static String JDBC_DRIVER="com.cloudera.impala.jdbc41.Driver";private static String CONNECTION_URL="jdbc:impala://node1:21050/default;auth=noSasl";//定義數據庫連接
static Connection conn=null;//定義PreparedStatement對象
static PreparedStatement ps=null;//定義查詢的結果集
static ResultSet rs= null;//數據庫連接
public staticConnection getConn(){try{
Class.forName(JDBC_DRIVER);
conn=DriverManager.getConnection(CONNECTION_URL);
}catch(Exception e) {
e.printStackTrace();
}returnconn;
}//創建一個表
public static voidcreateTable(){
conn=getConn();
String sql="CREATE TABLE impala_kudu_test" +
"(" +
"companyId BIGINT," +
"workId BIGINT," +
"name STRING," +
"gender STRING," +
"photo STRING," +
"PRIMARY KEY(companyId)" +
")" +
"PARTITION BY HASH PARTITIONS 16 " +
"STORED AS KUDU " +
"TBLPROPERTIES (" +
"'kudu.master_addresses' = 'node1:7051,node2:7051,node3:7051'," +
"'kudu.table_name' = 'impala_kudu_test'" +
");";try{
ps=conn.prepareStatement(sql);
ps.execute();
}catch(SQLException e) {
e.printStackTrace();
}
}//查詢數據
public staticResultSet queryRows(){try{//定義執行的sql語句
String sql="select * from impala_kudu_test";
ps=getConn().prepareStatement(sql);
rs=ps.executeQuery();
}catch(SQLException e) {
e.printStackTrace();
}returnrs;
}//打印結果
public static voidprintRows(ResultSet rs){/**private int companyId;
private int workId;
private String name;
private String gender;
private String photo;*/
try{while(rs.next()){//獲取表的每一行字段信息
int companyId = rs.getInt("companyId");int workId = rs.getInt("workId");
String name= rs.getString("name");
String gender= rs.getString("gender");
String photo= rs.getString("photo");
System.out.print("companyId:"+companyId+" ");
System.out.print("workId:"+workId+" ");
System.out.print("name:"+name+" ");
System.out.print("gender:"+gender+" ");
System.out.println("photo:"+photo);
}
}catch(SQLException e) {
e.printStackTrace();
}finally{if(ps!=null){try{
ps.close();
}catch(SQLException e) {
e.printStackTrace();
}
}if(conn !=null){try{
conn.close();
}catch(SQLException e) {
e.printStackTrace();
}
}
}
}//插入數據
public static voidinsertRows(Person person){
conn=getConn();
String sql="insert into table impala_kudu_test(companyId,workId,name,gender,photo) values(?,?,?,?,?)";try{
ps=conn.prepareStatement(sql);//給占位符？賦值
ps.setInt(1,person.getCompanyId());
ps.setInt(2,person.getWorkId());
ps.setString(3,person.getName());
ps.setString(4,person.getGender());
ps.setString(5,person.getPhoto());
ps.execute();
}catch(SQLException e) {
e.printStackTrace();
}finally{if(ps !=null){try{//關閉
ps.close();
}catch(SQLException e) {
e.printStackTrace();
}
}if(conn !=null){try{//關閉
conn.close();
}catch(SQLException e) {
e.printStackTrace();
}
}
}
}//更新數據
public static voidupdateRows(Person person){//定義執行的sql語句
String sql="update impala_kudu_test set workId="+person.getWorkId()+
",name='"+person.getName()+"' ,"+"gender='"+person.getGender()+"' ,"+
"photo='"+person.getPhoto()+"' where companyId="+person.getCompanyId();try{
ps=getConn().prepareStatement(sql);
ps.execute();
}catch(SQLException e) {
e.printStackTrace();
}finally{if(ps !=null){try{//關閉
ps.close();
}catch(SQLException e) {
e.printStackTrace();
}
}if(conn !=null){try{//關閉
conn.close();
}catch(SQLException e) {
e.printStackTrace();
}
}
}
}//刪除數據
public static void deleteRows(intcompanyId){//定義sql語句
String sql="delete from impala_kudu_test where companyId="+companyId;try{
ps=getConn().prepareStatement(sql);
ps.execute();
}catch(SQLException e) {
e.printStackTrace();
}
}//刪除表
public static voiddropTable() {
String sql="drop table if exists impala_kudu_test";try{
ps=getConn().prepareStatement(sql);
ps.execute();
}catch(SQLException e) {
e.printStackTrace();
}
}
}
總結
以上是生活随笔為你收集整理的java impala_Java实现impala操作kudu的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： java 画笔跟swing组件_Java
- 下一篇： java a 2_Java A* 算法(