Method DeleteDatabase

class/databaseModel/pgsqlModel.py:566–599

@删除数据库

(self, get)

            return public.returnMsg(False,str(e))

    def DeleteDatabase(self, get):
        """
        @删除数据库
        """
        id = get['id']
        find = public.M('databases').where("id=? AND LOWER(type)=LOWER('PgSql')", (id,)).field('id,pid,name,username,password,accept,ps,addtime,db_type,conn_config,sid,type').find()
        if not find: return public.returnMsg(False, '指定数据库不存在.')

        name = get['name']
        username = find['username']

        pgsql_obj = self.get_sql_obj_by_sid(find['sid'])
        status, err_msg = pgsql_obj.connect()
        if status is False:
            return public.returnMsg(False, "连接数据库失败！")

        # 查询当前数据是否被连接
        data_list = pgsql_obj.query("""SELECT * FROM pg_stat_activity WHERE datname = '{}';""".format(name))
        if data_list:
            return public.returnMsg(False, "删除失败！当前数据库正在连接中！")
        resp = pgsql_obj.execute("""DROP DATABASE "{}";""".format(name))
        if resp is not None:
            return public.returnMsg(False, "删除数据库失败！")
        pgsql_obj.execute("""DROP USER "{}";""".format(username))
        # 删除SQLITE
        public.M('databases').where("id=? AND LOWER(type)=LOWER('PgSql')", (id,)).delete()
        public.WriteLog("TYPE_DATABASE", 'DATABASE_DEL_SUCCESS', (name,))

        #删除配置文件中的数据库配置
        try:
            self.DeletePluginDatabaseConf(name)
        except:
            pass
        return public.returnMsg(True, 'DEL_SUCCESS')

    def ToBackup(self, args):
        """