本文介绍了如何在 Golang 中使用 SQL JOIN 语句跨多个 MySQL 数据库进行查询。通过直接在 SQL 查询中指定数据库名称，可以轻松地在不同数据库的表之间建立关联，检索所需数据。同时，也简要讨论了使用多个数据库连接的替代方案，并强调了使用 JOIN 语句的效率优势。
在 Golang 中，有时需要跨多个数据库进行查询，例如，关联 db1 数据库的 users 表和 db2 数据库的 comments 表，基于 db1.users.id = db2.comments.username_id 关系。 直接使用 SQL JOIN 语句可以实现这一目标，而无需复杂的应用层逻辑。
使用 JOIN 语句跨数据库查询
对于 MySQL 数据库，可以在 SQL 查询中直接指定数据库名称和表名，从而实现跨数据库的 JOIN 操作。 以下是一个示例：
立即学习“go语言免费学习笔记（深入）”；
package main
import (
"database/sql"
"fmt"
"log"
_ "github.com/go-sql-driver/mysql"
)
func main() {
db, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/") // 连接到 MySQL 服务器，但不指定默认数据库
if err != nil {
log.Fatal(err)
}
defer db.Close()
id := 123
var username string
err = db.QueryRow(`
SELECT
db1.users.username
FROM
db1.users
JOIN
db2.comments
ON db1.users.id = db2.comments.username_id
WHERE
db1.users.id = ?
`, id).Scan(&username)
switch {
case err == sql.ErrNoRows:
log.Printf("No user with that ID.")
case err != nil:
log.Fatal(err)
default:
fmt.Printf("Username is %s\n", username)
}
}代码解释：
- 数据库连接： sql.Open("mysql", "user:password@tcp(localhost:3306)/") 连接到 MySQL 服务器，注意连接字符串中没有指定默认数据库。这是因为我们将直接在 SQL 查询中指定数据库名称。
- SQL 查询： SELECT db1.users.username FROM db1.users JOIN db2.comments ON db1.users.id = db2.comments.username_id WHERE db1.users.id = ? 这条 SQL 语句跨 db1 和 db2 两个数据库进行 JOIN 操作。 db1.users 和 db2.comments 分别指定了数据库和表名。 ON db1.users.id = db2.comments.username_id 定义了 JOIN 的条件。 WHERE db1.users.id = ? 筛选特定的用户ID.
- 参数化查询： 使用 ? 作为占位符，并通过 db.QueryRow 的参数传入 id 变量，可以防止 SQL 注入。
- 结果处理： Scan(&username) 将查询结果赋值给 username 变量。 通过 switch 语句处理查询结果，包括未找到记录的情况 (sql.ErrNoRows) 和其他错误情况。
注意事项：
- 确保 MySQL 用户具有访问 db1 和 db2 数据库的权限。
- 连接字符串中的用户密码需要正确配置。
- SQL 语句中的数据库和表名需要与实际情况一致。
- 强烈建议使用参数化查询来防止 SQL 注入。
替代方案：多个数据库连接
另一种方法是分别建立与 db1 和 db2 的数据库连接，然后分别执行查询，并在应用层进行关联。 例如：
// 不推荐的方式
db1, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/db1")
if err != nil {
log.Fatal(err)
}
defer db1.Close()
db2, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/db2")
if err != nil {
log.Fatal(err)
}
defer db2.Close()
// 查询 db2.comments 获取所有 username_id
// 然后在应用层循环查询 db1.users
这种方法不推荐，因为数据库服务器通常比应用层更擅长执行 JOIN 操作，效率更高。
总结
使用 SQL JOIN 语句直接跨多个数据库进行查询是一种高效且简洁的方法。 通过在 SQL 语句中指定数据库名称，可以轻松地在不同数据库的表之间建立关联，检索所需数据。 这种方法避免了复杂的应用层逻辑，并充分利用了数据库服务器的优化能力。
