一、全量同步

本文以mysql -> mysql为示例:

  本次测试的表为mysql的系统库-sakila中的actor表,由于不支持目的端自动建表,此处预先建立目的表:

CREATE TABLE `actor_copy` (`actor_id` smallint(5) unsigned NOT NULL AUTO_INCREMENT,`first_name` varchar(45) NOT NULL,`last_name` varchar(45) NOT NULL,`last_update` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,PRIMARY KEY (`actor_id`),KEY `idx_actor_last_name` (`last_name`)
) ENGINE=InnoDB AUTO_INCREMENT=201 DEFAULT CHARSET=utf8;

  打开dataX的mysqlreader以及mysqlwriter文档,编写JSON配置文件:(此处经过试验,即使是自增主键,同样需要配置,否则会报输入输出不匹配的错),加上JSON配置文件的x权限:

{"job": {"setting": {"speed": {"channel": 3},"errorLimit": {"record": 0,"percentage": 0.02}},"content": [{"reader": {"name": "mysqlreader","parameter": {"username": "root","password": "Zcc170821#","column": ["actor_id","first_name","last_name","last_update"],"splitPk": "actor_id","connection": [{"table": ["actor"],"jdbcUrl": ["jdbc:mysql://192.168.19.129:3306/sakila"]}]}},"writer": {"name": "mysqlwriter","parameter": {"writeMode": "insert","username": "root","password": "Zcc170821#","column": ["actor_id","first_name","last_name","last_update"],"preSql": ["truncate table actor_copy"],"connection": [{"jdbcUrl": "jdbc:mysql://192.168.19.129:3306/sakila","table": ["actor_copy"]}]}}}]}
}

这样,单表的最基本全量同步就完成了!

二、增量同步

  增量同步的核心思路是时间戳,需要同步的表中要有Update_time字段:

  参考实现:https://www.jianshu.com/p/34b3a084d7d8

      https://blog.csdn.net/quadimodo/article/details/82186788

转载于:https://www.cnblogs.com/jiangbei/p/11258267.html

datax——全量、增量同步相关推荐

  1. ODPS 数据全量/增量同步方案

    随着业务量增加,原采用的mysql 对大量业务数据的处理效率降低,公司采购的ODPS(MaxCompute) 阿里数据处理平台,进行数据的处理. 一.源数据库 -> ODPS 全量同步,直接同步 ...

  2. mongodb监听oplog 全量+增量同步

    一.前言 前一个项目中,涉及到了一次数据迁移,这次迁移需要从mongodb迁移到另一个mongodb实例上,两个源的数据结构是不一样的.涉及到增量和全量数据迁移,整体迁移数据量在5亿左右.本篇即讲理论 ...

  3. solr mysql增量导入_10.Solr4.10.3数据导入(DIH全量增量同步Mysql数据)

    1.创建MySQL数据 create databasesolr;usesolr;DROP TABLE IF EXISTSstudent;CREATE TABLEstudent ( idchar(10) ...

  4. 利用Canal全量/增量同步mysql数据至ES

    Canal同步mysql数据至ES 1.更改Mysql配置 1.1 开启 Binlog 写入功能 配置 binlog-format 为 ROW 模式,配置my.cnf [mysqld] log-bin ...

  5. “全量增量” 与 “增量同步” 一文了解清楚【建议收藏】

    大家在同步数据的时候都会接触到2个名词,"全量增量" 与 "增量同步" ,名字都长得差不多,但是意思和操作却不一样:比如部门领导给你方案,那我们要如何去选择其中 ...

  6. 331全量增量数据、同步ld

    -- 数据同步 1 全量数据同步 1.1 不带参数的实现方式 每次更新目标表的时候,先把目标表中的数据清空,然后用源表的数据插入目标表中 . 1.2 通过参数 ,会计期(一个会计期 = 1个月 ,格式 ...

  7. mysqldump备份(全量+增量)

    在日常运维工作中,对mysql数据库的备份是万分重要的,以防在数据库表丢失或损坏情况出现,可以及时恢复数据. 线上数据库备份场景: 每周日执行一次全量备份,然后每天下午1点执行MySQLdump增量备 ...

  8. mysqldump全量恢复_【MySQL】全量+增量的备份/恢复

    生产环境中,有时需要做MySQL的备份和恢复工作.因MySQL是在运行过程中的,做全量备份需要时间,全量备份完成后又有数据变动,此时需要增量备份辅助.如果想恢复数据到一个空库(例如数据迁移或者上云等更 ...

  9. datax实现mysql增量同步_datax 3.0配合crontab实现数据定时增量同步

    使用datax 实现数据增量同步踩坑记录 前提概要 由于项目上需要将a服务器数据同步至b服务器,一开始使用mysql主从复制,但是由于主从同步无法触发位于b服务器的触发器,只能放弃此方案.后来找到了d ...

  10. MySQL数据库之全量+增量+二进制日志的备份与恢复

    一.简介数据的备份与恢复 1.为什么备份? 灾难恢复:人为错误.硬件故障(冗余).软件故障(bug).自然灾害.黑客攻击.误操作.-: 测试: 2.备份时应该注意些什么? 能容忍最多丢失多少数据: 恢 ...

最新文章

  1. 大数据中台向AI中台演进是大势所趋?
  2. git记住用户名和密码
  3. 【c语言】蓝桥杯基础练习 特殊的数字
  4. PXE网络无人值守装机
  5. Matlab学习笔记——文件的打开与关闭
  6. 面试官上来就问:Java 进程中有哪些组件会占用内存?
  7. sqlite随机读取N条记录
  8. 给谷歌输入法增添自定义词组,提高输入效率
  9. LogoSharp:Logo语言的C#实现
  10. 写出漂亮代码的七种方法
  11. MYSQL中的空格及大小写问题
  12. hdu-5583 Kingdom of Black and White(数学,贪心,暴力)
  13. 模拟监控和真实用户体验监测,选哪个?
  14. linux shell中$0,$?,$!等的特殊用法
  15. 大型网站建设方案(学院网站建设方案)
  16. week05-继承、多态、抽象类与接口
  17. You are using pip version 9.0.1, however version 22.1.2 is available. You should consider upgrading
  18. Vue之监测数据的原理
  19. 2018年8月7日 乐视2 X621 刷机包下载链接
  20. C语言中定义整数的一个小疑问

热门文章

  1. JScript.NET或者JScript是什么?
  2. 谱分析——傅里叶级数(离散谱)
  3. 中西宗教精神之比较研究
  4. 关于sublime Text3 显示gkb乱码的问题
  5. Python基础:字符集和编码
  6. Webyog Sqlyog Ultimate_12.5.1最新版完美破解(带注册码)
  7. 复旦计算机系吴昊,数学科学学院候选好导师访谈——吴昊老师
  8. 算法 | 虚树学习笔记
  9. ffmpeg 音频解码二
  10. 完美兼容MIC5203-3.3BM5的高压LDO-CSM5133SE/CSM5130SE