golang -- mysql & redis

flyking · · 5538 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

golang mysql

驱动安装
go get github.com/go-sql-driver/mysql
go install github.com/go-sql-driver/mysql
以下是select的例子
package main

import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/mysql"
)

func main() {
    initMySQL("root:112358@tcp(192.168.6.234:3306)/test?charset=utf8")
    defer db.Close()

    // Prepare statement for select data
    stmtOut, err := db.Prepare("SELECT id, name FROM users WHERE name=?")
    checkErr(err)
    defer stmtOut.Close()

    // Execute the query
    rows, err := stmtOut.Query("zs")
    var id, name []byte

    for rows.Next() {
        // Scan the value to []byte
        err = rows.Scan(&id, &name)
        checkErr(err)

        // Use the string value
        fmt.Println(string(id), string(name))
    }

}

var db *sql.DB

func initMySQL(dbUrl string) {
    db, _ = sql.Open("mysql", dbUrl)
}

func checkErr(err error) {
    if err != nil {
        panic(err)
    }
}

/* result:
1 zs
2 zs
*/

其他sql语句:

// 插入
stmtIns, err := db.Prepare("INSERT INTO squareNum VALUES(?, ?)") // ? = placeholder
res, err = stmtIns.Exec(i, (i * i)) // Insert tuples (i, i^2)
id, err := res.LastInsertId()

// 删除
stmtDel, err = db.Prepare("DELETE FROM userinfo WHERE uid=?")
res, err = stmtDel.Exec(id)
affect, err = res.RowsAffected()



golang redis

go redis client安装
go get github.com/hoisie/redis
go install github.com/hoisie/redis
package main

import (
	"fmt"
	"github.com/hoisie/redis"
	"sync"
)

func main() {
	initRedis()
	// 测试string
	client.Set("s", []byte("hello world"))
	val, _ := client.Get("s")
	fmt.Println(string(val))
	client.Del("s")

	//测试list
	vals := []string{"a1", "b2", "c3", "d4", "e5"}
	for _, v := range vals {
		client.Rpush("l", []byte(v))
	}
	dbvals, _ := client.Lrange("l", 0, 4)
	for i, v := range dbvals {
		println(i, ":", string(v))
	}
	client.Del("l")
}

var (
	client *redis.Client
	mutex  sync.Mutex
)

func initRedis() {
	mutex.Lock()
	defer mutex.Unlock()
	if client != nil {
		return
	}
	client = &redis.Client{
		Addr:        "127.0.0.1:6379",
		Db:          0,
		Password:    "",
		MaxPoolSize: 10000,
	}
	if err := client.Auth(""); err != nil {
		fmt.Println("Auth:", err.Error())
		return
	}
}



有疑问加站长微信联系(非本文作者)

本文来自:开源中国博客

感谢作者:flyking

查看原文:golang -- mysql & redis

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

5538 次点击  ∙  1 赞  
加入收藏 微博
1 回复  |  直到 2000-01-01 00:00:00
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传