Method ToBackup

class/databaseModel/pgsqlModel.py:601–707

@备份数据库 id 数据库id

(self, args)

        return public.returnMsg(True, 'DEL_SUCCESS')

    def ToBackup(self, args):
        """
        @备份数据库 id 数据库id
        """
        if not os.path.exists(self._PGDUMP_BIN):
            return public.returnMsg(False, '缺少备份工具，请先通过软件商店pgsql管理器!')

        if not hasattr(args, "id"):
            return public.returnMsg(False, "缺少参数！id")
        db_id = args.id
        table_list = getattr(args, "table_list", [])
        storage_type = getattr(args, "storage_type", "db")

        if storage_type not in ["db", "table"]:
            return public.returnMsg(False, "参数错误！storage_type")

        db_find = public.M('databases').where("id=? AND LOWER(type)=LOWER('pgsql')", (db_id,)).find()
        if not db_find: return public.returnMsg(False, '数据库不存在!')

        if not db_find["password"].strip():
            return public.returnMsg(False, '数据库密码为空，请先设置密码.')

        db_name = db_find["name"]

        db_user = "postgres"
        db_host = "127.0.0.1"
        if db_find["db_type"] == 0:
            db_port = panelPgsql.get_config_options("port", int, 5432)

            t_path = os.path.join(public.get_panel_path(), "data/postgresAS.json")
            if not os.path.isfile(t_path):
                return public.returnMsg(False, "请先设置管理员密码！")
            db_password = json.loads(public.readFile(t_path)).get("password", "")
            if not db_password:
                return public.returnMsg(False, "数据库密码为空！请先设置数据库密码！")
        elif db_find["db_type"] == 1:
            # 远程数据库
            conn_config = json.loads(db_find["conn_config"])
            db_host = conn_config["db_host"]
            db_port = conn_config["db_port"]
            db_user = conn_config["db_user"]
            db_password = conn_config["db_password"]
        elif db_find["db_type"] == 2:
            conn_config = public.M("database_servers").where("id=? AND LOWER(db_type)=LOWER('pgsql')", db_find["sid"]).find()
            db_host = conn_config["db_host"]
            db_port = conn_config["db_port"]
            db_user = conn_config["db_user"]
            db_password = conn_config["db_password"]
        else:
            return public.returnMsg(False, "未知的数据库类型")

        pgsql_obj = panelPgsql().set_host(host=db_host, port=db_port, database=None, user=db_user, password=db_password)
        status, err_msg = pgsql_obj.connect()
        if status is False:
            return public.returnMsg(False, "连接数据库[{}:{}]失败".format(db_host, int(db_port)))

        db_backup_dir = os.path.join(self._PGSQL_BACKUP_DIR, db_name)
        if not os.path.exists(db_backup_dir):