Go基础学习记录 - 编写Web应用程 - 数据库(五)

本次分享下 -- NoSQL数据库 - Redis数据库驱动程序

NoSQL数据库

NoSQL数据库提供了一种存储和检索数据的机制,该机制使用比典型的关系数据库更松散的一致性模型,以实现水平扩展和更高的可用性。
一些作者将它们称为"不仅仅是SQL",以强调某些NoSQL系统确实允许使用类似SQL的查询语言。
作为21世纪的C语言,Go对NoSQL数据库提供了很好的支持,包括流行的redis,mongoDB,Cassandra和Membase NoSQL数据库。

Redis

redis是一个像Memcached这样的键值存储系统,它支持string,list,set和zset(有序集)值类型。
redis有一些Go数据库驱动程序:

• https://github.com/gomodule/r...
• https://github.com/go-redis/r...
• https://github.com/hoisie/redis
• https://github.com/alphazero/...
• https://github.com/simonz05/g...

让我们看看如何使用redigo驱动程序在数据库上运行:

安装redigo:

go get github.com/gomodule/redigo

使用方式如下

package main
import (
 "fmt"
 "github.com/gomodule/redigo"
 "os"
 "os/signal"
 "syscall"
 "time"
)
var (
 Pool *redis.Pool
)
func init() {
 redisHost := ":6379"
 Pool = newPool(redisHost)
 close()
}
func newPool(server string) *redis.Pool {
 return &redis.Pool{
 MaxIdle: 3,
 IdleTimeout: 240 * time.Second,
 Dial: func() (redis.Conn, error) {
 c, err := redis.Dial("tcp", server)
 if err != nil {
 return nil, err
 }
 return c, err
 },
 TestOnBorrow: func(c redis.Conn, t time.Time) error {
 _, err := c.Do("PING")
 return err
 },
 }
}
func close() {
 c := make(chan os.Signal, 1)
 signal.Notify(c, os.Interrupt)
 signal.Notify(c, syscall.SIGTERM)
 signal.Notify(c, syscall.SIGKILL)
 go func() {
 <-c
 Pool.Close()
 os.Exit(0)
 }()
}
func Get(key string) ([]byte, error) {
 conn := Pool.Get()
 defer conn.Close()
 var data []byte
 data, err := redis.Bytes(conn.Do("GET", key))
 if err != nil {
 return data, fmt.Errorf("error get key %s: %v", key, err)
 }
 return data, err
}
func main() {
 test, err := Get("test")
 fmt.Println(test, err)
}

我们可以看到在Go中操作redis非常容易,并且它具有很高的性能。
它的客户端命令几乎与redis的内置命令相同。

MongoDB

MongoDB(来自"humongous")是一个由10gen开发和支持的面向文档的开源数据库系统。
它是NoSQL系列数据库系统的一部分。MongoDB不是像在"经典"关系数据库中那样在表中存储数据,而是将结构化数据存储为具有动态模式的类似JSON的文档(MongoDB调用BSON格式),使得在某些类型的应用程序中的数据集成更容易,更快捷。

MongoDB的最佳驱动程序称为mgo,将来它可能会包含在标准库中。

安装mgo:

go get gopkg.in/mgo.v2

使用方式如下

package main
import (
 "fmt"
 "gopkg.in/mgo.v2"
 "gopkg.in/mgo.v2/bson"
 "log"
)
type Person struct {
 Name string
 Phone string
}
func main() {
 session, err := mgo.Dial("server1.example.com,server2.example.com")
 if err != nil {
 panic(err)
 }
 defer session.Close()
 // Optional. Switch the session to a monotonic behavior.
 session.SetMode(mgo.Monotonic, true)
 c := session.DB("test").C("people")
 err = c.Insert(&Person{"Ale", "+55 53 8116 9639"},
 &Person{"Cla", "+55 53 8402 8510"})
 if err != nil {
 log.Fatal(err)
 }
 result := Person{}
 err = c.Find(bson.M{"name": "Ale"}).One(&result)
 if err != nil {
 log.Fatal(err)
 }
 fmt.Println("Phone:", result.Phone)
}

我们可以看到,在mgo数据库上运行时没有太大的区别;它们都是基于结构的。这是Go的做事方式。

今天就分享到这里,如果你有其他疑问请在下方留言或者加群交流