Rumah  >  Artikel  >  pembangunan bahagian belakang  >  Bagaimanakah rangka kerja golang berinteraksi dengan pangkalan data NoSQL?

Bagaimanakah rangka kerja golang berinteraksi dengan pangkalan data NoSQL?

WBOY
WBOYasal
2024-06-04 12:35:58240semak imbas

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)
        }
    
    }

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)
        }
    }

🎜 : 🎜 [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)
    }
}

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!

Kenyataan:
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