Updated Sync RDB (markdown)

rewerma
2018-11-22 09:36:37 +08:00
parent 2e0257039e
commit d1ac2c47a7

@@ -14,33 +14,31 @@ RDB adapter 用于适配mysql到任意关系型数据库(需支持jdbc)的数据
## 1/ 修改启动器配置: application.yml, 这里以oracle目标库为例 ## 1/ 修改启动器配置: application.yml, 这里以oracle目标库为例
``` ```
server:
port: 8081
logging:
level:
com.alibaba.otter.canal.client.adapter.rdb: DEBUG
......
canal.conf: canal.conf:
canalServerHost: 127.0.0.1:11111 # 配置具体的canal server地址 canalServerHost: 127.0.0.1:11111
batchSize: 500
syncBatchSize: 1000
retries: 0
timeout:
mode: tcp # kafka rocketMQ
srcDataSources: srcDataSources:
defaultDS: defaultDS:
url: jdbc:mysql://127.0.0.1:3306/mytest?useUnicode=true url: jdbc:mysql://127.0.0.1:3306/mytest?useUnicode=true
username: root username: root
password: 121212 password: 121212
canalInstances: canalAdapters:
- instance: example - instance: example # canal instance Name or mq topic name
groups: groups:
- outAdapters: - groupId: g1
outerAdapters:
- name: rdb # 指定为rdb类型同步 - name: rdb # 指定为rdb类型同步
key: oracle1 # 指定adapter的唯一key, 与表映射配置中outerAdapterKey对应 key: oracle1 # 指定adapter的唯一key, 与表映射配置中outerAdapterKey对应
properties: properties:
jdbc.driverClassName: oracle.jdbc.OracleDriver # jdbc驱动名, jdbc的jar包需要自行放致lib目录下 jdbc.driverClassName: oracle.jdbc.OracleDriver # jdbc驱动名, 部分jdbc的jar包需要自行放致lib目录下
jdbc.url: jdbc:oracle:thin:@localhost:49161:XE # jdbc url jdbc.url: jdbc:oracle:thin:@localhost:49161:XE # jdbc url
jdbc.username: mytest # jdbc username jdbc.username: mytest # jdbc username
jdbc.password: m121212 # jdbc password jdbc.password: m121212 # jdbc password
threads: 5 # 并行执行的线程数, 默认为1 threads: 5 # 并行执行的线程数, 默认为1
commitSize: 3000 # 批次提交的最大行数
``` ```
注意点: 注意点:
1. 其中 outAdapter 的配置: name统一为rdb, key为对应的数据源的唯一标识需和下面的表映射文件中的outerAdapterKey对应, properties为目标库jdb的相关参数 1. 其中 outAdapter 的配置: name统一为rdb, key为对应的数据源的唯一标识需和下面的表映射文件中的outerAdapterKey对应, properties为目标库jdb的相关参数
@@ -53,7 +51,7 @@ canal.conf:
dataSourceKey: defaultDS # 源数据源的key, 对应上面配置的srcDataSources中的值 dataSourceKey: defaultDS # 源数据源的key, 对应上面配置的srcDataSources中的值
destination: example # cannal的instance或者MQ的topic destination: example # cannal的instance或者MQ的topic
outerAdapterKey: oracle1 # adapter key, 对应上面配置outAdapters中的key outerAdapterKey: oracle1 # adapter key, 对应上面配置outAdapters中的key
concurrent: true # 是否按主键hase并行同步, 并行同步的表必须保证主键不会更改及主键不能为其他同步表的外键!! concurrent: true # 是否按主键hash并行同步, 并行同步的表必须保证主键不会更改及主键不能为其他同步表的外键!!
dbMapping: dbMapping:
database: mytest # 源数据源的database/shcema database: mytest # 源数据源的database/shcema
table: user # 源数据源表名 table: user # 源数据源表名