创建student表

CREATE TABLE student ( 学号 int NOT NULL, 姓名 varchar(45) DEFAULT NULL, 性别 varchar(45) DEFAULT NULL, 班级 int DEFAULT NULL, 年龄 int DEFAULT NULL, 成绩 int DEFAULT NULL, 身高 int DEFAULT NULL, 手机 varchar(20) DEFAULT NULL, PRIMARY KEY (学号) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;

向student表添加数据

INSERT INTO student (学号,姓名,性别,班级,年龄,成绩,身高,手机) VALUES (1,'张一','男',1701,16,78,170,18946554571), (2,'李二','男',1701,17,80,175,18946554572), (3,'谢逊','男',1702,18,95,169,18946554573), (4,'赵玲','女',1702,19,86,180,18956257895), (5,'张明','男',1704,20,85,185,18946554575), (6,'张三','女',1704,18,92,169,18946554576);

创建student_cdc表

CREATE TABLE student_cdc ( 学号 int NOT NULL, 姓名 varchar(45) DEFAULT NULL, 性别 varchar(45) DEFAULT NULL, 班级 int DEFAULT NULL, 年龄 int DEFAULT NULL, 成绩 int DEFAULT NULL, 身高 int DEFAULT NULL, 手机 varchar(20) DEFAULT NULL, 插入时间 varchar(20) DEFAULT NULL, 更新时间 varchar(20) DEFAULT NULL, PRIMARY KEY (学号) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;

添加数据

INSERT INTO student_cdc (学号,姓名,性别,班级,年龄,成绩,身高,手机,插入时间,更新时间) VALUES (1,'张一','男',1701,16,78,170,18946554571,'2022-10-01','2022-10-01'), (2,'李二','男',1701,17,80,175,18946554572,'2022-10-01','2022-10-01'), (3,'谢逊','男',1702,18,95,169,18946554573,'2022-10-01','2022-10-01'), (4,'赵玲','女',1702,19,86,180,18956257895,'2022-10-01','2022-10-01'), (5,'张明','男',1704,20,85,185,18946554575,'2022-10-15','2022-10-15'), (6,'张三','女',1704,18,92,169,18946554576,'2022-10-01','2022-10-15');

创建表

CREATE TABLE cdc_time_log ( ID int NOT NULL AUTO_INCREMENT, 上次执行时间 varchar(20) DEFAULT NULL, PRIMARY KEY (ID) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;

创建表

CREATE TABLE cdc_seq_log ( ID int NOT NULL AUTO_INCREMENT, 上次执行序列 int DEFAULT 0, PRIMARY KEY (ID) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;

创建表

CREATE TABLE student_cdc_sync ( ID int NOT NULL, 学号 int NOT NULL, 姓名 varchar(45) DEFAULT NULL, 性别 varchar(45) DEFAULT NULL, 班级 int DEFAULT NULL, 年龄 int DEFAULT NULL, 成绩 int DEFAULT NULL, 身高 int DEFAULT NULL, 手机 varchar(20) DEFAULT NULL, 插入时间 varchar(20) DEFAULT NULL, 更新时间 varchar(20) DEFAULT NULL, 导入时间 varchar(20) DEFAULT NULL, PRIMARY KEY (ID) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;

创建表

CREATE TABLE cdc_opt_log ( ID int NOT NULL, 学号 int NOT NULL, 操作 varchar(45) DEFAULT NULL, 处理标志 varchar(45) DEFAULT NULL, PRIMARY KEY (ID) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;

添加数据

INSERT INTO student_cdc_sync (ID,学号,姓名,性别,班级,年龄,成绩,身高,手机,插入时间,更新时间,导入时间) VALUES (1,1,'张一','男',1701,16,78,170,18946554571,'2022-10-01','2022-10-01','2022-10-01'), (2,2,'李二','男',1701,17,80,175,18946554572,'2022-10-01','2022-10-01','2022-10-01'), (3,3,'谢逊','男',1702,18,95,169,18946554573,'2022-10-01','2022-10-01','2022-10-01'), (4,4,'赵玲','女',1702,19,86,180,18956257895,'2022-10-01','2022-10-01','2022-10-01'), (5,5,'张明','男',1704,20,85,185,18946554575,'2022-10-15','2022-10-15','2022-10-15'), (6,6,'张三','女',1704,18,92,169,18946554576,'2022-10-01','2022-10-15','2022-10-15');

添加数据

INSERT INTO cdc_opt_log (ID,学号,操作,处理标志) VALUES (1,1,'新增','未处理'), (2,2,'新增','未处理'), (3,3,'新增','未处理'), (4,4,'新增','未处理'), (5,5,'新增','未处理'), (6,6,'新增','未处理');

MySQL CDC数据同步实战:创建表及添加数据

原文地址: https://www.cveoy.top/t/topic/ft1v 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录