Go語言中，可以使用database/sql包結合相應的數據庫驅動來完成MySQL數據庫的數據遷移。以下是一個基本的步驟指南：

1. 安裝必要的包： 確保你已經安裝了Go語言的MySQL驅動，如go-sql-driver/mysql。你可以使用以下命令來安裝它：

go get -u github.com/go-sql-driver/mysql

2. 連接到源數據庫和目標數據庫： 使用database/sql包中的Open函數來連接到源數據庫和目標數據庫。你需要提供相應的數據庫驅動名稱、用戶名、密碼、主機地址等信息。

import (
 "database/sql"
 _ "github.com/go-sql-driver/mysql"
)

func main() {
 sourceDB, err := sql.Open("mysql", "user:password@tcp(source_host:port)/source_db")
 if err != nil {
 log.Fatal(err)
 }
 defer sourceDB.Close()

 targetDB, err := sql.Open("mysql", "user:password@tcp(target_host:port)/target_db")
 if err != nil {
 log.Fatal(err)
 }
 defer targetDB.Close()
}

3. 執行數據遷移： 你可以編寫SQL查詢語句或使用Go語言中的Query方法來執行數據遷移。以下是一個簡單的示例，演示了如何從源數據庫中選擇數據并將其插入到目標數據庫中：

// 查詢源數據庫中的數據
rows, err := sourceDB.Query("SELECT * FROM source_table")
if err != nil {
 log.Fatal(err)
}
defer rows.Close()

// 遍歷查詢結果并插入到目標數據庫中
for rows.Next() {
 var id int
 var name string
 err := rows.Scan(&id, &name)
 if err != nil {
 log.Fatal(err)
 }

 // 插入數據到目標數據庫
 _, err = targetDB.Exec("INSERT INTO target_table (id, name) VALUES (?, ?)", id, name)
 if err != nil {
 log.Fatal(err)
 }
}

// 檢查查詢過程中是否發生錯誤
if err = rows.Err(); err != nil {
 log.Fatal(err)
}

請注意，上述示例僅用于演示目的，實際的數據遷移可能需要更復雜的邏輯，例如處理數據轉換、刪除源表中的某些記錄等。

4. 處理事務和錯誤： 為了確保數據的一致性和完整性，你可能需要將數據遷移過程包裝在一個事務中。此外，你還應該妥善處理可能發生的錯誤，并在必要時回滾事務。

// 開始事務
tx, err := targetDB.Begin()
if err != nil {
 log.Fatal(err)
}

// 執行數據遷移操作
_, err = tx.Exec("INSERT INTO target_table (id, name) VALUES (?, ?)", id, name)
if err != nil {
 // 發生錯誤時回滾事務
 tx.Rollback()
 log.Fatal(err)
 }

// 提交事務
err = tx.Commit()
if err != nil {
 log.Fatal(err)
}

5. 優化和擴展： 根據你的需求和數據量，你可能需要進一步優化和擴展數據遷移腳本。例如，你可以使用并發來加速數據插入過程，或者將數據遷移過程分解為多個步驟以逐步完成遷移。

總之，Go語言提供了靈活且強大的工具來執行MySQL數據庫的數據遷移。通過結合database/sql包和相應的數據庫驅動，你可以編寫出高效且可靠的數據遷移腳本。