栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Python

Python 操作MongoDB

Python 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Python 操作MongoDB

丝毫没有考虑并发量,事务等,留待完善

from pymongo import MongoClient

class User:

    FirstName = None
    LastName = None
    Email = None
    Password = None

    def __init__(self,Email,Password,FirstName,LastName = ""):
        self.Email = Email
        self.Password = Password
        self.FirstName = FirstName
        self.LastName = LastName
    def json(self):
        json = {
                    "Email":self.Email,
                    "Password":self.Password,
                    "FirstName":self.FirstName,
                    "LastName":self.LastName
                }
        return json

class GameDB:

    url = ""
    client = None
    db = None
    def __init__(self,url = "mongodb://jo:jokda@localhost"):
        self.url = url
        self.client = MongoClient(self.url)
        self.db = self.client.game

    def insert(self,user,flag=False):
        if flag:
            self.db.inventory.insert_many(user)
            return 1
        select = self.select({"Email":user.Email})
        if len(select) != 0 :
            return -1
        json_user = user.json()
        self.db.inventory.insert_one(json_user)
        return 1

    def select(self,condition={}):
        cursor = self.db.inventory.find(condition)
        result = [doc for doc in cursor]
        return result

    def update(self,user:User,flag=True):
        select = self.select({"Email":user.Email})
        if len(select)<1:
            return -1

        if flag :
            self.db.inventory.update_many(
                {"Email":user.Email},
                {"$set":{
                    "Password":user.Password,
                    "FirstName":user.FirstName,
                    "LastName":user.LastName
                }},
            )
            return 1

        self.db.inventory.update_one(
                {"Email":user.Email},
                {"$set":{
                    "$Password":user.Password,
                    "$FirstName":user.FirstName,
                    "$LastName":user.LastName
                }},
        )
        return 1

    def delete(self,condition,flag=True):
        if flag :
            self.db.inventory.delete_many(condition)
        else:
            self.db.inventory.delete_one(condtion)
        return 1

#user = User("19@qq.com","password","pa","zika")

#db = GameDB()
#db.add(user)
#db.printf()

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/665151.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号