文田0611：mongodb基本操作

37ck

mgdata.py

1. 
   
2. url = "mongodb://root:37ck2020@iot.37ck.cn:27017"
   
3. dbname = "曾老师"
   
4. coll = "37ck"
   
5. udb="coll"
   
6. 
   
7. update_data=[{"content": "脱水会使人精疲力竭，而喝水可以使人精神饱满"},
   
8.                            {"$set": {"content": "吃饭前，先喝杯水或一碗汤，可减少饭量，对控制体重有明显的帮助"}}]
   
9. data = [
   
10.     {
    
11.         # "_id": "8",
    
12.         "articleid": "100001",
    
13.         "content": "吃饭千万不能吃多了，因为会饱",
    
14.         "userid": "1008",
    
15.         "nickname": "天涯若比邻",
    
16. 
    
17.     },
    
18.     {
    
19.         # "_id": "9",
    
20.         "articleid": "100001",
    
21.         "content": "吃饭前，先喝杯水或一碗汤，可减少饭量，对控制体重有帮助",
    
22.         "userid": "1008",
    
23.         "nickname": "玛丽莲·梦露",
    
24.         "age": "18",
    
25.         "phone": "13937165554",
    
26.         "createdatetime": "new Date()",
    
27.         "likenum": "8888",
    
28.         "state": "null",
    
29.     }
    
30. ]
    
31. 
    
32. newDoc = {
    
33.     # "_id": "7",
    
34.     "articleid": "100001",
    
35.     "content": "脱水会使人精疲力竭，而喝水可以使人精神饱满",
    
36.     "userid": "1007",
    
37.     "nickname": "咫尺天涯间",
    
38.     "age": "25",
    
39.     "phone": "13937165554",
    
40.     "createdatetime": "new Date()",
    
41.     "likenum": "999",
    
42.     "state": "1",
    
43. }
    

复制代码

appmgex.py

1. # pip install pymongo==3.12.0
   
2. from pymongo import MongoClient
   
3. from mgdata import *
   
4. 
   
5. class Mgdbex:
   
6.     # 创建类的构造函数或初始化方法，其中包含一个参数self，表示类的示例，self在定义类的方法时是必须要有的，在带哦用时可以不传入相应参数
   
7.     def __init__(self):
   
8.         # 获取数据库的连接
   
9.         # self.client = MongoClient('127.0.0.1', 27017)#本地数据库
   
10.         self.url = url  # "mongodb://root:37ck2020@iot.37ck.cn:27017"
    
11.         self.client = MongoClient(self.url)  # 远程数据库
    
12.         self.dbname = dbname
    
13.         print(self.client)
    
14.         # dbs = self.client.list_database_names()
    
15.         # for db in dbs:
    
16.         #     print("数据库列表：" + db)
    
17. 
    
18.     def getDBs(self):
    
19.         dbs = self.client.list_database_names()
    
20.         for db in dbs:
    
21.             print("数据库列表：" + db)
    
22. 
    
23.     def getColl(self):
    
24.         articledb = self.client["articledb"]
    
25.         collections = articledb.list_collection_names()
    
26.         for collection in collections:
    
27.             print(collection)
    
28. 
    
29.     def createColl(self):
    
30.         articledb = self.client["articledb"]
    
31.         articledb.create_collection("itcast")
    
32. 
    
33.     def dropColl(self):
    
34.         articledb = self.client["articledb"]
    
35.         articledb.drop_collection("itcast")
    
36. 
    
37.     def findDoc(self):
    
38.         self.articledb = self.client["articledb"]
    
39.         comment = self.articledb["comment"]
    
40.         documents = comment.find()
    
41.         for document in documents:
    
42.             print(document)
    
43. 
    
44.     def insertOne(self, col):
    
45.         '''插入单条数据：格式以字典（键值对）mgdata的newDoc；col就是数据表也是数据集合'''
    
46.         self.articledb = self.client[self.dbname]
    
47.         comment = self.articledb[col]
    
48.         comment.insert_one(newDoc)
    
49. 
    
50.     def insert(self, col):
    
51.         '''插入多条数据insert_many：data是列表包含字典的json'''
    
52.         self.articledb = self.client[self.dbname]
    
53.         comment = self.articledb[col]
    
54.         re = comment.insert_many(data)
    
55.         print(re)
    
56. 
    
57.     def find(self, col):
    
58.         self.articledb = self.client[self.dbname]
    
59.         comment = self.articledb[col]
    
60.         documents = comment.find()
    
61.         for document in documents:
    
62.             print(document)
    
63. 
    
64.     def insertManyDoc(self):
    
65.         self.articledb = self.client["articledb"]
    
66.         comment = self.articledb["comment"]
    
67.         re = comment.insert_many(data)
    
68.         print(re)
    
69. 
    
70.     def updateDoc(self):
    
71.         self.articledb = self.client["articledb"]
    
72.         comment = self.articledb["comment"]
    
73.         comment.update_one({"content": "脱水会使人精疲力竭，而喝水可以使人精神饱满"},
    
74.                            {"$set": {"content": "吃饭前，先喝杯水或一碗汤，可减少饭量，对控制体重有明显的帮助"}})
    
75. 
    
76.     def deleteDoc(self):
    
77.         self.articledb = self.articledb = self.client["articledb"]
    
78.         comment = self.articledb["comment"]
    
79.         comment.delete_one({"nickname": "咫尺天涯间"})
    
80. 
    
81. 
    
82. # 主程序入口
    
83. if __name__ == '__main__':
    
84.     test = Mgdbex()  # 创建类的实例对象
    
85.     test.getDBs()
    
86.     test.dbname = '0611'
    
87.     # test.insert("0611")
    
88.     test.insertOne('0611')
    
89.     test.find("0611")
    
90.     # test.getDBs()
    
91.     # test.createColl()
    
92.     # test.dropColl()
    
93.     # test.getColl()
    
94.     # test.insertOneDoc()
    
95.     # test.insertManyDoc()
    
96.     # test.updateDoc()
    
97.     # test.deleteDoc()
    
98.     # test.findDoc()
    

复制代码