在企業級應用中，常常需要將MySQL數據庫的數據同步到SQL Server數據庫中，以便更好地進行數據分析和業務處理。本文介紹如何通過使用Java編寫的ETL（Extract-Transform-Load）工具來實現MySQL數據庫的實時同步到SQL Server數據庫中。

首先，我們需要創建兩個數據庫——一個MySQL數據庫，一個SQL Server數據庫，并且需要在兩個數據庫中分別創建一個表以便于數據的同步。

CREATE TABLE `customer` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`name` varchar(50) DEFAULT NULL,
`age` int(11) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

CREATE TABLE [dbo].[customer](
[id] [int] IDENTITY(1,1) NOT NULL,
[name] [varchar](50) NULL,
[age] [int] NULL,
CONSTRAINT [PK_customer] PRIMARY KEY CLUSTERED 
(
[id] ASC
)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON) ON [PRIMARY]
) ON [PRIMARY]

接下來，我們需要使用Java編寫一個ETL工具來實現MySQL數據庫的實時同步到SQL Server數據庫中。

public class MySql2SqlServerETL {
public static void main(String[] args) throws SQLException {
Connection sourceConn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "password");
Connection targetConn = DriverManager.getConnection("jdbc:sqlserver://localhost:1433;DatabaseName=test", "sa", "password");
sourceConn.setAutoCommit(false);
targetConn.setAutoCommit(false);
try {
Statement sourceStmt = sourceConn.createStatement();
Statement targetStmt = targetConn.createStatement();
ResultSet sourceRs = sourceStmt.executeQuery("select * from customer");
while (sourceRs.next()) {
int id = sourceRs.getInt("id");
String name = sourceRs.getString("name");
int age = sourceRs.getInt("age");
String targetSql = "insert into customer (name, age) values ('" + name + "', " + age + ")";
targetStmt.executeUpdate(targetSql);
}
targetConn.commit();
sourceConn.commit();
} catch (Exception e) {
System.out.println(e.getMessage());
targetConn.rollback();
sourceConn.rollback();
} finally {
sourceConn.close();
targetConn.close();
}
}
}

最后，我們需要使用定時任務來定時地執行ETL工具，以實時同步MySQL數據庫的數據到SQL Server數據庫中。

通過以上操作，我們成功地實現了MySQL數據庫的實時同步到SQL Server數據庫中，為企業級應用的數據分析和業務處理提供了更好的基礎支持。