python连接mongodb操作代码

2015/03/03 36531

清华大佬耗费三个月吐血整理的几百G的资源，免费分享！....>>>

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
__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'))}})

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
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()