go - 不知道如何使用 GORM 的 DBResolver

标签 go replication go-gorm

import (
    "github.com/jinzhu/gorm"
    _ "github.com/jinzhu/gorm/dialects/mysql"
    "server/config"
    "gorm.io/plugin/dbresolver"
)
    
func DB(config *config.Config) {
    var err error

    config.DB, err = gorm.Open("mysql", config.DBDSN)
    if err != nil {
        panic(err)
    }


    if !config.IsDev {
        config.DB.Use(dbresolver.Register(dbresolver.Config{
            Replicas: []gorm.Dialector{mysql.Open("mysql", config.DBDSN2)},
        }))
    }

}

我正在尝试使用 GORM 的 DBresolver 来利用我的云 SQL 实例的只读副本。我认为我使用的 GORM 包和 DBresolver 插件存在一些版本控制问题。当我运行上面的代码时,出现以下错误:

  • config.DB.使用未定义(类型*“github.com/jinzhu/gorm”。DB没有 字段或方法使用)
  • 未定义:“github.com/jinzhu/gorm”.方言

我在网上找不到任何原因,而且关于 GORM 高级功能的在线资源也很少。如果我创建一个单独的连接,我可以轻松地让副本工作,但这样我每次与数据库交互时都需要指定数据库。 我使用以下代码来实现上面的代码:https://gorm.io/docs/dbresolver.html

最佳答案

您正在使用 gorm 的 v1 导入路径,但 DBResolver 是 V2 功能。 您需要使用:

  • “gorm.io/gorm” 主导入包
  • “gorm.io/driver/mysql” 用于驱动程序导入
  • gorm.Openmysql.Open 用于创建连接。
  • V2 基本上向后兼容,但您需要确保所有旧代码都经过测试才能在新版本上运行。
import (
    "gorm.io/gorm"
    "gorm.io/driver/mysql"
    "gorm.io/plugin/dbresolver"
    "server/config"
)
    
func DB(config *config.Config) {
    var err error

    config.DB, err := gorm.Open(mysql.Open(config.DBDSN), &gorm.Config{})
    if err != nil {
        panic(err)
    }


    if !config.IsDev {
        config.DB.Use(dbresolver.Register(dbresolver.Config{
            Replicas: []gorm.Dialector{mysql.Open("mysql", config.DBDSN2)},
        }))
    }
}

关于go - 不知道如何使用 GORM 的 DBResolver,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/66512547/

相关文章:

Gorm 按关联计数排序

mysql - 在 mysql 中使用 gorm 插入类型 []byte 引发 "Error 1241: Operand should contain 1 columns(s)"

go - 如何使用 "crypto/rand"包生成随机整数?

go - Go中限制并发的简单方法

go - http.NewRequest() 解码我的 URL 输入

elasticsearch - 复制 Elasticsearch 主分片

PostgreSQL 同步复制一致性

algorithm - 为什么我的红黑树实现基准测试显示线性时间复杂度?

Postgresql 9.2 故障转移

sql-server - 使用gorm错误连接到sql server命名实例,主机名中出现无效字符 "\\"