python mongodb案例

37ck

1. # pip install pymongo==3.12.0
   
2. from pymongo import MongoClient
   
3. 
   
4. data = [
   
5.         {
   
6.                 # "_id": "8",
   
7.                 "articleid": "100001",
   
8.                 "content": "吃饭千万不能吃多了，因为会饱",
   
9.                 "userid": "1008",
   
10.                 "nickname": "天涯若比邻",
    
11.                 "age": "21",
    
12.                 "phone": "135846240285",
    
13.                 "createdatetime": "new Date()",
    
14.                 "likenum": "666",
    
15.                 "state": "1",
    
16.         },
    
17.         {
    
18.                 # "_id": "9",
    
19.                 "articleid": "100001",
    
20.                 "content": "吃饭前，先喝杯水或一碗汤，可减少饭量，对控制体重有帮助",
    
21.                 "userid": "1008",
    
22.                 "nickname": "玛丽莲·梦露",
    
23.                 "age": "18",
    
24.                 "phone": "13937165554",
    
25.                 "createdatetime": "new Date()",
    
26.                 "likenum": "8888",
    
27.                 "state": "null",
    
28.         }
    
29. ]
    
30. 
    
31. 
    
32. class Test:
    
33.         # 创建类的狗仔函数或初始化方法，其中包含一个参数self，表示类的示例，self在定义类的方法时是必须要有的，在带哦用时可以不传入相应参数
    
34.         def __init__(self):
    
35.                 # 获取数据库的连接
    
36.                 # self.client = MongoClient('127.0.0.1', 27017)#本地数据库
    
37.                 self.client = MongoClient("mongodb://root:37ck2020@iot.37ck.cn:27017")#远程数据库
    
38.                 self.dbname = "37ck0604"
    
39.                 print(self.client)
    
40.                 dbs = self.client.list_database_names()
    
41.                 for db in dbs:
    
42.                         print("数据库列表：" + db)
    
43.        
    
44.         def getDBs(self):
    
45.                 dbs = self.client.list_database_names()
    
46.                 for db in dbs:
    
47.                         print(db)
    
48.        
    
49.         def getColl(self):
    
50.                 articledb = self.client["articledb"]
    
51.                 collections = articledb.list_collection_names()
    
52.                 for collection in collections:
    
53.                         print(collection)
    
54.        
    
55.         def createColl(self):
    
56.                 articledb = self.client["articledb"]
    
57.                 articledb.create_collection("itcast")
    
58.        
    
59.         def dropColl(self):
    
60.                 articledb = self.client["articledb"]
    
61.                 articledb.drop_collection("itcast")
    
62.        
    
63.         def findDoc(self):
    
64.                 self.articledb = self.client["articledb"]
    
65.                 comment = self.articledb["comment"]
    
66.                 documents = comment.find()
    
67.                 for document in documents:
    
68.                         print(document)
    
69.        
    
70.         def insertOneDoc(self):
    
71.                 self.articledb = self.client["articledb"]
    
72.                 comment = self.articledb["comment"]
    
73.                 newDoc = {
    
74.                         # "_id": "7",
    
75.                         "articleid": "100001",
    
76.                         "content": "脱水会使人精疲力竭，而喝水可以使人精神饱满",
    
77.                         "userid": "1007",
    
78.                         "nickname": "咫尺天涯间",
    
79.                         "age": "25",
    
80.                         "phone": "13937165554",
    
81.                         "createdatetime": "new Date()",
    
82.                         "likenum": "999",
    
83.                         "state": "1",
    
84.                 }
    
85.                 comment.insert_one(newDoc)
    
86.        
    
87.         def find(self,col):
    
88.                 self.articledb = self.client[self.dbname]
    
89.                 comment = self.articledb[col]
    
90.                 documents = comment.find()
    
91.                 for document in documents:
    
92.                         print(document)
    
93.        
    
94.         def insert(self,col):
    
95.                 self.articledb = self.client[self.dbname]
    
96.                 comment = self.articledb[col]
    
97.                 re = comment.insert_many(data)
    
98.                 print(re)
    
99.        
    
100.         def insertManyDoc(self):
     
101.                 self.articledb = self.client["articledb"]
     
102.                 comment = self.articledb["comment"]
     
103.                 newDocs = [
     
104.                         {
     
105.                                 # "_id": "8",
     
106.                                 "articleid": "100001",
     
107.                                 "content": "吃饭千万不能吃多了，因为会饱",
     
108.                                 "userid": "1008",
     
109.                                 "nickname": "天涯若比邻",
     
110.                                 "age": "21",
     
111.                                 "phone": "135846240285",
     
112.                                 "createdatetime": "new Date()",
     
113.                                 "likenum": "666",
     
114.                                 "state": "1",
     
115.                         },
     
116.                         {
     
117.                                 # "_id": "9",
     
118.                                 "articleid": "100001",
     
119.                                 "content": "吃饭前，先喝杯水或一碗汤，可减少饭量，对控制体重有帮助",
     
120.                                 "userid": "1008",
     
121.                                 "nickname": "玛丽莲·梦露",
     
122.                                 "age": "18",
     
123.                                 "phone": "13937165554",
     
124.                                 "createdatetime": "new Date()",
     
125.                                 "likenum": "8888",
     
126.                                 "state": "null",
     
127.                         }
     
128.                 ]
     
129.                 re = comment.insert_many(newDocs)
     
130.                 print(re)
     
131.        
     
132.         def updateDoc(self):
     
133.                 self.articledb = self.client["articledb"]
     
134.                 comment = self.articledb["comment"]
     
135.                 comment.update_one({"content": "脱水会使人精疲力竭，而喝水可以使人精神饱满"},
     
136.                                    {"$set": {"content": "吃饭前，先喝杯水或一碗汤，可减少饭量，对控制体重有明显的帮助"}})
     
137.        
     
138.         def deleteDoc(self):
     
139.                 self.articledb = self.articledb = self.client["articledb"]
     
140.                 comment = self.articledb["comment"]
     
141.                 comment.delete_one({"nickname": "咫尺天涯间"})
     
142. 
     
143. 
     
144. # 主程序入口
     
145. if __name__ == '__main__':
     
146.         # 创建类的实例对象
     
147.         test = Test()
     
148.         test.insert("user")
     
149.         test.find("user")
     
150.         # test.getDBs()
     
151.         # test.createColl()
     
152.         # test.dropColl()
     
153.         # test.getColl()
     
154.         # test.insertOneDoc()
     
155.         # test.insertManyDoc()
     
156.         # test.updateDoc()
     
157.         # test.deleteDoc()
     
158.         # test.findDoc()
     

复制代码