checkBackup

checkBackup(backupDir, dbPath, [tableName], [partition])

backupDir 字符串，表示存放备份数据的目录。

dbPath 字符串，表示数据库路径。

tableName 字符串标量或向量，表示表名。若不指定，表示指定数据库下的所有表。

partition 表示分区。是字符串，表示备份分区的相对路径。分区路径可以包含通配符("%"和"?")，"?"表示单个字符，"%"表示0，1或多个字符。

• 若仅检查某个分区，输入分区的相对路径或者"%/"+”分区名称”。举例：要检查 "dfs://compoDB" 下的分区”20170810/50_100”，输入 "/compoDB/20170807/0_50" 或者 "%/20170807/0_50"。

• 若需要检查所有分区，直接输入"%"。

检查备份文件的的完整性和准确性。若所有备份文件均完整且准确，则返回一个空表；否则返回异常的备份文件信息，此时可通过在 backup 函数设置 force = true 开启强制备份以恢复受损的备份分区数据。

dbName = "dfs://compoDB2"
n=1000
ID=rand("a"+string(1..10), n)
dates=2017.08.07..2017.08.11
date=rand(dates, n)
x=rand(10, n)
t=table(ID, date, x)
db1 = database(, VALUE, 2017.08.07..2017.08.11)
db2 = database(, HASH,[INT, 20])
if(existsDatabase(dbName)){
   dropDatabase(dbName)
}
db = database(dbName, COMPO,[ db1,db2])

// 创建2个表
pt1 = db.createPartitionedTable(t, `pt1, `date`x).append!(t)
pt2 = db.createPartitionedTable(t, `pt2, `date`x).append!(t)

// SQL 元代码方式备份 pt1
backup(backupDir=backupDir1, sqlObj=<select * from pt1>, parallel=true)
// 拷贝文件方式备份 pt2
backup(backupDir=backupDir2, dbName, parallel=true, tableName=`pt2)

// pt2 备份文件都正常，pt1 中一个 chunk 文件出现问题
checkBackup(backupDir=backupDir2, dbPath=dbName, tableName="pt2")  // 返回一个空表
checkBackup(backupDir=backupDir1, dbPath=dbName, tableName="pt1")  // 返回出错的 chunk 信息

上例中，通过调用 checkBackup 函数，可以发现在 pt1 中存在损坏的 chunk 文件。此时，设置 force = true 再次强制备份，以恢复受损文件。

backup(backupDir1, <select * from pt1>,force=true, parallel=true)
checkBackup(backupDir=backupDir1, dbPath=dbName, tableName="pt1")  // 返回一个空表