tfse-admin-api-v0.2/user/user_db.py

import pymongo

MG_USER = "root"
MG_PWD = "RYIHrqml#LSW6#!*"
MG_HOST = "116.63.130.34"
MG_PORT = "27020"
CLIENT = pymongo.MongoClient('mongodb://{}:{}@{}:{}'.format(MG_USER, MG_PWD, MG_HOST, MG_PORT))


def INSERT_DATA(param1, param2, param3):
    """
    插入一条数据
    Parameters:
        param1: str 数据库
        param2: str 数据集
        param3: obj 插入数据
    Returns:
        True 执行成功
        False 执行失败
    """
    collection = CLIENT[param1][param2][param3]
    collection.insert_one(param3)
    return True


def DELETE_DATA(param1, param2, param3):
    """
    根据查询条件删除一条文档
    Parameters:
        param1: str 数据库
        param2: str 数据集
        param3: obj 查询条件
    Returns:
        True 执行完成
    """
    collection = CLIENT[param1][param2][param3]
    collection.delete_one(param3)
    return True


def UPDATE_DATA(param1, param2, param3, param4):
    """
    Parameters:
        param1: str 数据库
        param2: str 数据集
        param3: obj 查询条件
        param4: obj 插入数据
    Returns:
        True 执行完成
    """
    collection = CLIENT[param1][param2][param3]
    collection.update_one(param3, param4)
    return True


def UPSERT_DATA(param1, param2, param3, param4):
    """
    Parameters:
        param1: str 数据库
        param2: str 数据集
        param3: obj 查询条件
        param4: obj 插入数据
    Returns:
        True 执行完成
    """
    collection = CLIENT[param1][param2][param3]
    collection.update_one(param3, {"$set": param4}, upsert=True)
    return True


def FIND_DATA(param1, param2, param3):
    """
    根据查询条件查询符合条件的所有数据
    Parameters:
        param1: str 数据库
        param2: str 数据集
        param3: obj 查询条件
    Returns:
        records: list 符合条件的数据
    """
    collection = CLIENT[param1][param2][param3]
    records = list(collection.find(param3, {'_id': False}))
    return records