python连接mongodb数据库操作数据示例

2023-07-10 11:40:03 68

#encoding=utf-8 ''' MongoConn连接类 ''' importpymongo classDBConn: conn=None servers="mongodb://localhost:27017" defconnect(self): self.conn=pymongo.Connection(self.servers) defclose(self): returnself.conn.disconnect() defgetConn(self): returnself.conn

#encoding=utf-8 ''' Mongo操作Demo Done: ''' importMongoDBConn dbconn=MongoDBConn.DBConn() conn=None lifeba_users=None defprocess(): #建立连接 dbconn.connect() globalconn conn=dbconn.getConn() #列出server_info信息 printconn.server_info() #列出全部数据库 databases=conn.database_names() printdatabases #删除库和表 dropTable() #添加数据库lifeba及表(collections)users createTable() #插入数据 insertDatas() #更新数据 updateData() #查询数据 queryData() #删除数据 deleteData() #释放连接 dbconn.close() definsertDatas(): datas=[{"name":"steven1","realname":"测试1","age":25}, {"name":"steven2","realname":"测试2","age":26}, {"name":"steven1","realname":"测试3","age":23}] lifeba_users.insert(datas) defupdateData(): '''只修改最后一条匹配到的数据第3个参数设置为True,没找到该数据就添加一条第4个参数设置为True,有多条记录就不更新 ''' lifeba_users.update({'name':'steven1'},{'$set':{'realname':'测试1修改'}},False,False) defdeleteData(): lifeba_users.remove({'name':'steven1'}) defqueryData(): #查询全部数据 rows=lifeba_users.find() printResult(rows) #查询一个数据 printlifeba_users.find_one() #带条件查询 printResult(lifeba_users.find({'name':'steven2'})) printResult(lifeba_users.find({'name':{'$gt':25}})) defcreateTable(): '''创建库和表''' globallifeba_users lifeba_users=conn.lifeba.users defdropTable(): '''删除表''' globalconn conn.drop_database("lifeba") defprintResult(rows): forrowinrows: forkeyinrow.keys():#遍历字典 printrow[key],#加,不换行打印 print'' if__name__=='__main__': process()

python连接mongodb数据库操作数据示例

热门推荐

随机推荐