Go操作MySql Memache Mongodb

http://blog.woshifengzi.com/2014/12/12/go%E6%93%8D%E4%BD%9Cmysql-memcache-mongodb.html#mysql

操作mysql

go-sql-driver/mysql Example 上提供了用go操作mysql的两个例子。 例子中关于查询，一个是一次只取一个结果，一个是一次去多个结果，而且使用了prepare的方法，防止sql注入攻击。
此文中是参考上面例子，做的测试。

只取一个数据的例子

1. import(
2. "database/sql"
3. _ "github.com/go-sql-driver/mysql"
4. )
6. func main(){
7. db, err := sql.Open("mysql","user:passwd@tcp(host:port)/db_name")
8. if err !=nil{
9. panic(err.Error())
10. }
11. defer db.Close()
13. stmtOut, err := db.Prepare("SELECT uid FROM mj_table limit 1")
14. if err !=nil{
15. panic(err.Error())
16. }
17. var uid string
18. err = stmtOut.QueryRow().Scan(&uid)
19. if err !=nil{
20. Log.Info("err to Scan: %s", err)
21. return
22. }
23. Log.Info("uid: %s", uid)
24. }

取多个数据的例子

1. ...
2. rows, err := db.Query("select appid from mj_table limit 1")
3. if err !=nil{
4. Log.Info("No Err in select msyql: %s", err)
5. return
6. }
7. // Get column names
8. columns, err := rows.Columns()
9. if err !=nil{
10. panic(err.Error())
11. }
13. // Make a slice for the values
14. values := make([]sql.RawBytes, len(columns))
15. scanArgs := make([]interface{}, len(values))// 必须要有此类型
16. for i := range values {
17. scanArgs[i]=&values[i]
18. }
20. // Fetch rows
21. for rows.Next(){
22. // get RawBytes from data
23. err = rows.Scan(scanArgs...)
24. if err !=nil{
25. panic(err.Error())
26. }
27. var value string
28. for i, col := range values {
29. if col ==nil{
30. value ="NULL"
31. }else{
32. value =string(col)
33. }
34. Log.Info("name: %s, value: %s ", columns[i], value)
35. }
36. Log.Info("-----------------------------------")
37. }
38. ...

操作mongodb

mgo是go语言操作MongoDb的驱动，因为接口比较丰富，官方文档看着也就比较长。

下面代码提供了建立连接、插入数据、查询、删除的操作

1. import(
2. "time"
3. "gopkg.in/mgo.v2"// mgo的包
4. "gopkg.in/mgo.v2/bson"
5. )
7. func main(){
8. var(
9. err error
10. )
11. //建立连接
12. mongoURL :="192.168.1.140,192.168.1.141:20001,192.168.1.141:20002"//可在配置文件中设置
13. maxWait := time.Duration(10* time.Second)
14. sess, err = mgo.DialWithTimeout(mongoURL, maxWait)
15. if err !=nil{
16. Log.Error("mgo.Dial err:%s", err)
17. panic(err)
18. }
19. sess.SetMode(mgo.Monotonic,true)
20. defer sess.Close()
22. //插入数据
23. //...构造要插入数据
24. db_name :="db"
25. table_name :="table"// 即mongodb中的Collection
26. dataBytes :=[]byte("{\"name\":\"jgj\"}")
27. var intf map[string]interface{}
28. err = json.Unmarshal(dataBytes,&intf)
30. //...执行入库操作
31. // new_sess := sess.Copy() // 可以复制一份回话，用新回话做操作
32. col := sess.DB(appid).C(classname)
33. err = col.Insert(intf)
34. if err !=nil{
35. Log.Error("db POST, db insert error, appid:%s, class:%s, data:%s, err:%s", appid, classname,string(dataBytes), err)
36. return
37. }
39. // 获取数据
40. var objectid interface{}
41. objectid =string("5486b4e08bb3c2659c000001")
42. err = col.FindId(objectid).One(&intf)
43. this.Data["json"]= intf
44. // this.ServeJson() // 显示
46. // 更新某个对象
47. err = col.Update(bson.M{"_id": objectid,"updatedAt": oldUpdatedAt}, intf)
49. // 删除某个对象
50. err = col.RemoveId(objectid)
52. // 查询
53. selectParam :="{\"name\":true, \"age\":true}"
54. var selectIntf map[string]bool
55. err = json.Unmarshal([]byte(selectParam),&selectIntf)
56. whereParam :="{\"or\":[{\"name\":\"jgj\"},{\"age\":\"29\"}]}"
57. var whereIntf := map[string]interface{}{}
58. err = json.Unmarshal([]byte(whereParam),&whereIntf)
59. //...json to bson. 代码未提供
60. ConvertBSON(whereIntf)
61. sortParam ="name,-age"
62. offset =1
63. limit =10
65. //...TODO 此处要有错误的判断
66. query := col.Find(whereIntf)
67. query = query.Sort(sortParam)
68. query = query.Select(selectIntf)
69. query = query.Skip(offset)
70. query = query.Limit(limit)
72. iter := query.Iter()
73. var result []bson.M = make([]bson.M,0)
74. intf := bson.M{}
75. for iter.Next(&intf){
76. result = append(result, intf)
77. intf = bson.M{}
78. }
79. iter.Close()
80. this.Data["json"]= result
81. this.ServeJson()
82. }

操作memcache

GoDoc中memcache的说明提供了操作的一些函数，没有给出实际的例子。

下面是测试的小例子：

import "github.com/bradfitz/gomemcache/memcache" (附件中已提供此包源代码)

1. con := memcache.New("ip:host")
2. if con ==nil{
3. Log.Info("Failed to connect Memcache")
4. }
6. item :=&memcache.Item{Key:"jgj",Value:[]byte("test_value"),Expiration:0}
7. err := con.Set(item)
8. if err !=nil{
9. Log.Info("failed to set item: %s", err)
10. }
12. item1, err := con.Get("jgj")
13. if err !=nil{
14. Log.Info("Failed to get item %s ", err)
15. return
16. }
17. Log.Info("get value: %s", item1.Value)