如何同步mysql数据到Doris中

Doris官网定义 mysql原始表结构 1.doris中关联mysql外表 结果如下： 2.doris中关联kafka导入数据 查看作业 State为RUNNING，表示已经成功。 停止作业 3.通过flink导入mysql数据到doris 方法1：通过mysql-cdc写入kafka，kafka关联doris表。 方法2：通过阿里云DTS->datahub，然后通过Flink写入kafka，再关联到doris外表 如何处理delete数据？对于方法1，需要手动的删除doris中的数据；对于方法2，可以通过dts_operation_flag字段来标示，dts_operation_flag可以为I/U/D，分别表示添加、更新和删除。那我们就只需要在doris表中添加一个dts_operation_flag字段来标示就可以了，查询数据的时候就不再查询等于D的值。 如何处理脏数据？delete doris中的数据，然后insert正确的值；还有个方法是将关联一个外表（这个是正确的值），然后再将doris中的表和外表中的值diff，将diff的值insert到doris中。

附加数据库

或者导入数据库

sql本身有数据导入的 *** 作。但如果要从一个备份的文件中导入数据，则要进行另外的 *** 作。下面以一个例子进行说明。

sql服务器上已有一个doe数据库，并且里面有大量的数据，现准备从另外一个备份文件a1.bak（不是doe数据库的备份文件）中导入另外的数据（即导入后在doe中增加一些数据表，表中已录有数据），并保持原doe的数据不变。

1、首先，在“sql企业管理器”中新建一个临时数据库a1。

2、右击a1数据库，选择：所有任务－＞还原数据库。

3、在“还原数据库”窗口中，选择：“从设备”。

4、点击“选择设备”。

5、点击“添加”。

6、从文件名中选择要还原的数据库文件，如a1.bak。

7、点击“确定”，返回“还原数据库”窗口。

8、点击“选项”卡，进入选项设置。

9、钩选：“在现有数据库上强制还原”。

10、修改“移到物理文件名”为：“c:\a1.ldf”、“c:\a1.mdf”。

11、点确定，即可导入备份文件中的数据到临时数据库a1中。

12、此时，你可以将数据从a1导入到另外一真正要导入的数据库中，如doe数据库。

（下面的数据导入 *** 作为sql2000企业管理器的一般数据导入导出 *** 作。）

13、在“sql企业管理器”中选择“doe”数据库。

14、右击doe数据库，选择：所有任务－＞导入数据。

15、在“dts导入/导出向导”窗口的“选择数据源”中，数据源选择刚才建立并导入数据的临时数据库a1。点击下一步。

16、在“选择目的”中，系统已经默认为doe数据库。

17、连续点击“下一步”，直到完成。

经过上面的 *** 作，你已经成功地将备份文件a1.bak中数据导入doe数据库中，并且doe数据库原有数据不变。

此时，你可以删除临时数据库a1。

---