Go 中的数据库交互：从 SQL 到 NoSQL

php中文网 2024-10-15 11:47:51

介绍

go (golang) 已成为构建健壮、高性能后端服务的流行选择。 go 的主要优势之一是它对数据库操作的出色支持，无论您使用传统 sql 数据库还是现代 nosql 解决方案。在本指南中，我们将探索如何在 go 中与数据库交互，涵盖 sql 和 nosql 方法。

sql 数据库交互

使用database/sql包

go 的标准库提供了 database/sql 包，它提供了围绕 sql（或类似 sql）数据库的通用接口。该软件包旨在与特定于数据库的驱动程序结合使用。

让我们从一个使用 sqlite 的简单示例开始：

package main

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

func main() {
    // open the database
    db, err := sql.open("sqlite3", "./test.db")
    if err != nil {
        log.fatal(err)
    }
    defer db.close()

    // create table
    _, err = db.exec(`create table if not exists users (
        id integer primary key autoincrement,
        name text,
        age integer
    )`)
    if err != nil {
        log.fatal(err)
    }

    // insert a user
    result, err := db.exec("insert into users (name, age) values (?, ?)", "alice", 30)
    if err != nil {
        log.fatal(err)
    }

    // get the id of the inserted user
    id, err := result.lastinsertid()
    if err != nil {
        log.fatal(err)
    }
    fmt.printf("inserted user with id: %dn", id)

    // query for the user
    var name string
    var age int
    err = db.queryrow("select name, age from users where id = ?", id).scan(&amp;name, &amp;age)
    if err != nil {
        log.fatal(err)
    }
    fmt.printf("user: %s, age: %dn", name, age)
}

此示例演示了在 go 中使用 sql 数据库的基础知识：

打开数据库连接
创建表格
插入数据
查询数据

database/sql 包提供了数据库的低级接口，让您可以很好地控制查询和操作。

使用 orm：gorm

虽然database/sql包很强大，但许多开发人员更喜欢使用对象关系映射（orm）工具来更方便地进行数据库操作。 gorm 是 go 中最受欢迎的 orm 之一。

这是一个将 gorm 与 sqlite 结合使用的示例：

package main

import (
    "fmt"
    "log"

    "gorm.io/driver/sqlite"
    "gorm.io/gorm"
)

type user struct {
    id   uint
    name string
    age  int
}

func main() {
    // open the database
    db, err := gorm.open(sqlite.open("test.db"), &amp;gorm.config{})
    if err != nil {
        log.fatal(err)
    }

    // auto migrate the schema
    db.automigrate(&amp;user{})

    // create a user
    user := user{name: "bob", age: 25}
    result := db.create(&amp;user)
    if result.error != nil {
        log.fatal(result.error)
    }
    fmt.printf("inserted user with id: %dn", user.id)

    // query for the user
    var fetcheduser user
    db.first(&amp;fetcheduser, user.id)
    fmt.printf("user: %s, age: %dn", fetcheduser.name, fetcheduser.age)

    // update the user
    db.model(&amp;fetcheduser).update("age", 26)

    // delete the user
    db.delete(&amp;fetcheduser)
}

gorm 提供了对数据库操作的更高级别的抽象，允许您直接使用 go 结构，而不是编写原始 sql 查询。它还提供自动迁移、挂钩和关联等功能。

nosql 数据库交互

mongodb 与官方 go 驱动程序

对于nosql数据库，我们来看看如何使用官方go驱动与mongodb交互：

package main

import (
    "context"
    "fmt"
    "log"
    "time"

    "go.mongodb.org/mongo-driver/bson"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
)

type User struct {
    Name string `bson:"name"`
    Age  int    `bson:"age"`
}

func main() {
    // Set client options
    clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")

    // Connect to MongoDB
    ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    defer cancel()
    client, err := mongo.Connect(ctx, clientOptions)
    if err != nil {
        log.Fatal(err)
    }

    // Check the connection
    err = client.Ping(context.TODO(), nil)
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("Connected to MongoDB!")

    // Get a handle for your collection
    collection := client.Database("test").Collection("users")

    // Insert a user
    user := User{Name: "Charlie", Age: 35}
    insertResult, err := collection.InsertOne(context.TODO(), user)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Inserted user with ID: %vn", insertResult.InsertedID)

    // Find a user
    var result User
    filter := bson.M{"name": "Charlie"}
    err = collection.FindOne(context.TODO(), filter).Decode(&amp;result)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Found user: %+vn", result)

    // Update a user
    update := bson.M{
        "$set": bson.M{
            "age": 36,
        },
    }
    updateResult, err := collection.UpdateOne(context.TODO(), filter, update)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Updated %v user(s)n", updateResult.ModifiedCount)

    // Delete a user
    deleteResult, err := collection.DeleteOne(context.TODO(), filter)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Deleted %v user(s)n", deleteResult.DeletedCount)

    // Disconnect
    err = client.Disconnect(context.TODO())
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("Connection to MongoDB closed.")
}

此示例演示了使用官方 go 驱动程序对 mongodb 进行基本的 crud（创建、读取、更新、删除）操作。