restore

语法

restore(backupDir, dbPath, tableName, partition, [force=false], [outputTable], [parallel=false], [snapshot=true])

参数

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

dbPath 字符串,表示已备份的分布式数据库的路径。

tableName 字符串,表示已备份的表的名称。

partition 字符串,表示要恢复的分区的相对路径。分区路径可以包含通配符(“%”和”?”), “?”表示单个字符,”%”表示0,1或多个字符。

  • 若仅恢复某个分区,输入分区的相对路径或者”%/”+”分区名称”。举例:要恢复”dfs://compoDB”下的分区”20170810/50_100”,输入”/compoDB/20170807/0_50”或者”%/20170807/0_50”。 请注意:若使用 1.30.16 ~ 1.30.18 版本 server,对表级分区数据进行备份和恢复时,该参数必须指定路径到物理索引(可通过函数 listTables 获取),例如分区 “/compoDB/20170807/0_50” 下表的物理索引为8,则 partition 需指定为 “/compoDB/20170807/0_50/8”。

  • 若需要恢复所有分区,直接输入”%”。 但需注意,采用此方法可能会导致当前数据表的数据丢失。举例说明:若当前表有10个分区,备份只包含2个分区,若使用%恢复数据,则可能导致表中其他8个分区的数据丢失。

force 布尔值,表示是否强制恢复。默认值为false,表示只有元数据与备份数据元数据不一致的分区,才会恢复。

outputTable 分布式表句柄,该表的结构必须与要恢复的表结构一致。如果没有指定outputTable,恢复后的数据会存放到原表;如果指定了outputTable,恢复后的数据会存放到该表中,而原数据表保持不变。

parallel 布尔值,表示是否对一个数据表下不同分区进行并行恢复。默认值为 false。

snapshot 仅在参数 partition = “%” 时有效。表示进行非首次恢复时,备份中若存在被删除的表/分区,是否同步将数据库中对应的表/分区删除。 若设置为 true,则数据库将同步删除备份中不存在的分区或表;否则不会删除。

详情

恢复指定分区的数据。返回一个字符串向量,包含恢复的分区的路径。该函数必须要用户登录后才能执行。

注意事项

  • 恢复通过 SQL 元代码(即 backup 指定 sqlObj 参数)备份的文件时,不能指定 snapshot,否则会报错。

  • 指定 outputTable 时,恢复通过 SQL 元代码备份的文件,系统会在 outputTable 中直接追加(append)备份数据;而恢复通过拷贝方式(即 backup 指定 dbPath 参数)备份的文件时,系统只覆盖 outputTable 中数据不一致的分区。若不指定 outputTable,则数据恢复至原表,恢复方式相同。

  • 恢复时需要确保备份数据与待恢复数据库的引擎类型(engine)一致,且 partitionScheme(VALUE 除外)也保持一致。当采用 VALUE 分区时,须保证备份数据中的分区方案是待恢复数据库的分区方案的子集。例如:备份文件的分区方案是 database(“dfs://xxx”, VALUE, 2017.08.07..2017.08.11), 则待恢复数据库的 VALUE 分区范围必须不小于 2017.08.07..2017.08.11。

例子

创建一个组合分区的数据库dfs://compoDB:

n=1000000
ID=rand(100, n)
dates=2017.08.07..2017.08.11
date=rand(dates, n)
x=rand(10.0, n)
t=table(ID, date, x);

dbDate = database(, VALUE, 2017.08.07..2017.08.11)
dbID=database(, RANGE, 0 50 100);
db = database("dfs://compoDB", COMPO, [dbDate, dbID]);
pt = db.createPartitionedTable(t, `pt, `date`ID)
pt.append!(t);

备份表 pt 的所有数据:

backup("/home/DolphinDB/backup",<select * from loadTable("dfs://compoDB","pt")>,true);
// output
10

例1. 恢复所有数据到原表。

restore("/home/DolphinDB/backup","dfs://compoDB","pt","%",true);
// output
["dfs://compoDB/20170807/0_50/6F","dfs://compoDB/20170807/50_100/6F","dfs://compoDB/20170808/0_50/6F","dfs://compoDB/20170808/50_100/6F","dfs://compoDB/20170809/0_50/6F","dfs://compoDB/20170809/50_100/6F","dfs://compoDB/20170810/0_50/6F","dfs://compoDB/20170810/50_100/6F","dfs://compoDB/20170811/0_50/6F","dfs://compoDB/20170811/50_100/6F"]

例2. 恢复日期为2017.08.10的数据。

restore("/home/DolphinDB/backup","dfs://compoDB","pt","%20170810%",true)
// output
["dfs://compoDB/20170810/0_50/6F","dfs://compoDB/20170810/50_100/6F"]

例3. 在数据库 dfs://compoDB 中创建一个与表 pt 结构相同的表 temp,把 pt 的数据恢复到表 temp。请注意,采用此方法可能导致表中数据丢失。

temp=db.createPartitionedTable(t, `pt, `date`ID);

restore("/home/DolphinDB/backup","dfs://compoDB","pt","%",true,temp);
// output
["dfs://compoDB/20170807/0_50/6F","dfs://compoDB/20170807/50_100/6F","dfs://compoDB/20170808/0_50/6F","dfs://compoDB/20170808/50_100/6F","dfs://compoDB/20170809/0_50/6F","dfs://compoDB/20170809/50_100/6F","dfs://compoDB/20170810/0_50/6F","dfs://compoDB/20170810/50_100/6F","dfs://compoDB/20170811/0_50/6F","dfs://compoDB/20170811/50_100/6F"]

select count(*) from temp;
count
1000000

相关函数:restoreDB, restoreTable, migrate, backup