Go语言连接多个MySQL数据库的方法示例

随着互联网应用的不断发展，数据量和数据处理速度也越来越大。为了更容易地管理这些数据，常常需要使用多个数据库来存储和处理数据。Go语言作为一门高效的编程语言，在处理大规模数据时也备受青睐。本文将介绍如何使用Go语言连接多个MySQL数据库。

一、准备工作

1. 安装Go语言

首先，我们需要在本机上安装Go语言，此处不再赘述。

2. 安装MySQL驱动

使用Go语言连接MySQL需要安装驱动，并且以import的方式引用该驱动。

可以通过以下命令来安装MySQL驱动：

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

3. 准备MySQL数据库

在本地MySQL上创建两个数据库，这里分别命名为db1和db2。为了方便后续操作，我们在每个数据库中创建一个名为user的表，并在里面插入一些测试数据。

二、连接多个MySQL数据库

使用Go语言连接MySQL数据库非常简单。您只需要传递一些参数即可实现连接。以下是连接单个MySQL数据库的示例代码：

package main

import (
    "database/sql"
    "fmt"
    "log"

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

func main() {
    db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/db1")
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close()

    rows, err := db.Query("SELECT * FROM user")
    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)
        }
        fmt.Println(id, name)
    }

    err = rows.Err()
    if err != nil {
        log.Fatal(err)
    }
}

上述代码打开名为db1的MySQL数据库，然后查找名为user的表中的数据。 它打印的结果如下：

1 John
2 Jane
3 Mike
4 Lucy

如果要连接多个MySQL数据库，我们可以维护多个sql.DB连接。以下是连接两个MySQL数据库的示例代码：

package main

import (
    "database/sql"
    "fmt"
    "log"

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

func main() {
    db1, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/db1")
    if err != nil {
        log.Fatal(err)
    }
    defer db1.Close()

    rows1, err := db1.Query("SELECT * FROM user")
    if err != nil {
        log.Fatal(err)
    }
    defer rows1.Close()

    fmt.Println("Database1:")

    for rows1.Next() {
        var id int
        var name string
        err = rows1.Scan(&id, &name)
        if err != nil {
            log.Fatal(err)
        }
        fmt.Println(id, name)
    }

    err = rows1.Err()
    if err != nil {
        log.Fatal(err)
    }

    db2, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/db2")
    if err != nil {
        log.Fatal(err)
    }
    defer db2.Close()

    rows2, err := db2.Query("SELECT * FROM user")
    if err != nil {
        log.Fatal(err)
    }
    defer rows2.Close()

    fmt.Println("Database2:")

    for rows2.Next() {
        var id int
        var name string
        err = rows2.Scan(&id, &name)
        if err != nil {
            log.Fatal(err)
        }
        fmt.Println(id, name)
    }

    err = rows2.Err()
    if err != nil {
        log.Fatal(err)
    }
}

通过上述代码，我们可以连接名为db1和db2的两个MySQL数据库，然后查找名为user的表中的数据。它打印的结果如下：

Database1:
1 John
2 Jane
3 Mike
4 Lucy
Database2:
1 Tom
2 Jerry
3 Lisa
4 Sara

三、总结

本文介绍了如何使用Go语言连接多个MySQL数据库。我们只需要维护多个sql.DB连接即可轻松连接并查询多个MySQL数据库中的数据。接下来您可以根据需要通过使用Go语言来管理您自己的数据。