在現代應用程序中，數據同步是至關重要的。在應用程序中，有時需要將數據從一個數據庫系統同步到另一個，以便在兩個數據庫之間共享數據。MySQL和SQL Server是最流行的數據庫系統之一。在這篇文章中，我們將學習如何使用實時同步工具將MySQL數據實時同步到SQL Server。

--創建source數據庫
CREATE DATABASE source;
--創建person表
CREATE TABLE source.person (
id INT PRIMARY KEY AUTO_INCREMENT,
name VARCHAR(50),
age INT
);
--插入測試數據
INSERT INTO source.person (name,age) VALUES ('張三',18),('李四',20);

要將MySQL數據實時同步到SQL Server，第一步是使用ODBC驅動程序連接到兩個數據庫系統。然后，我們可以使用Microsoft的SQL Server Integration Services（SSIS）來設計和執行數據同步任務。

--安裝ODBC驅動程序
sudo apt-get install unixodbc unixodbc-dev
--安裝MySQL ODBC驅動程序
sudo apt-get install libmyodbc
--連接MySQL數據庫
odbcinst -i -d -f /etc/odbcinst.ini
--連接SQL Server數據庫
odbcinst -i -d -f /etc/odbcinst.ini

在SSIS中，我們可以使用“Data Flow Task”來傳輸數據。首先，我們需要在“Connection Managers”中創建兩個連接：一個是連接到MySQL，另一個是連接到SQL Server。然后，我們創建一個“Data Flow Task”，并將源轉換為“OLE DB Source”，將目標轉換為“SQL Server Destination”。

--創建MySQL連接
Data Source=myServerAddress;User Id=myUsername;Password=myPassword;
--創建SQL Server連接
Data Source=myServerAddress;Initial Catalog=myDataBase;User ID=myUsername;Password=myPassword;

在“Data Flow Task”中，我們可以使用“Data Conversion”轉換來確保數據類型的兼容性。然后，我們使用“Derived Column”轉換來添加目標數據表的列。

--Data Conversion
SELECT CAST(id AS bigint) as id, CONVERT(VARCHAR(50),name) as name, CAST(age AS real) as age FROM source.person;
--Derived Column
SELECT id, name, age, GETDATE() as inserted_date FROM source.person;

最后，我們使用“SQL Server Destination”向目標數據庫中寫入數據。在此過程中，我們可以設置檢查點，以便在將來執行數據同步任務時跳過已同步的行。此外，我們還可以將錯誤行轉到另一個目標表或文件中，用于以后的處理。

--設置檢查點
SELECT TOP 1 inserted_date FROM target.person ORDER BY inserted_date DESC
--轉換錯誤的行
SELECT * INTO target.person_error FROM target.person WHERE age IS NULL

在本文中，我們學習了如何使用ODBC驅動程序連接到MySQL和SQL Server。然后，我們學習了如何使用SSIS來設計和執行MySQL數據的實時同步任務。此外，我們還學習了如何設置檢查點和轉換錯誤的行，以便在未來的數據同步任務中處理它們。