1. 程式人生 > >0021-使用JDBC向Kudu表插入中文字元-cast的祕密

0021-使用JDBC向Kudu表插入中文字元-cast的祕密

溫馨提示:要看高清無碼套圖,請使用手機開啟並單擊圖片放大檢視。

1.問題描述

使用Impala JDBC向Kudu表中插入中文字元,插入的中文字串亂碼,中文字串被截斷。

繼之前文件使用sql拼接方式插入中文字串亂碼解決方法後,此文件描述使用jdbc的PreparedStatement方式插入中文字串亂碼問題。

2.問題復現

測試環境:

  • CDH5.12.0
  • Kudu1.4.0
  • ImpalaJDBC41_2.5.35

1.使用ImpalaJDBC程式碼進行測試,測試程式碼

 staticString JDBC_DRIVER ="com.cloudera.impala.jdbc41.Driver";
static String CONNECTION_URL ="jdbc:impala://ip-172-31-10-118:21050/default";

public static void main(String[] args) {
    Connection con = null;
 ResultSetrs = null;
 PreparedStatementps = null;

    try {
        Class.forName(JDBC_DRIVER);
 con =DriverManager.getConnection(CONNECTION_URL);

 Stringsql2 = "insert into my_first_table values(?, ?)";
 ps =con.prepareStatement(sql2);
 ps.setInt(1,81);
 ps.setString(2,"測試中文字元");
 ps.execute();
 ps.close();

 ps =con.prepareStatement("select * from my_first_table order byid asc");
 rs = ps.executeQuery();
        while (rs.next()){
            System.out.println(rs.getLong(1)+ "\t" +rs.getString(2));
 }

    } catch (Exceptione) {
        e.printStackTrace();
 } finally{
 try {// 關閉rs、ps和con
 rs.close();
 ps.close();
 con.close();
 } catch(SQLException e) {
 // TODOAuto-generated catch block
 e.printStackTrace();
 }

    }
}

2.向Kudu表中分別插入測試資料,如“測試”,“測試中文”,“測試中文字元”

String sql2 = "insert into my_first_table values(?, ?)";
ps = con.prepareStatement(sql2);
ps.setInt(1, 73);
ps.setString(2, "測試");
ps.execute();
ps.close();

ps = con.prepareStatement(sql2);
ps.setInt(1, 74);
ps.setString(2, "測試中文");
ps.execute();
ps.close();

ps = con.prepareStatement(sql2);
ps.setInt(1, 75);
ps.setString(2, "測試中文字元");
ps.execute();
ps.close();

通過Hue查詢結果如下:

0021-使用JDBC向Kudu表插入中文字元-cast的祕密

中文字元全部亂碼,部分亂碼,字串被截斷問題重現。

3.解決方法

修改程式中插入語句,將插入字串列使用cast函式轉成String型別

String sql2 = "insert into my_first_table values(?, cast(?as string))";
ps = con.prepareStatement(sql2);
ps.setInt(1, 60);
ps.setString(2, "測試中文字元");
ps.execute();
ps.close();

ps = con.prepareStatement(sql2);
ps.setInt(1, 61);
ps.setString(2, "測試中文");
ps.execute();
ps.close();

ps = con.prepareStatement(sql2);
ps.setInt(1, 62);
ps.setString(2, "測試");
ps.execute();
ps.close();

修改後重新向Kudu中插入測試資料:“測試中文字元”,“測試中文”,“測試”

使用Hue查詢顯示如下:

0021-使用JDBC向Kudu表插入中文字元-cast的祕密

中文字串插入Kudu顯示正常。

醉酒鞭名馬,少年多浮誇! 嶺南浣溪沙,嘔吐酒肆下!摯友不肯放,資料玩的花!
溫馨提示:要看高清無碼套圖,請使用手機開啟並單擊圖片放大檢視。

歡迎關注Hadoop實操,第一時間,分享更多Hadoop乾貨,喜歡請關注分享。

0021-使用JDBC向Kudu表插入中文字元-cast的祕密

原創文章,歡迎轉載,轉載請註明:轉載自微信公眾號Hadoop實操