开发者社区> hadoop实操> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

0020-使用JDBC向Kudu表插入中文字符-双引号的秘密

简介:
+关注继续查看

温馨提示:要看高清无码套图,请使用手机打开并单击图片放大查看。

1.问题描述

使用Impala JDBC向Kudu表中插入中文字符,插入的中文字符串乱码,中文字符串被截断。

2.问题复现

测试环境:

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

1.使用ImpalaJDBC代码进行测试,测试代码

static String 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;
 ResultSet rs = null;
 PreparedStatement ps = null;

    try {
        Class.forName(JDBC_DRIVER);
 con = DriverManager.getConnection(CONNECTION_URL);
 String insertsql = "insertinto my_first_table values(46, '测试中文字符')";

 ps = con.prepareStatement(insertsql);
 ps.execute();
 ps.close();

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

    } catch (Exception e) {
        e.printStackTrace();
 } finally {
 try { // 关闭rs、ps和con
 rs.close();
 ps.close();
 con.close();
 } catch (SQLException e) {
 // TODO Auto-generated catch block
 e.printStackTrace();
 }

    }
}

2.向Kudu表中分别插入测试数据,如“测试”,“测试中文”,“测试中文字符”

String insertsql = "insert into my_first_table values(44, '测试')";
String insertsql = "insert into my_first_table values(45, '测试中文')";
String insertsql = "insert into my_first_table values(46, '测试中文字符')";

如下是按测试顺序插入的数据

通过以上操作重现问题。

3.解决方法

修改程序中插入语句,将插入字符串的单引号修改为双引号

String insertsql = "insert into my_first_table values(51, \"测试中文字符\")";
String insertsql = "insert into my_first_table values(52, \"测试中文\")";
String insertsql = "insert into my_first_table values(53, \"测试\")";

修改后重新向Kudu中插入测试数据:“测试中文字符”,“测试中文”,“测试”

使用Hue查询显示如下:

中文字符串插入Kudu显示正常。

4.备注

1.使用Cloudera官网最新的JDBC驱动,插入中文字符时也有上述问题

下载地址:https://downloads.cloudera.com/connectors/impala_jdbc_2.5.38.1058.zip

2.通过Impala-shell插入中文字符串正常

[172.31.10.118:21000] > insert into my_first_table values(66,'插入中文字符');
Modified 1 row(s), 0 row error(s) in 0.11s
[172.31.10.118:21000] > select * from my_first_table where id=66;
+----+--------------+
| id | name         |
+----+--------------+
| 66 | 插入中文字符 |
+----+--------------+
Fetched 1 row(s) in 0.21s
[172.31.10.118:21000] >

[172.31.10.118:21000] > insert into my_first_table values(77, "测试中文字符");
Modified 1 row(s), 0 row error(s) in 0.11s
[172.31.10.118:21000] > select * from my_first_table where id=77;
+----+--------------+
| id | name         |
+----+--------------+
| 77 | 测试中文字符 |
+----+--------------+
Fetched 1 row(s) in 0.18s
[172.31.10.118:21000] > 

醉酒鞭名马,少年多浮夸! 岭南浣溪沙,呕吐酒肆下!挚友不肯放,数据玩的花!

温馨提示:要看高清无码套图,请使用手机打开并单击图片放大查看。

欢迎关注Hadoop实操,第一时间,分享更多Hadoop干货,喜欢请关注分享。

原创文章,欢迎转载,转载请注明:转载自微信公众号Hadoop实操

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
【C/C++学院】0905-boostSocketTCPUDP/虚函数表的调用/复杂表达式
<p></p> <h2> <span style="font-family:宋体; font-size:16pt">boostSocketTCPUDP</span><span style="font-family:宋体; font-size:16pt"></span> </h2> <p></p> <p>Serverudp.cpp</p> <pre code_snippet_id="
1392 0
使用jquery-easyui写的CRUD插件(3)
好,静态的页面已经可以完成了,下面就开始加上后台的处理部分。 查看easyui的API可以看到,如果需要后台支持的话,需要设置url属性,下面用java来做后台处理数据。 传输的格式用的是JSON,如果你还不知道JSON那么就去baidu一下好了。
671 0
使用IDEA 自带的 MySQL UI 工具插件
比使用 WorkBench, Navicat更加方便! 螢幕快照 2017-10-20 21.55.12.png
1151 0
ECS 7 天实践训练营 - day01 - 基于 ECS 搭建 FTP 服务
七天训练营第一天的任务是基于 ECS 搭建 FTP 服务,教程文档很详细,任务基本无难度。
0 0
使用ABAP 7.40引入的table表达式来操作内表
使用ABAP 7.40引入的table表达式来操作内表
0 0
+关注
文章
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载