卓越飞翔博客卓越飞翔博客

卓越飞翔 - 您值得收藏的技术分享站
技术文章73799本站已运行433

golang框架与各种数据库的集成实战

golang 提供了与 mysql、postgresql 和 mongodb 等不同数据库集成的实战解决方案:连接 mysql:使用 database/sql 包和 go-sql-driver/mysql 驱动程序。查询 postgresql:使用 pgx/v4 和 stdlib 扩展连接到数据库并执行查询。插入 mongodb:使用 mongo-driver 库连接到数据库并向集合中插入数据。

golang框架与各种数据库的集成实战

Golang 与各种数据库的集成实战

前言

在现代应用程序开发中,数据库集成至关重要。Golang 作为一门流行的编程语言,提供了强大的功能来无缝连接各种数据库。本文将介绍 Golang 与不同数据库(如 MySQL、PostgreSQL 和 MongoDB)集成的实战案例。

立即学习“go语言免费学习笔记(深入)”;

案例 1:连接 MySQL

package main

import (
    "database/sql"
    "fmt"

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

func main() {
    db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/database")
    if err != nil {
        fmt.Println(err)
        return
    }
    defer db.Close()
}

案例 2:查询 PostgreSQL

package main

import (
    "context"
    "fmt"

    "github.com/jackc/pgx/v4"
    "github.com/jackc/pgx/v4/stdlib"
)

func main() {
    connString := "user=user password=password host=127.0.0.1 port=5432 database=database"
    pool, err := pgx.NewPool(context.Background(), stdlib.RegisterConnConfig(connString))
    if err != nil {
        fmt.Println(err)
        return
    }
    defer pool.Close()

    rows, err := pool.Query(context.Background(), "SELECT * FROM users")
    if err != nil {
        fmt.Println(err)
        return
    }

    for rows.Next() {
        var id int
        var name string
        err := rows.Scan(&id, &name)
        if err != nil {
            fmt.Println(err)
            continue
        }
        fmt.Printf("ID: %d, Name: %sn", id, name)
    }
}

案例 3:插入 MongoDB

package main

import (
    "context"
    "fmt"
    "log"

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

func main() {
    clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")
    client, err := mongo.Connect(context.Background(), clientOptions)
    if err != nil {
        log.Fatal(err)
    }

    db := client.Database("mydb")
    collection := db.Collection("users")

    insertResult, err := collection.InsertOne(context.Background(), map[string]interface{}{
        "name": "John Doe",
        "age": 30,
    })
    if err != nil {
        log.Fatal(err)
    }

    fmt.Printf("Inserted document with ID: %sn", insertResult.InsertedID)
}

结论

通过这些实战案例,我们展示了 Golang 如何轻松地与 MySQL、PostgreSQL 和 MongoDB 等各种数据库集成。利用 Golang 的强大功能,开发人员可以构建可靠且高效的数据驱动的应用程序。

卓越飞翔博客
上一篇: C++框架在金融科技中的应用:安全、可靠性和合规性
下一篇: 返回列表
留言与评论(共有 0 条评论)
   
验证码:
隐藏边栏