python连接mongo

连接mongodb数据库

用到pymongo模块

应该是这样来使用：

from pymongo import MongoClient

conn = MongoClient(host= host, port=port)

db = conn[db]#连接指定数据库

db[col].find_one(x)

db.spgoods.find_one(x)

db[col].update({"_id": spinfo["_id"]}, spinfo, True)

db[col].update({"_id": spinfo["_id"]},{"$set":spinfo}, True)

.db[table].insert(spinfo)

db[table].find()

还可以写成类的模式

class nosql:        def __init__(self,host, port, db):#主机地址，端口，数据库名称        self.conn = MongoClient(host= host, port=port)        self.db = self.conn[db]#连接指定数据库

def getthespgood(self, x):

    spdata = self.db["spgoods"].find_one(x)

    return spdata

def updatespgood(self, spinfo):    self.db["spgoods"].update({"_id": spinfo["_id"]}, spinfo, True)
    return True

conn = nosql(‘localhost‘, 27017, ‘goods‘)

然后连接数据库层这么写

def getSpinfo(item,value,depart,comp):    result = pnosql.conn.getthespgood({item: value, "depart":depart, "comp": comp})

得到这种形式的数据需要循环输出

def getspgoods(self,table):    spdata = self.db[table].find()    return spdata

来自为知笔记(Wiz)