| 注册
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
jopen
10年前发布

python连接mongodb操作代码

__author__ = 'Administrator'  #pip install  pymongo  from bson.objectid import ObjectId  import  pymongo  import  time  class 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 ObjectId  import pymongo  import  time     class 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()