# Seatunnel-关系型数据库同步示例

本示例主要介绍 Seatunnel 处理引擎下，使用关系型数据库进行单表迁移、多表数据迁移、整库数据迁移的全量同步场景。

单表迁移：将关系型数据源的一张表的数据迁移到另一个数据源。

多表迁移：将关系型数据源的多张表的数据迁移到另一个数据源。

整库迁移：将关系型数据源的所有表的数据迁移到另一个数据源。

主要步骤如下：

准备数据
新建通用模板作业
配置数据源/库
配置表名映射
同步配置
通用配置
保存草稿
运行
提交版本

# 准备数据

以 MySQL 数据库为例。创建两个数据库：dws_source_dev、dws_front_dev，在数据库 dws_source_dev 中创建一个表 t_xueji。

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for t_xueji
-- ----------------------------
DROP TABLE IF EXISTS `t_xueji`;
CREATE TABLE `t_xueji` (
  `id` int(11) DEFAULT NULL,
  `xuehao` varchar(255) DEFAULT NULL,
  `banji` varchar(255) DEFAULT NULL,
  `xueji` varchar(255) DEFAULT NULL,
  `xingbie` int(11) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

-- ----------------------------
-- Records of t_xueji
-- ----------------------------
BEGIN;
INSERT INTO `t_xueji` (`id`, `xuehao`, `banji`, `xueji`, `xingbie`) VALUES (1, '2023-0001', '1班', 'H', 1);
INSERT INTO `t_xueji` (`id`, `xuehao`, `banji`, `xueji`, `xingbie`) VALUES (2, '2023-0002', '1班', 'H', 1);
INSERT INTO `t_xueji` (`id`, `xuehao`, `banji`, `xueji`, `xingbie`) VALUES (3, '2023-0003', '1班', 'H', 0);
INSERT INTO `t_xueji` (`id`, `xuehao`, `banji`, `xueji`, `xingbie`) VALUES (4, '2023-0004', '1班', 'H', 0);
INSERT INTO `t_xueji` (`id`, `xuehao`, `banji`, `xueji`, `xingbie`) VALUES (5, '2023-0005', '1班', 'H', 1);
INSERT INTO `t_xueji` (`id`, `xuehao`, `banji`, `xueji`, `xingbie`) VALUES (6, '2023-0006', '1班', 'X', 0);
INSERT INTO `t_xueji` (`id`, `xuehao`, `banji`, `xueji`, `xingbie`) VALUES (7, '2023-0007', '1班', 'X', 0);
INSERT INTO `t_xueji` (`id`, `xuehao`, `banji`, `xueji`, `xingbie`) VALUES (8, '2023-0008', '1班', 'X', 1);
INSERT INTO `t_xueji` (`id`, `xuehao`, `banji`, `xueji`, `xingbie`) VALUES (9, '2023-0009', '1班', 'X', 0);
INSERT INTO `t_xueji` (`id`, `xuehao`, `banji`, `xueji`, `xingbie`) VALUES (10, '2023-0010', '1班', 'X', 2);

COMMIT;

SET FOREIGN_KEY_CHECKS = 1;