Method InputSql

class/databaseModel/sqlserverModel.py:236–278

(self, get)

    # 导入
    def InputSql(self, get):

        name = get.name
        file = get.file

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

        tmp = file.split('.')
        exts = ['sql', 'zip', 'bak']
        ext = tmp[len(tmp) - 1]
        if ext not in exts:
            return public.returnMsg(False, 'DATABASE_INPUT_ERR_FORMAT')

        backupPath = session['config']['backup_path'] + '/database'

        if ext == 'zip':
            try:
                fname = os.path.basename(file).replace('.zip', '')
                dst_path = backupPath + '/' + fname
                if not os.path.exists(dst_path): os.makedirs(dst_path)

                public.unzip(file, dst_path)
                for x in os.listdir(dst_path):
                    if x.find('bak') >= 0 or x.find('sql') >= 0:
                        file = dst_path + '/' + x
                        break
            except:
                return public.returnMsg(False, '导入失败，该文件不是有效的zip格式的文件。')

        mssql_obj = self.get_mssql_obj_by_sid(find['sid'])
        data = mssql_obj.query("use %s ;select filename from sysfiles" % find['name'])

        isError = self.IsSqlError(data)
        if isError != None: return isError
        if type(data) == str: return public.returnMsg(False, data)

        mssql_obj.execute("ALTER DATABASE %s SET OFFLINE WITH ROLLBACK IMMEDIATE" % (find['name']))
        mssql_obj.execute("use master;restore database %s from disk='%s' with replace, MOVE N'%s' TO N'%s',MOVE N'%s_Log'  TO N'%s' " % (find['name'], file, find['name'], data[0][0], find['name'], data[1][0]))
        mssql_obj.execute("ALTER DATABASE %s SET ONLINE" % (find['name']))

        public.WriteLog("TYPE_DATABASE", '导入数据库[{}]成功'.format(name))
        return public.returnMsg(True, 'DATABASE_INPUT_SUCCESS')

    # 同步数据库到服务器
    def SyncToDatabases(self, get):