goMongo

标签：logistics fmt filter goMongo Println Message

goMongo

简介

golang简单分装mongodb操作

使用

go get github.com/wms3001/goMongo

实例

1. 连接

goMongo := GoMongo{}
goMongo.Addr = "192.168.4.81"
goMongo.Port = "27017"
goMongo.User = "logistics"
goMongo.Pass = "123456"
goMongo.Db = "logistics"
goMongo.Connect()
goMongo.Ping()
goMongo.SetCollection("order1")
goMongo.CloseConn()

2. 单个添加

goMongo := GoMongo{}
goMongo.Addr = "192.168.4.81"
goMongo.Port = "27017"
goMongo.User = "logistics"
goMongo.Pass = "123456"
goMongo.Db = "logistics"
resp := goMongo.Connect()
resp1 := goMongo.SetCollection("orderTest")
ids, _ := uuid2.NewUUID()
order := OrderTest{ids.String(), 0}
resp2 := goMongo.AddOne(order)
resp3 := goMongo.CloseConn()
fmt.Println(resp.Message)
fmt.Println(resp1.Message)
fmt.Println(resp2.Message + Strval(resp2.Data))
fmt.Println(resp3.Message)

3. 批量添加

goMongo := GoMongo{}
goMongo.Addr = "192.168.4.81"
goMongo.Port = "27017"
goMongo.User = "logistics"
goMongo.Pass = "123456"
goMongo.Db = "logistics"
resp := goMongo.Connect()
resp1 := goMongo.SetCollection("orderTest")
id, _ := uuid2.NewUUID()
o1 := OrderTest{id.String(), 0}
id1, _ := uuid2.NewUUID()
o2 := OrderTest{id1.String(), 0}
id2, _ := uuid2.NewUUID()
o3 := OrderTest{id2.String(), 0}
orders := []interface{}{o1, o2, o3}
resp2 := goMongo.AddMany(orders)
resp3 := goMongo.CloseConn()
fmt.Println(resp.Message)
fmt.Println(resp1.Message)
fmt.Println(resp2.Message)
fmt.Println(resp3.Message)

4. 获取单个

goMongo := GoMongo{}
goMongo.Addr = "192.168.4.81"
goMongo.Port = "27017"
goMongo.User = "logistics"
goMongo.Pass = "123456"
goMongo.Db = "logistics"
resp := goMongo.Connect()
resp1 := goMongo.SetCollection("orderTest")
var filter = &Filter{}
filter.Type = "and"
var fMap = map[string]interface{}{}
fMap["test"] = "9fb73527-f076-11ec-81a7-2c4d54d02652"
filter.FMap = fMap
resp2 := goMongo.GetOne(filter)
resp3 := goMongo.CloseConn()
fmt.Println(resp.Message)
fmt.Println(resp1.Message)
fmt.Println(resp2.Data)
fmt.Println(resp3.Message)

5. 获取多个

goMongo := GoMongo{}
goMongo.Addr = "192.168.4.81"
goMongo.Port = "27017"
goMongo.User = "logistics"
goMongo.Pass = "123456"
goMongo.Db = "logistics"
resp := goMongo.Connect()
resp1 := goMongo.SetCollection("orderTest")
var filter = &Filter{}
var option = &Option{}
filter.Type = "and"
var fMap = map[string]interface{}{}
fMap["status"] = 0
filter.FMap = fMap

resp2 := goMongo.GetMany(filter, option)
resp3 := goMongo.CloseConn()
fmt.Println(resp.Message)
fmt.Println(resp1.Message)
fmt.Println(resp2.Data)
fmt.Println(resp3.Message)

6. 单个更新

goMongo := GoMongo{}
goMongo.Addr = "192.168.4.81"
goMongo.Port = "27017"
goMongo.User = "logistics"
goMongo.Pass = "123456"
goMongo.Db = "logistics"
resp := goMongo.Connect()
resp1 := goMongo.SetCollection("orderTest")
var filter = &Filter{}
filter.Type = "and"
var fMap = map[string]interface{}{}
fMap["status"] = 0
filter.FMap = fMap
var uData = &UData{}
var uMap = map[string]interface{}{}
uMap["status"] = 1
uData.UMap = uMap
resp2 := goMongo.UpdateOne(filter, uData)
resp3 := goMongo.CloseConn()
fmt.Println(resp.Message)
fmt.Println(resp1.Message)
fmt.Println(resp2.Data)
fmt.Println(resp3.Message)

