0611 mgdata

37ck

mgdata.py

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

复制代码

appmgex.py

1. # pip install pymongo==3.12.0
   
2. from pymongo import MongoClient
   
3. from mgdata import data,newDoc,url,coll
   
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 = "37ck0604"
    
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 insertOneDoc(self):
    
45.         self.articledb = self.client["articledb"]
    
46.         comment = self.articledb["comment"]
    
47.         comment.insert_one(newDoc)
    
48. 
    
49.     def find(self, col):
    
50.         self.articledb = self.client[self.dbname]
    
51.         comment = self.articledb[col]
    
52.         documents = comment.find()
    
53.         for document in documents:
    
54.             print(document)
    
55. 
    
56.     def insert(self, col):
    
57.         self.articledb = self.client[self.dbname]
    
58.         comment = self.articledb[col]
    
59.         re = comment.insert_many(data)
    
60.         print(re)
    
61. 
    
62.     def insertManyDoc(self):
    
63.         self.articledb = self.client["articledb"]
    
64.         comment = self.articledb["comment"]
    
65.         re = comment.insert_many(data)
    
66.         print(re)
    
67. 
    
68.     def updateDoc(self):
    
69.         self.articledb = self.client["articledb"]
    
70.         comment = self.articledb["comment"]
    
71.         comment.update_one({"content": "脱水会使人精疲力竭，而喝水可以使人精神饱满"},
    
72.                            {"$set": {"content": "吃饭前，先喝杯水或一碗汤，可减少饭量，对控制体重有明显的帮助"}})
    
73. 
    
74.     def deleteDoc(self):
    
75.         self.articledb = self.articledb = self.client["articledb"]
    
76.         comment = self.articledb["comment"]
    
77.         comment.delete_one({"nickname": "咫尺天涯间"})
    
78. 
    
79. # 主程序入口
    
80. if __name__ == '__main__':
    
81.     # 创建类的实例对象
    
82.     test = Mgdbex()
    
83.     test.dbname='0611'
    
84.     test.insert("37ck")
    
85.     test.find("37ck")
    
86.     # test.getDBs()
    
87.     # test.createColl()
    
88.     # test.dropColl()
    
89.     # test.getColl()
    
90.     # test.insertOneDoc()
    
91.     # test.insertManyDoc()
    
92.     # test.updateDoc()
    
93.     # test.deleteDoc()
    
94.     # test.findDoc()
    

复制代码