Bagaimanakah rangka kerja golang berinteraksi dengan pangkalan data NoSQL?

WBOY
Lepaskan: 2024-06-04 12:35:58
asal
323 orang telah melayarinya

Rangka kerja Go menyediakan keupayaan berkuasa untuk berinteraksi dengan pangkalan data NoSQL melalui perpustakaan standard dan rangka kerja pihak ketiga. Rangka kerja ini termasuk: 1. Perpustakaan MongoDB: mgo; 2. Pustaka Redis: redigo; Rangka kerja ini menyediakan API untuk berinteraksi dengan pangkalan data MongoDB, Redis dan Cassandra, termasuk operasi seperti mewujudkan sambungan, melaksanakan pertanyaan, memasukkan, mengemas kini dan memadam dokumen.

Bagaimanakah rangka kerja golang berinteraksi dengan pangkalan data NoSQL?

Rangka kerja Go berinteraksi dengan pangkalan data NoSQL

Pangkalan data NoSQL semakin popular dalam aplikasi moden disebabkan oleh kebolehskalaan, fleksibiliti dan keupayaan storan yang besar. Bahasa Go menyediakan keupayaan berkuasa untuk berinteraksi dengan pangkalan data NoSQL melalui perpustakaan standard dan rangka kerja pihak ketiga yang kaya.

Berikut ialah cara berinteraksi dengan pangkalan data NoSQL menggunakan rangka kerja Go:

1 MongoDB

  • Perpustakaan: [mgo](https://godoc.org/gopkg.in/mgo)
  • .
    package main
    
    import (
        "context"
        "fmt"
        "log"
        "time"
    
        "gopkg.in/mgo.v2"
    )
    
    func main() {
        // 建立连接
        session, err := mgo.Dial("mongodb://localhost:27017")
        if err != nil {
            log.Fatal(err)
        }
        defer session.Close()
    
        // 获取所选数据库和集合
        db := session.DB("test")
        collection := db.C("users")
    
        // 插入文档
        if err := collection.Insert(map[string]interface{}{"name": "Alice", "age": 30}); err != nil {
            log.Fatal(err)
        }
    
        // 查找文档
        result := &struct{ Name string }{Name: ""}
        if err := collection.Find(nil).One(result); err != nil {
            log.Fatal(err)
        }
        fmt.Println("Name:", result.Name)
    
        // 更新文档
        if _, err := collection.Update(map[string]interface{}{"name": "Alice"}, map[string]interface{}{"age": 31}); err != nil {
            log.Fatal(err)
        }
    
        // 删除文档
        if err := collection.Remove(map[string]interface{}{"name": "Alice"}); err != nil {
            log.Fatal(err)
        }
    
    }
    Salin selepas log masuk

2. Redis

  • Perpustakaan: [redigo](https://godoc.org/github.com/garyburd/redigo/redis)
  • package main
    
    import (
        "fmt"
        "log"
    
        "github.com/garyburd/redigo/redis"
    )
    
    func main() {
        // 建立连接
        conn, err := redis.Dial("tcp", "localhost:6379")
        if err != nil {
            log.Fatal(err)
        }
        defer conn.Close()
    
        // 设置键值对
        if _, err := conn.Do("SET", "name", "Alice"); err != nil {
            log.Fatal(err)
        }
    
        // 获取值
        name, err := redis.String(conn.Do("GET", "name"))
        if err != nil {
            log.Fatal(err)
        }
        fmt.Println("Name:", name)
    
        // 删除键
        if _, err := conn.Do("DEL", "name"); err != nil {
            log.Fatal(err)
        }
    }
    Salin selepas log masuk

🎜 : 🎜 [gocql](https://godoc.org/github.com/gocql/gocql)🎜🎜
package main

import (
    "fmt"
    "log"
    "time"

    "github.com/gocql/gocql"
)

func main() {
    // 建立连接
    cluster := gocql.NewCluster("localhost:9042")
    session, err := cluster.CreateSession()
    if err != nil {
        log.Fatal(err)
    }
    defer session.Close()

    // 创建表
    if err := session.Query(`CREATE TABLE users (name text, age int, PRIMARY KEY (name))`).Exec(); err != nil {
        log.Fatal(err)
    }

    // 插入数据
    if err := session.Query(`INSERT INTO users (name, age) VALUES (?, ?)`).Bind("Alice", 30).Exec(); err != nil {
        log.Fatal(err)
    }

    // 查询数据
    iter := session.Query(`SELECT * FROM users`).Iter()
    var name string
    var age int
    for iter.Scan(&name, &age) {
        fmt.Println("Name:", name, "Age:", age)
    }
    if err := iter.Close(); err != nil {
        log.Fatal(err)
    }

    // 更新数据
    if err := session.Query(`UPDATE users SET age = ? WHERE name = ?`).Bind(31, "Alice").Exec(); err != nil {
        log.Fatal(err)
    }

    // 删除数据
    if err := session.Query(`DELETE FROM users WHERE name = ?`).Bind("Alice").Exec(); err != nil {
        log.Fatal(err)
    }
}
Salin selepas log masuk

Atas ialah kandungan terperinci Bagaimanakah rangka kerja golang berinteraksi dengan pangkalan data NoSQL?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Label berkaitan:
sumber:php.cn
Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan