mgex案例分解

admin

mgdata.py

1. url = "mongodb://root:37ck2020@iot.37ck.cn:27017"
   
2. dbname = "曾老师"
   
3. coll = "37ck"
   
4. udb = "coll"
   
5. 
   
6. update_old = {'content': '37ck而喝水可以满'}
   
7. update_new = {'$set': {'content': '37ck而喝水可以使人精神饱满'}}
   
8. 
   
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.     {"content": "脱水会使人精疲力竭，而喝水可以使人精神饱满"}
    
31. ]
    
32. 
    
33. one = {'content': '脱水会使人精疲力竭，而喝水可以使人精神饱满'}
    
34. # {"articleid": "100001"}
    
35. # {'_id': '6485fe8b294f6a06bc038efb'}
    
36. # {"content": "脱水会使人精疲力竭，而喝水可以使人精神饱满"}
    
37. 
    
38. # {"nickname": "咫尺天涯间"}
    
39. 
    
40. newDoc = {
    
41.     # "_id": "7",
    
42.     "articleid": "100001",
    
43.     "content": "脱水会使人精疲力竭，而喝水可以使人精神饱满",
    
44.     "userid": "1007",
    
45.     "nickname": "咫尺天涯间",
    
46.     "age": "25",
    
47.     "phone": "13937165554",
    
48.     "createdatetime": "new Date()",
    
49.     "likenum": "999",
    
50.     "state": "1",
    
51. }
    

复制代码

mgex.py

1. # pip install pymongo==3.12.0
   
2. from pymongo import MongoClient
   
3. from mgdata import *
   
4. 
   
5. 
   
6. class Mgdbex:
   
7.     # 创建类的构造函数或初始化方法，其中包含一个参数self，表示类的示例，self在定义类的方法时是必须要有的，在带哦用时可以不传入相应参数
   
8.     def __init__(self):
   
9.         # 获取数据库的连接
   
10.         # self.client = MongoClient('127.0.0.1', 27017)#本地数据库
    
11.         self.url = url  # "mongodb://root:37ck2020@iot.37ck.cn:27017"
    
12.         self.client = MongoClient(self.url)  # 远程数据库
    
13.         self.dbname = dbname
    
14.         print(self.client)
    
15. 
    
16.     def getDBs(self):
    
17.         '''获取所有数据库名字'''
    
18.         dbs = self.client.list_database_names()
    
19.         for db in dbs:
    
20.             print("数据库列表：" + db)
    
21.         return dbs
    
22. 
    
23.     def getColl(self):
    
24.         '''获取数据库中所有集合：数据表 名字'''
    
25.         articledb = self.client[self.dbname]
    
26.         collections = articledb.list_collection_names()
    
27.         for collection in collections:
    
28.             print(collection)
    
29. 
    
30.     def createColl(self, col):
    
31.         '''创建数据集：数据表'''
    
32.         articledb = self.client[self.dbname]
    
33.         articledb.create_collection(col)
    
34. 
    
35.     def dropColl(self, col):
    
36.         '''删除数据集'''
    
37.         articledb = self.client[self.dbname]
    
38.         articledb.drop_collection(col)
    
39. 
    
40.     def insertOne(self, col):
    
41.         '''0611插入单条数据：格式以字典（键值对）mgdata的newDoc；col就是数据表也是数据集合'''
    
42.         self.articledb = self.client[self.dbname]
    
43.         comment = self.articledb[col]
    
44.         comment.insert_one(newDoc)
    
45. 
    
46.     def insert(self, col):
    
47.         '''0611插入多条数据insert_many：data是列表包含字典的json'''
    
48.         self.articledb = self.client[self.dbname]
    
49.         comment = self.articledb[col]
    
50.         re = comment.insert_many(data)
    
51.         print(re)
    
52. 
    
53.     def find(self, col):
    
54.         '''0611查找数据集所有数据'''
    
55.         self.articledb = self.client[self.dbname]
    
56.         comment = self.articledb[col]
    
57.         documents = comment.find()
    
58.         for document in documents:
    
59.             print(document)
    
60. 
    
61.     def updateDoc(self, col):
    
62.         self.articledb = self.client[self.dbname]
    
63.         comment = self.articledb[col]
    
64.         comment.update_one(update_old,
    
65.                            update_new)
    
66. 
    
67.     def deleteDoc(self, col):
    
68.         self.articledb = self.client[self.dbname]
    
69.         comment = self.articledb[col]
    
70.         comment.delete_one(one)
    
71. 
    
72. 
    
73. # 主程序入口
    
74. if __name__ == '__main__':
    
75.     test = Mgdbex()  # 创建类的实例对象
    
76.     # 0611
    
77.     test.getDBs()
    
78.     test.dbname = '0611'
    
79.     # test.insert("0611")
    
80.     # test.insertOne('0611')
    
81.     # test.find("0611")
    
82.     test.getColl()

复制代码

appmgex.py

1. from mgex import Mgdbex
   
2. 
   
3. Mg = Mgdbex()
   
4. # Mg.getDBs()
   
5. Mg.dbname = '0611'
   
6. # 已经存在的时候创建会错误
   
7. # Mg.createColl('37创')
   
8. # Mg.dropColl('37创')
   
9. # Mg.getColl()
   
10. # Mg.insertOne('user')
    
11. # Mg.insert('user')
    
12. Mg.updateDoc('user')
    
13. # Mg.deleteDoc('user')
    
14. Mg.find('user')

复制代码