python连接mongodb操作代码，pythonmongodb代码,__author__ =
__author__ = 'Administrator'#pip install pymongofrom bson.objectid import ObjectIdimport pymongoimport timeclass pgo: def __init__(self, ip, port, db, tb): self.ip = ip self.port = port self.db = db self.tb = tb def run(self): num = 0 try: conn = pymongo.Connection(self.ip, self.port) #db = conn.kkk[self.database] #data = db.kkk print('88888') db = conn[self.db] data = db[self.tb].find() for i in data: num += 1 print(i,num) print(i['_id'], i['name'], '\t', i['age'], '\t', i['bm'], '\t', i['date'], '\t', i['mod_date'], '\t', num) print('姓名', '\t', '年龄', '\t', '部门', '\t', '注册日期', '\t\t\t\t\t\t', '修改日期', '\t\t\t\t\t\t', '统计') conn.close() return data except Exception as e: conn.close() print('Fail:', '\t', e) def add(self, name, age, bm): try: conn = pymongo.Connection(self.ip, self.port) db = conn[self.db] data = db[self.tb] #data.insert({'name':'kkk', 'age':22, 'bm':'op'}) data.insert({'name':name,'age':age,'bm':bm,'date':(time.strftime('%Y-%m-%d %H:%M'))}) conn.close() print('OK') except: conn.close() print('Fail!') def remove(self, xarg): try: conn = pymongo.Connection(self.ip, self.port) db = conn[self.db] data = db[self.tb] #id ='ObjectId("%s")'%xarg id = '%s'%xarg data.remove({"_id": ObjectId(id)}) #data.remove(xarg) conn.close() print('OK') except: conn.close() print('Fail!') def update(self, *xarg): try: conn = pymongo.Connection(self.ip, self.port) db = conn[self.db] data = db[self.tb] #data.update({"name":{'$eq':'kkk'}}, {'$set':{'age':10}}, upsert=False, multi=True) data.update(*xarg,upser=False, multi=True) conn.close() print('OK') except: conn.close() print('Fail!')if __name__ == '__main__': #a = "549be654b69e727c1396c8f8" #pgo('127.0.0.1', 27017, 'kkk', 'kkk').remove(a) #pgo('127.0.0.1', 27017, 'kkk', 'kkk').add('kkk', 99, 'OP') pgo('127.0.0.1', 27017, 'kkk', 'kkk').update({'name':'user_18'}, {'$set':{'date':(time.strftime('%Y-%m-%d %H:%M')), 'mod_date':(time.strftime('%Y-%m-%d %H:%M'))}})2-__author__ = 'Administrator'#pip install pymongo#from bson.objectid import ObjectIdimport pymongoimport timeclass pgo: def __init__(self, ip, port, db, tb): self.ip = ip self.port = port self.db = db self.tb = tb def run(self): try: conn = pymongo.Connection(self.ip, self.port) db = conn[self.db] data = db[self.tb].find({}).limit(1500) conn.close() return data except Exception as e: conn.close() def find(self,xarg): try: conn = pymongo.Connection(self.ip, self.port) db = conn[self.db] data = db[self.tb].find_one(xarg) conn.close() return data except Exception as e: conn.close() def add(self, xarg): try: conn = pymongo.Connection(self.ip, self.port) db = conn[self.db] data = db[self.tb] data.insert(xarg) conn.close() except: conn.close() def remove(self, xarg): try: conn = pymongo.Connection(self.ip, self.port) db = conn[self.db] data = db[self.tb] data.remove(xarg) conn.close() except: conn.close() def insert(self, xarg): try: conn = pymongo.Connection(self.ip, self.port) db = conn[self.db] data = db[self.tb] data.insert(xarg) conn.close() except: conn.close() def save(self, xarg): try: conn = pymongo.Connection(self.ip, self.port) db = conn[self.db] data = db[self.tb] data.save(xarg) conn.close() except: conn.close() def update(self, *xarg): try: conn = pymongo.Connection(self.ip, self.port) db = conn[self.db] data = db[self.tb] #data.update({"name":{'$eq':'kkk'}}, {'$set':{'age':10}}, upsert=False, multi=True) data.update(*xarg, upser=False, multi=True) conn.close() except: conn.close()if __name__ == '__main__': #pgo('127.0.0.1', 27017, 'kkk', 'kkk').remove({'name':'kkk', 'age':{"$gte":32}}) #pgo('127.0.0.1', 27017, 'kkk', 'kkk').add('kkk', 99, 'OP') #pgo('127.0.0.1', 27017, 'kkk', 'kkk').update({}, {'$set':{'date': (time.strftime("%Y-%m-%d_%H:%M")), 'mod_date': (time.strftime("%Y-%m-%d_%H:%M"))}}) pgo('127.0.0.1', 27017, 'kkk', 'kkk').run()
评论关闭