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的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。