golang -- mysql & redis
发布时间：2020-12-16 18:57:05 所属栏目：大数据 来源：网络整理
导读：golang mysql 驱动安装 go get github.com/go-sql-driver/mysql go install github.com/go-sql-driver/mysql 以下是select的例子 package mainimport ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql")func main() { initMySQL("root:112358@tcp(
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 redisgo redis client安装go getgithub.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",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
}
} （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |