文档章节

Debezium接入Mysql遇到到的Tinyint坑

吐槽的达达仔
 吐槽的达达仔
发布于 10/22 18:53
字数 294
阅读 41
收藏 0

问题背景:

在Debezium做数据初始化的时候,对于一些tinyint字段的值,出现0,1的值的异常。

经过源码排查,数据在JDBC上面,读取到的数据是Boolean值。

通过排查,原来是MYSQL特有的数据问题,需要在JDBC上面加上关键字,问题解决。

 

JAVA数据类型 和 MYSQL的数据类型转换,要注意tinyInt 类型,且存储长度为1的情况。

MySQL Types to Java Types for ResultSet.getObject():

 

在Kafka-Connect  debezium 的配置上,加上:

"database.tinyInt1isBit":"false",   

(PS. 其他需要在JDBC上面增加参数,可以通过 database.PARAM_NAME=XXX的方式)

 

 

 

 

 

如果tinyInt1isBit =true(默认),且tinyInt存储长度为1 ,则转为java.lang.Boolean 。

否则转为java.lang.Integer。

 

JDBC的URL增加 tinyInt1isBit=false参数,注意参数名区分大小写,否则不生效

jdbc:mysql://${ucmha.proxy1_2.host}/${db.mysql.db}?tinyInt1isBit=false

 

 

© 著作权归作者所有

吐槽的达达仔
粉丝 28
博文 108
码字总数 8126
作品 0
广州
程序员
私信 提问
debezium关于cdc的使用(上)

博文原址:debezium关于cdc的使用(上) 简介 debezium是一个为了捕获数据变更(cdc)的开源的分布式平台。启动并指向数据库,当其他应用对此数据库执行、、操作时,此应用快速得到响应。debeziu...

大萌小路
06/25
63
0
如何使用Kafka Connect实现同步RDS binlog数据

1. 背景 在我们的业务开发中,往往会碰到下面这个场景: 业务更新数据写到数据库中 业务更新数据需要实时传递给下游依赖处理 所以传统的处理架构可能会这样: 但这个架构也存在着不少弊端:我...

鱼跟猫
2018/05/11
0
0
你了解你的数据吗(练气篇)

0x00 前言 数据一道,可深可浅,可大可小。同为数据人,新手和老鸟亦有很大差别。本篇是了解数据的入门篇,包含两部门内容: 数据接入,你的掌控力如何?主要聊一聊数据接入人员对自己接入数...

木东居士
2018/01/13
0
0
Kafka Connect如何实现同步RDS binlog数据?

  【IT168 技术】本文介绍如何在E-MapReduce上使用Kafka Connect实现同步RDS binlog数据   1. 背景   在我们的业务开发中,往往会碰到下面这个场景:   业务更新数据写到数据库中  ...

云栖社区
2018/05/14
0
0
Unity游戏开发——unity接入多渠道sdk

最近游戏进入最后测试和接入sdk阶段,对接了多个sdk简单记录和分享一下在接入各个渠道sdk中遇到的问题和坑,在之后或其他人看到之后可以绕过,提高效率仅此而已。 我们使用的unity开发,在选...

liang_704959721
2017/07/25
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Java自学指南五、编码工具

工欲善其事,必先利其器... 想要高效率编码输出和快速处理文本,需要 熟悉编程语言的语法 盲打 至少需要熟练使用一种文本编辑器 至少熟练熟练使用一种 IDE (集成开发环境) 现实中,看到过二指...

ConstXiong
26分钟前
4
0
Java 集合框架

早在 Java 2 中之前,Java 就提供了特设类。比如:Dictionary, Vector, Stack, 和 Properties 这些类用来存储和操作对象组。 虽然这些类都非常有用,但是它们缺少一个核心的,统一的主题。由...

天子剑毅
42分钟前
6
0
Oracle 回滚段

--查询数据文件 select t.TABLESPACE_NAME, --表空间名 t.FILE_NAME, --文件名 t.AUTOEXTENSIBLE, --是否自动扩展 t.BYTES / 1024 / 1024 as tsize, --表空间初始大小 t.MAXBYTE...

max佩恩
50分钟前
6
0
在Serverless Kubernetes(ASK)集群中使用Nginx Ingress

ASK: Alibaba Cloud Serverless Kubernetes 导读 不同于阿里云ACK集群默认通过nginx-ingress-controller提供ingress能力,在ASK(Serverless Kubernetes)集群中默认基于SLB七层转发提供ingre...

阿里云官方博客
今天
5
0
Android换肤原理和Android-Skin-Loader框架解析

https://blog.csdn.net/stven_king/article/details/78648095 https://www.jianshu.com/p/b0253de8ac04 https://blog.csdn.net/weixin_38261570/article/details/82079540......

shzwork
今天
7
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部