本文介绍了如何在 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 %sn", username)     } }

代码解释：

1. 数据库连接： sql.Open(“mysql“, “user:password@tcp(localhost:3306)/”) 连接到 MySQL 服务器，注意连接字符串中没有指定默认数据库。这是因为我们将直接在 SQL 查询中指定数据库名称。
2. 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.
3. 参数化查询： 使用 ? 作为占位符，并通过 db.QueryRow 的参数传入 id 变量，可以防止 SQL 注入。
4. 结果处理： Scan(&username) 将查询结果赋值给 username 变量。 通过 switch 语句处理查询结果，包括未找到记录的情况 (sql.ErrNoRows) 和其他错误情况。

注意事项：

蓝心千询

蓝心千询是vivo推出的一个多功能AI智能助手

34

查看详情

• 确保 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 语句中指定数据库名称，可以轻松地在不同数据库的表之间建立关联，检索所需数据。 这种方法避免了复杂的应用层逻辑，并充分利用了数据库服务器的优化能力。