Canal 数据同步(最终测试) | 学习笔记

简介: 快速学习 Canal 数据同步(最终测试)

开发者学堂课程【微服务+全栈在线教育实战项目演练(SpringCloud Alibaba+SpringBoot)Canal 数据同步(最终测试)】学习笔记,与课程紧密连接,让用户快速学习知识。

课程地址https://developer.aliyun.com/learning/course/667/detail/11519


Canal 数据同步(最终测试)


目录:

一、启动

二、具体操作

三、总结


一、启动

要想测试,就先启动,使用脚本进程,再看进程。将本地项目启动,

数据同步现主要做的监控,就是监控远程部分变化,有客户端的工具,先用端口号启动。端口号为10000。

用 debug 方式启动。用 debug 之后,就能看到的结果,那重新换种方式,用debug 款就这个它启动,然后启动之后再加上几个断点,通过 debug 来看执行过程,理解流程。


二、具体操作

//当队列里面堆积的 sql 大于一定数值的时候就 模拟执行

if (SQL QUEUE. size() >= 1)

executeQueueSql;

模拟执行队列里面的 sql 语句

public void executeQueueSql()

int size = SQL_QUEUE.size();

for (int i =0; i

String sql =SQL_QUEUE.pol1();

System.out.println("[sql]——>”+ sql);

this.execute(sql.toString());

再其中加了断点,进行测试。

在本地库没有东西,连接数据库,写个语句,在这个远程库里边加一条数据,如果效果正确,在本地库中也会同步添加,这个过程就叫数据同步。

1.insert语句如下:

mysql>insert into members values(1, 'lucy' ,20);

执行后如下:

if (batchId ==-1 size ==0) (batchId:2 size:3

Thread.sleep( millis:1000); I

)else(

dataHandle(message.getEntries());message:Message[id=2,entries=[header

此时 size 大于0,就可以继续操作。

点击绿色按钮,一路执行,到下一个断点,判断做哪个操作,当前做的是添加:

else if (eventType == EventType. INSER) {KeventType: "INSERT"

2.修改操作:

mysql= update members set username=“mary" where id=1;

结果如下:

Query oK, row affected(0.11 sec)

Fows matched: 1 Changed: 1 warnings : 0

3.删除操作如下:

mysql≥ delete frommembers where id-l:

结果如下:

Query ok, l row affected ie.o1l sec)


三、总结

当远程库时,远程库添加删除,本地库也会随之发生变化。过程中需要安装,在本地写出代码。

有以下细节:

第一个细节就是远程库的名字和数据表的名字,跟本地库名字表名字必须要一样,根据名字做匹配,在这里都叫做 guli members。

第二个细节是就是改 kindle 中的配置文件的时候,这个数据库的用户名要特别注意,这些用户名需要有远程连接的权限,默认 root 是没这个权限,默认只能是本地连接,需要做修改,或者说按着过程重新创建,或者说创建用过的用户。

相关文章
|
2月前
|
存储 分布式计算 DataWorks
DataWorks产品使用合集之在DataWorks中,从数据同步到最终的大屏幕展示的基本流程如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
38 0
DataWorks产品使用合集之在DataWorks中,从数据同步到最终的大屏幕展示的基本流程如何解决
|
2月前
|
canal 关系型数据库 MySQL
Canal数据同步工具
Canal数据同步工具
81 2
|
2月前
|
Java 测试技术 编译器
JMM测试利器-JCStress学习笔记
JMM测试利器-JCStress学习笔记
|
8月前
|
消息中间件 NoSQL 关系型数据库
Canal+Kafka实现MySQL与Redis数据同步(二)
Canal+Kafka实现MySQL与Redis数据同步
162 0
|
8月前
|
消息中间件 canal NoSQL
Canal+Kafka实现MySQL与Redis数据同步(一)
Canal+Kafka实现MySQL与Redis数据同步
305 0
|
8月前
|
canal NoSQL 关系型数据库
淘东电商项目(22) -Canal数据同步框架
淘东电商项目(22) -Canal数据同步框架
77 0
|
10月前
|
canal SQL 关系型数据库
大数据同步工具Canal 2
大数据同步工具Canal
249 0
|
10月前
|
canal 消息中间件 关系型数据库
大数据同步工具Canal 1
大数据同步工具Canal
425 0
|
21天前
|
JSON JavaScript 测试技术
Postman接口测试工具详解
Postman接口测试工具详解
30 1
|
10天前
|
XML JSON 测试技术
Postman接口测试工具详解
📚 Postman全攻略:API测试神器!📚 发送HTTP请求,管理集合,写测试脚本,集成CI/CD。从安装配置到环境变量、断言、数据驱动测试,一步步教你如何高效测试RESTful API。实战案例包含GET、POST、PUT、DELETE请求。用Newman在命令行跑集合,自动化测试不发愁!👉 [洛秋小站](https://www.luoqiu.site/) 学更多!🚀
24 1