[mongodb] pymongo 예시

pymongo site : http://api.mongodb.org/python/current/

# ?/usr/bin/python

import pymongo

class Database():

    def __init__(self, address=DB_DEFAULT_ADDRESS, port=DB_DEFAULT_PORT):

        self.port = port

        self.address = address

          

    def getDb(self, dbName=DB_DEFAULT_NAME):

        client = pymongo.MongoClient(self.address, self.port)

        return client[dbName]

    

class DbQuery():

    def __init__(self, db):

        self.db = db

        

    def insert(self, col, val):

        try:

            self.db[col].insert(val)

        except Exception as e:

            return e.args[0]

        

    def remove(self, col, id):

        try:

            self.db[col].remove(where)

        except Exception as e:

            return e.args[0]

    

    def set(self, col, where, val):

        try:

            self.db[col].update(where, {"$set":val})

        except Exception as e:

            return e.args[0]

    

    def push(self, col, where, val):

        try:

            self.db[col].update(where, {"$push": val}, True)

        except Exception as e:

            return e.args[0]

        

    def pull(self, col, where, val):

        try:

            self.db[col].update(where, {"$pull": val}, True)

        except Exception as e:

            return e.args[0]

        

    def find(self, col, where, val):

        try:

            return self.db[col].find(where, val)

        except Exception as e:

            return e.args[0]

        return e.args[0]

    

    def findOne(self, col, where, val):

        try:

            return self.db[col].find_one(where, val)

        except Exception as e:

            return e.args[0]

        return e.args[0]

    

    def inc(self, col, where, val):

        try:

            self.db[col].update(where, {"$inc":val})

        except Exception as e:

            return e.args[0]