我要投稿

Golang框架如何集成Google Cloud SQL数据库？

资讯主编 Go

2024-08-11 0 546

在 go 应用程序中集成 google cloud sql 数据库涉及使用流行的 go 框架，例如 gORM 和 x/sql，与 cloud sql 数据库建立连接。这些框架提供便捷的方法来管理数据库连接和执行 crud 操作。通过使用 gorm 或 x/sql 与 cloud sql 建立连接，可以轻松访问和管理云中的关系数据库。

Go框架中集成Google Cloud SQL数据库

简介

在Go应用程序中集成Google Cloud SQL数据库是访问和管理云中关系数据库的必要步骤。本文将向你展示如何使用流行的Go框架，例如GORM和x/sql，与Cloud SQL数据库建立连接。

立即学习“go语言免费学习笔记（深入）”；

先决条件

安装Go并配置Go路径
创建Cloud SQL实例
为Cloud SQL创建服务账号

使用GORM

GORM是一个流行的ORM，它提供了一个与数据库交互的简单、直观的接口。要使用GORM与Cloud SQL连接，请执行以下步骤：

import (
    "context"
    "fmt"
    "io"

    "Github.com/jinzhu/gorm"
    _ "github.com/jinzhu/gorm/dialects/Mysql"
)

// connectToCloudSQL establishes a connection to the Cloud SQL instance,
// using GORM and the provided database connection parameters.
func connectToCloudSQL(w io.Writer, dbuser, dbPwd, dbName string) (*gorm.DB, error) {
    // Note: Saving credentials in.environment variables is convenient, but not
    // secure - consider a more secure solution such as
    // Cloud Secret Manager (HTTPs://cloud.google.com/secret-manager) to help
    // keep secrets safe.
    var (
        dbUser    = os.Getenv("DB_USER")      // e.g. 'my-db-user'
        dbPwd     = os.Getenv("DB_PASS")      // e.g. 'my-db-password'
        dbName     = os.Getenv("DB_NAME")      // e.g. 'my-database'
        dbPort     = os.Getenv("DB_PORT")      // e.g. '3306'
        dbTCPHost = os.Getenv("INSTANCE_HOST") // e.g. '127.0.0.1' ('172.17.0.1' if deployed to GAE Flex)
    )

    dbURI := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?parseTime=true",
        dbUser, dbPwd, dbTCPHost, dbPort, dbName)

    // dbPool is the pool of database connections.
    dbPool, err := gorm.Open("mysql", dbURI)
    if err != nil {
        return nil, fmt.Errorf("gorm.Open: %v", err)
    }

    configureDB(dbPool)

    _, err = createTable(dbPool, w)
    if err != nil {
        return nil, fmt.Errorf("createTable: %v", err)
    }

    return dbPool, nil
}

使用x/sql

x/sql是Go标准库中用于直接与数据库交互的包。使用x/sql与Cloud SQL建立连接，请执行以下步骤：

import (
    "context"
    "database/sql"
    "fmt"
    "io"

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

// connectWithXSQL establishes a connection to the Cloud SQL instance,
// using the x/sql package and the provided database connection parameters.
func connectWithXSQL(w io.Writer, dbUser, dbPwd, dbName string) (*sql.DB, error) {
    var (
        dbUser    = os.Getenv("DB_USER")      // e.g. 'my-db-user'
        dbPwd     = os.Getenv("DB_PASS")      // e.g. 'my-db-password'
        dbName     = os.Getenv("DB_NAME")      // e.g. 'my-database'
        dbPort     = os.Getenv("DB_PORT")      // e.g. '3306'
        dbTCPHost = os.Getenv("INSTANCE_HOST") // e.g. '127.0.0.1' ('172.17.0.1' if deployed to GAE Flex)
    )

    dbURI := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?parseTime=true",
        dbUser, dbPwd, dbTCPHost, dbPort, dbName)

    // dbPool is the pool of database connections.
    dbPool, err := sql.Open("mysql", dbURI)
    if err != nil {
        return nil, fmt.Errorf("sql.Open: %v", err)
    }

    configureDB(dbPool, w)

    _, err = createTable(dbPool, w)
    if err != nil {
        return nil, fmt.Errorf("createTable: %v", err)
    }

    return dbPool, nil
}

实战案例

以下是一个使用GORM与Cloud SQL数据库进行交互的实际示例：

func main() {
    ctx := context.Background()
    dbPool, err := connectToCloudSQL(os.Stdout, "user", "password", "test")
    if err != nil {
        log.Fatal(err)
    }
    defer dbPool.Close()

    type User struct {
        ID   int `gorm:"primary_key"`
        Name string
    }

    // Migrate the schema
    dbPool.AutoMigrate(&User{})

    // Create
    user := User{Name: "John"}
    dbPool.Create(&user)

    // Read
    var retrievedUser User
    dbPool.First(&retrievedUser, user.ID)
    fmt.Fprintf(os.Stdout, "Retrieved user: %+v\n", retrievedUser)

    // Update
    dbPool.Model(&retrievedUser).Update("Name", "Jane")

    // Delete
    dbPool.Delete(&retrievedUser)
}

登录后复制

收藏 (0) 打赏

感谢您的支持，我会继续努力的!

打开微信/支付宝扫一扫，即可进行扫码打赏哦，分享从这里开始，精彩与您同在

免责声明
1. 本站所有资源来源于用户上传和网络等，如有侵权请邮件联系本站整改team@lcwl.fun！
2. 分享目的仅供大家学习和交流，您必须在下载后24小时内删除！
3. 不得使用于非法商业用途，不得违反国家法律。否则后果自负！
4. 本站提供的源码、模板、插件等等其他资源，都不包含技术服务请大家谅解！
5. 如有链接无法下载、失效或广告，请联系本站工作人员处理！
6. 本站资源售价或VIP只是赞助，收取费用仅维持本站的日常运营所需！
7. 如遇到加密压缩包，请使用WINRAR解压，如遇到无法解压的请联系管理员！
8. 因人力时间成本问题，部分源码未能详细测试（解密），不能分辨部分源码是病毒还是误报，所以没有进行任何修改，大家使用前请进行甄别！
9.本站所有源码资源都是经过本站工作人员人工亲测可搭建的，保证每个源码都可以正常搭建，但不保证源码内功能都完全可用，源码属于可复制的产品，无任何理由退款！

网站搭建学习网 Go Golang框架如何集成Google Cloud SQL数据库？ https://www.xuezuoweb.com/10706.html