WalMiner2.0 Beta(2020-6-7更新)

make && make install

create extension walminer;

-- 添加wal文件：
select walminer_wal_add('/opt/test/wal');
-- 注：参数可以为目录或者文件

-- 移除wal文件：
select walminer_wal_remove('/opt/test/wal');
-- 注：参数可以为目录或者文件

-- 列出wal文件：
select walminer_wal_list();

--解析add的全部wal日志
select walminer_all();
或 select wal2sql();

--在add的wal日志中查找对应时间范围的wal记录
--可以参照walminer_time.sql回归测试中的使用用例
select walminer_by_time(starttime, endtime);
或 select wal2sql(starttime, endtime);

--在add的wal日志中查找对应lsn范围的wal记录
--可以参照walminer_lsn.sql回归测试中的使用用例
select walminer_by_lsn(startlsn, endlsn);
或 select wal2sql(startlsn, endlsn);

--在add的wal日志中查找对应xid的wal记录
--可以参照walminer_lsn.sql回归测试中的使用用例
--前一个walminer版本对xid的支持是范围解析，但是xid的提交是不连续的
--会导致各种问题，所以这个版本只支持单xid解析
select walminer_by_xid(xid);
或 select wal2sql(xid);

--在add的wal日志中查找对应时间范围的wal记录
select walminer_by_time(starttime, endtime,'true'); 
或 select wal2sql(starttime, endtime,'true');
--在add的wal日志中查找对应lsn范围的wal记录
select walminer_by_lsn(startlsn, endlsn,'true'); 
或 select wal2sql(startlsn, endlsn,'true');
--在add的wal日志中查找对应xid的wal记录
select walminer_by_xid(xid,'true'); 
或 select wal2sql(xid,'true');

select * from walminer_contents;

-- 表walminer_contents 
(
 sqlno int, 		--本条sql在其事务内的序号
 xid bigint,		--事务ID
 topxid bigint,		--如果为子事务，这是是其父事务；否则为0
 sqlkind int,		--sql类型1->insert;2->update;3->delete(待优化项目)
 minerd bool,		--解析结果是否完整(缺失checkpoint情况下可能无法解析出正确结果)
 timestamp timestampTz, --这个SQL所在事务提交的时间
 op_text text,		--sql
 undo_text text,	--undo sql
 complete bool		--如果为false，说明有可能这个sql所在的事务是不完整解析的
)

select walminer_stop();

create extension walminer;

select walminer_build_dictionary('/opt/proc/store_dictionary');
-- 注：参数可以为目录或者文件

create extension walminer;

select walminer_load_dictionary('/opt/test/store_dictionary');
-- 注：参数可以为目录或者文件

-- 增加wal文件：
select walminer_wal_add('/opt/test/wal');
-- 注：参数可以为目录或者文件

-- 移除wal文件：
select walminer_wal_remove('/opt/test/wal');
-- 注：参数可以为目录或者文件

-- 列出wal文件：
select walminer_wal_list();
-- 注：参数可以为目录或者文件

select * from walminer_contents;

select walminer_stop();