7. 批量更新

goMongo := GoMongo{}
goMongo.Addr = "192.168.4.81"
goMongo.Port = "27017"
goMongo.User = "logistics"
goMongo.Pass = "123456"
goMongo.Db = "logistics"
resp := goMongo.Connect()
resp1 := goMongo.SetCollection("orderTest")
var filter = &Filter{}
filter.Type = "and"
var fMap = map[string]interface{}{}
fMap["status"] = 0
filter.FMap = fMap
var uData = &UData{}
var uMap = map[string]interface{}{}
uMap["status"] = 1
uData.UMap = uMap
resp2 := goMongo.UpdateMany(filter, uData)
resp3 := goMongo.CloseConn()
fmt.Println(resp.Message)
fmt.Println(resp1.Message)
fmt.Println(resp2.Data)
fmt.Println(resp3.Message)

8. 统计条数

goMongo := GoMongo{}
goMongo.Addr = "192.168.4.81"
goMongo.Port = "27017"
goMongo.User = "logistics"
goMongo.Pass = "123456"
goMongo.Db = "logistics"
resp := goMongo.Connect()
resp1 := goMongo.SetCollection("orderTest")
var filter = &Filter{}
filter.Type = "and"
var fMap = map[string]interface{}{}
fMap["status"] = 1
filter.FMap = fMap
resp2 := goMongo.Count(filter)
resp3 := goMongo.CloseConn()
fmt.Println(resp.Message)
fmt.Println(resp1.Message)
fmt.Println(resp2.Data)
fmt.Println(resp3.Message)

9. 取唯一值

goMongo := GoMongo{}
goMongo.Addr = "192.168.4.81"
goMongo.Port = "27017"
goMongo.User = "logistics"
goMongo.Pass = "123456"
goMongo.Db = "logistics"
resp := goMongo.Connect()
resp1 := goMongo.SetCollection("orderTest")
var filter = &Filter{}
filter.Type = "and"
var fMap = map[string]interface{}{}
fMap["status"] = 1
filter.FMap = fMap
resp2 := goMongo.Distinct(filter, "test")
resp3 := goMongo.CloseConn()
fmt.Println(resp.Message)
fmt.Println(resp1.Message)
fmt.Println(resp2.Data)
fmt.Println(resp3.Message)

10. 单个删除

goMongo := GoMongo{}
goMongo.Addr = "192.168.4.81"
goMongo.Port = "27017"
goMongo.User = "logistics"
goMongo.Pass = "123456"
goMongo.Db = "logistics"
resp := goMongo.Connect()
resp1 := goMongo.SetCollection("orderTest")
var filter = &Filter{}
filter.Type = "and"
var fMap = map[string]interface{}{}
fMap["status"] = 1
filter.FMap = fMap
resp2 := goMongo.DeleteOne(filter)
resp3 := goMongo.CloseConn()
fmt.Println(resp.Message)
fmt.Println(resp1.Message)
fmt.Println(resp2.Data)
fmt.Println(resp3.Message)

11. 批量删除

goMongo := GoMongo{}
goMongo.Addr = "192.168.4.81"
goMongo.Port = "27017"
goMongo.User = "logistics"
goMongo.Pass = "123456"
goMongo.Db = "logistics"
resp := goMongo.Connect()
resp1 := goMongo.SetCollection("orderTest")
var filter = &Filter{}
filter.Type = "and"
var fMap = map[string]interface{}{}
fMap["status"] = 1
filter.FMap = fMap
resp2 := goMongo.DeleteMany(filter)
resp3 := goMongo.CloseConn()
fmt.Println(resp.Message)
fmt.Println(resp1.Message)
fmt.Println(resp2.Data)
fmt.Println(resp3.Message)

标签：logistics,fmt,filter,goMongo,Println,Message
From： https://blog.51cto.com/wms3001/5762067