MongoDB 增刪改查與 Golang 的語法實現

2019-11-11 05:36:35

字體：大中小

來源：轉載

供稿：網友

首先需要獲取到本地數據庫，數據表的一個 Collection，獲取到這個collection 后就可以進行增刪改成的操作了，實現方式如下 :

package mainimport "gopkg.in/mgo.v2"func main() { session, err := mgo.Dial("127.0.0.1:27017") if err != nil { panic(err) } collection := session.DB("mars").C("dns_servers")}

1 列出并選用 1.1 列出所有數據庫

> show dbs local 0.000GBmyblog 0.000GB

1.2 使用某個數據庫

> use myblogswitched to db myblog

1.3 列出所有集合

> show collectionsarticlesreplicationColletionsessionsuserswangduanduan

2 插入數據 insert(value)

// 在已經存在的集合中插入數據> db.users.insert({name:'hh',age:23})Inserted 1 record(s) in 43ms// 在不存在的集合中插入數據,集合不存在則自動創建集合并插入> db.students.insert({name:'hh',age:23})Inserted 1 record(s) in 72ms

3 查詢 find(option) 3.1 查詢集合里所有的文檔

> db.users.find()/* 1 */{ "_id" : ObjectId("583e908453be942d0c5419dc"), "login_name" : "wangduanduan", "passWord" : "wrong age"}/* 2 */{ "_id" : ObjectId("583ed2a5cc9a937db049616d"), "login_name" : "hh", "password" : "sdfsdf"}/* 3 */{ "_id" : ObjectId("583fb2e9b12f8b7a7aa37572"), "name" : "wangduanduan", "age" : 34.0}/* 4 */{ "_id" : ObjectId("583fb707b12f8b7a7aa37573"), "name" : "hh", "age" : 23.0}

3.2 按條件查詢文檔

> db.users.find({name:'wangduanduan'})/* 1 */{ "_id" : ObjectId("583fb2e9b12f8b7a7aa37572"), "name" : "wangduanduan", "age" : 34.0}注意// 這是錯的，查不到結果> db.users.find({_id:'583fb2e9b12f8b7a7aa37572'})Fetched 0 record(s) in 1ms// 這是正確的> db.users.find({_id:ObjectId('583fb2e9b12f8b7a7aa37572')})/* 1 */{ "_id" : ObjectId("583fb2e9b12f8b7a7aa37572"), "name" : "wangduanduan", "age" : 34.0}

3.3 查詢集合內文檔的個數

> db.users.count()

4 3.4 比較運算符 gt:大于 $gt: 大于$ gte: 大于等于 lt:小于 $lt: 小于$ lte: 小于等于 $ne: 不等于

// 查詢用戶里年齡大于30歲的人，其他條件以此類推> db.user.find({age:{$gt:30}})/* 1 */{ "_id" : ObjectId("583fb2e9b12f8b7a7aa37572"), "name" : "wangduanduan", "age" : 34.0}

3.5 邏輯運算符 3.5.1 與

// 查詢名字是wangduanduan,age=34的用戶> db.users.find({name:'wangduanduan',age:34})/* 1 */{ "_id" : ObjectId("583fb2e9b12f8b7a7aa37572"), "name" : "wangduanduan", "age" : 34.0}

3.5.2 $in 或

// 查詢名字是wangduanduan,或hh的用戶> db.users.find({name:{$in:['wangduanduan','hh']}})/* 1 */{ "_id" : ObjectId("583fb2e9b12f8b7a7aa37572"), "name" : "wangduanduan", "age" : 34.0}

3.5.3 $nin 非

// 查詢名字不是wangduanduan或者hh的用戶> db.users.find({name:{$nin:['wangduanduan','hh']}})/* 1 */{ "_id" : ObjectId("583e908453be942d0c5419dc"), "login_name" : "wangduanduan", "password" : "wrong age"}/* 2 */{ "_id" : ObjectId("583ed2a5cc9a937db049616d"), "login_name" : "hh", "password" : "sdfsdf"}

3.6 正則匹配

// 查詢名字是中含有duan的用戶> db.users.find({name:/duan/})/* 1 */{ "_id" : ObjectId("583fb2e9b12f8b7a7aa37572"), "name" : "wangduanduan", "age" : 34.0}/* 2 */{ "_id" : ObjectId("583fc919b12f8b7a7aa37575"), "name" : "wangduanduan", "age" : 45.0}

4 更新 update(); 4.1 整體更新

> db.users.update({login_name:'wangduanduan'},{name:'heihei',age:34})Updated 1 existing record(s) in 116ms

4.2 $set 局部更新

// 只是將用戶年齡設置成101> db.users.update({name:'wangduanduan'},{$set:{age:101}})

4.3 $inc

// 將用戶年齡增加1歲，如果文檔沒有age這個字段，則會增加這個字段> db.users.update({name:'wangduanduan'},{$inc:{age:1}})

4.3 upsert操作

// 如果查不到文檔，則增加文檔> db.users.update({name:'nobody'},{$inc:{age:1}},true)Updated 1 new record(s) in 3ms/* 6 */{ "_id" : ObjectId("583fd20f2cfa6a4817c4171c"), "name" : "nobody", "age" : 1.0}

4.4 批量更新

// upadate 的第四個參數設置成true的時候，就會批量更新> db.users.update({name:'wangduanduan'},{$set:{age:1891}},false,true)

5 刪除

// 刪除某些文檔db.person.remove({"name":"joe"})// 刪除整個集合db.person.remove()

上一篇：轉換流(InputStreamReader)

下一篇：代做題目