分享
golang -- mysql & redis
flyking · · 6932 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
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
}
}
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信6932 次点击 ∙ 1 赞
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
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
}
}