有的时候，我们利用 ogg，dsg，datax 或者其他数据迁移同步工具将数据从 oracle 11g 迁移到 oracle 19c 时，有极小极小的可能会导致源端和目标端两边的数据不一致，比如少个索引，少个约束啥的，需要进一步比对数据一致性。当然有的时候也是为了给领导证明迁移过程中没有数据丢失的一种手段吧，oracle 的 oracle goldengate veridata 不仅可用于检查数据的不一致，而且能在数据不一致的情况下进行修复，但是需要付费才可以，实施起来有点难度，我这里其主要技术就是利用了 oracle 的 dblink 同时连接到一个库下进行 count 查询比对行数不一样的表，下面来一起看看。
注意： 当然对于不同版本的数据库，尤其是没有打 190716 psu 的 11.2.0.4 的数据库而言，如果你使用了 dblink 的话，那么你的数据库版本要都一样，不一样的话，很频繁的 dblink 会导致你的数据库的 scn 异常耗尽，出现 ora-19706: invalid scn 错误。scn 的异常增长通常来说：每秒最大允许的 16k/32k 增长速率已经足够了，但是不排除由于 bug，或者人为调整导致 scn 异常增长过大。特别是后者，比如数据库通过特殊手段强制打开，手工把 scn 递增得很大。同时 oracle 的scn会通过 dblink 进行传播。如果 a 库通过 dblink 连接到 b 库，如果 a 库的 scn 高于 b 库的 scn，那么 b 库就会递增 scn 到跟 a 库一样，反之如果 a 库的 scn 低于 b 库的 scn，那么 a 库的 scn 会递增到跟b库的 scn 一样。也就是说，涉及到 dblink 进行操作的多个库，它们会将 scn 同步到这些库中的最大的 scn。对 dblink 依赖很严重的系统可能会导致业务系统问题，严重情况下甚至会宕库，所以不同版本的没有补丁的数据库 dblink 最好少用。
首先创建 dblink
--创建 dblink，从目标库 link 到源库
create database link prod_link
connect to system
identified by "oracle123456"
using 'prod_link';
检查两边对象是否一致，如下存在两个 schema 的表分区，索引及自建类型不一致，并列出源端总个数。
select owner,object_type,count(object_name) from dba_objects@prod_link where owner in ('prod_cc','prod_op','prod_cb','cuwb','ous','cc_gmp') group by object_type,owner
minus
select owner,object_type,count(object_name) from dba_objects where owner in ('prod_cc','prod_op','prod_cb','cuwb','ous','cc_gmp') group by object_type,owner order by 1,3,2;
owner object_type count(object_name)
------------------------------ ----------------------- ------------------
ous table partition 17
ous table 308
ous index 1848
prod_cc type 1
着重检查不一致的对象
select owner,object_name from dba_objects@prod_link where owner='ous' and object_type='table partition'
minus
select owner,object_name from dba_objects where owner='ous' and object_type='table partition';
下面着重比较两端表行数是否一致，
方法一
1、创建统计表,在目标端使用 sys 用户创建一张表用于统计行结果 row_count_stats
drop table sys.row_count_stats;
create table sys.row_count_stats(schemaname varchar2(30),
tablename varchar2(50),
row_cnt_source number,
row_cnt_target number,
cnt_diff number);
2、配置 tns，创建 dblink
--先创建名为 prod_link 的 tns，然后创建 dblink
prod_link =
(description =
(address = (protocol = tcp)(host = 192.168.16.118)(port = 1521))
(connect_data =
(server = dedicated)
(service_name = sourcedb)
)
)
create public database link prod_link connect to system identified by 123456 using 'prod_link'; --这里写源库用户和密码
3、使用 sys 用户创建 table_list 表,将需要比对的用户和表插入新创建的 table_list 表。
drop table sys.table_list;
create table sys.table_list(schemaname varchar2(30),
tablename varchar2(50));
insert into sys.table_list select owner,table_name from dba_tables@prod_link
where owner in ('prod_cc','prod_op','prod_cb','cuwb','ous','cc_gmp') order by owner;
commit;
4、使用下面的命令比对数据是否一致
declare
v_schemaname varchar2(60);
v_tablename varchar2(60);
v_tarcount number(16) := 0;
v_srccount number(16) := 0;
v_sql1 varchar2(2000);
v_sql2 varchar2(2000);
v_sql3 varchar2(2000);
v_cntdiff number(16) := 0;
cursor cur_tablist is
select schemaname,tablename from sys.table_list;
begin
open cur_tablist;
loop
fetch cur_tablist
into v_schemaname,v_tablename;
exit when cur_tablist%notfound;
v_sql1 := 'select count(*) from "'||v_schemaname||'"."'||v_tablename ||'"';
--dbms_output.put_line(v_sql1);
execute immediate v_sql1 into v_tarcount;
v_sql2 := 'select count(*) from "'||v_schemaname||'"."'||v_tablename ||'"@prod_link';
execute immediate v_sql2 into v_srccount;
v_cntdiff :=v_tarcount - v_srccount;
v_sql3 := 'insert into sys.row_count_stats (schemaname,tablename,row_cnt_source,row_cnt_target,cnt_diff) values ('''||upper(v_schemaname)||''','''||v_tablename||''',' || v_srccount || ',' || v_tarcount || ',' || v_cntdiff || ')';
execute immediate v_sql3;
end loop;
close cur_tablist;
end;
/
完成后，可以在 row_count_stats 表中生成报告，以确定是否存在差异。根据该表的 cnt_diff 列结果进行判断，如果是0，则表示数量一致，如果不为0，则表示两端数据存在差异。
示例代码如下：
select * from sys.row_count_stats;
select * from sys.row_count_stats where cnt_diff !=0;
19:26:29 sys@testogg> select * from sys.row_count_stats where cnt_diff !=0;
schemaname tablename row_cnt_source row_cnt_target cnt_diff
------------------------------ -------------------------------------------------- -------------- -------------- ----------
prod_cc t_original 871882 871879 -3
prod_op t_sys_retryable_task 372263 372262 -1
方法二
pro_tab_cnt v3.0 存储过程对比数据（需要 sys 用户执行,已测试，源端和目标端用户需要一样），来源于网友分享。
所有操作均在目标库执行，不影响原库数据，在目标库创建表存放对比结果。
1、创建表 tab_cnt 用于存放结果
drop table tab_cnt purge;
create table tab_cnt (owner varchar2(32),tab_name varchar2(50),compare_date date,src_or_tag varchar2(30), table_cnt number);
alter table tab_cnt add primary key(owner,tab_name,src_or_tag);
2、创建存储过程
prod_link 前面已经创建成功，如下 sql 创建存储过程。
附 pro_tab_cnt v3.0 存储过程
create or replace procedure pro_tab_cnt(v_user in dba_tables.owner%type) is
-- created : 2022/06/10
-- purpose : the comparison on table count of the source and target schema
v_tb_cnt1 int;
v_tb_cnt2 int;
v_src varchar2(32);
v_tag varchar2(32);
v_sql varchar2(600);
cursor c_tb_name is
select owner, table_name
from dba_tables@prod_link
where owner = v_user
order by owner, table_name;
begin
v_src:='source';
v_tag:='target';
/* 目标库不存在的表 */
select count(*)
into v_tb_cnt1
from dba_tables@prod_link a
where not exists (select 1
from dba_tables b
where a.owner = b.owner
and a.table_name = b.table_name)
and a.owner = v_user;
/* 源库不存在的表 */
select count(*)
into v_tb_cnt2
from dba_tables a
where not exists (select 1
from dba_tables@prod_link b
where a.owner = b.owner
and a.table_name = b.table_name)
and a.owner = v_user;
/* 判断 source db 和 target db 表是否一样 */
if (v_tb_cnt1 = 0 and v_tb_cnt2 = 0) then
dbms_output.put_line('the tatles of both source side and target side is equal!');
for i in c_tb_name loop
v_sql := 'insert into tab_cnt
select /* parallel(dt,32)*/
'''||i.owner||''' as owner,
'''||i.table_name||''' as tab_name,
sysdate,
'''||v_tag||''' as src_or_tag,
count(1) from ' ||i.owner||'.'|| i.table_name|| ' dt union all select /* parallel(ds,32)*/
'''||i.owner||''' as owner,
'''||i.table_name||''' as tab_name,
sysdate,
'''||v_src||''' as src_or_tag,
count(1)
from ' || i.owner || '.'|| i.table_name || '@prod_link ds';
dbms_output.put_line(v_sql);
execute immediate v_sql;
commit;
end loop;
/* source db 存在 target db 不存在的表 */
elsif (v_tb_cnt1 <> 0) then
raise_application_error(-20001,
'the tables of both source side and target side isn''t equal, please execute the following sql to check: ' ||
chr(10) ||
'select owner,table_name from dba_tables@prod_link a where not exists (select 1 from dba_tables b where a.owner=b.owner and a.table_name=b.table_name) and a.owner = ');
/* target db 存在 source db 不存在的表 */
elsif (v_tb_cnt2 <> 0) then
raise_application_error(-20002,
'the tables of both source side and target side isn''t equal, please execute the following sql to check: ' ||
chr(10) ||
'select owner,table_name from dba_tables a where not exists (select 1 from dba_tables@prod_link b where a.owner=b.owner and a.table_name=b.table_name) and a.owner = ');
end if;
end;
/
3、执行存储过程，查看表结果比对
truncate table tab_cnt; --对比前清空上次对比结果
set serveroutput on
exec pro_tab_cnt('&user'); --对比某个用户的所有表的count
--查看 count 不同的表,正常情况下这个结果为空。
select owner,tab_name,table_cnt from tab_cnt where src_or_tag ='source'
minus
select owner,tab_name,table_cnt from tab_cnt where src_or_tag ='target';
no rows selected
如果出现类似如下结果说明两端数据不一致，如下显示源端的用户名、表名及行数。
select owner,tab_name,table_cnt from tab_cnt where src_or_tag ='source'
17:20:25 2 minus
17:20:25 3 select owner,tab_name,table_cnt from tab_cnt where src_or_tag ='target';
owner tab_name table_cnt
------------------------------ -------------------------------------------------- ----------
prod_sop t_auth_soft_ca_tx_his 321928
prod_sop t_sys_file 571055
--如下是目标端实际行数
17:20:36 sys@testogg> select count(*) from prod_sop.t_auth_soft_ca_tx_his;
count(*)
----------
321964
17:22:19 sys@testogg> select count(*) from prod_sop.t_sys_file;
count(*)
----------
571076
注意:1、system 用户创建存储过程可能会报错，存储过程无效
system@testogg> exec pro_tab_cnt('&user');
enter value for user: cc_sz
begin pro_tab_cnt('cc_sz'); end;
*
error at line 1:
ora-06550: line 1, column 7:
pls-00905: object system.pro_tab_cnt is invalid
ora-06550: line 1, column 7:
pl/sql: statement ignored
2、源端和目标端表个数不一样会报错。
sql> exec pro_tab_cnt('&user');
enter value for user: prod_cc
begin pro_tab_cnt('prod_cc'); end;
*
error at line 1:
ora-20002: the tables of both source side and target side isn't equal, please execute the following sql to check:
select owner,table_name from dba_tables a where not exists (select 1 from dba_tables@prod_link b where a.owner=b.owner and a.table_name=b.table_name) and a.owner =
ora-06512: at "sys.pro_tab_cnt", line 63
ora-06512: at line 1
select owner,table_name from dba_tables a where not exists (select 1 from dba_tables@prod_link b where a.owner=b.owner and a.table_name=b.table_name) and a.owner = 'prod_cc';
owner table_name
------------------------------ --------------------------------------------------------------------------------------------------------------------------------
prod_cc sys_export_table_01
解决办法：
经查看，目标端是一个用户级别的数据泵导出时创建的表，先将其删除，再尝试。
drop table prod_cc.sys_export_table_01 purge;
sql> exec pro_tab_cnt('&user');
enter value for user: ous
the tatles of both source side and target side is equal!
pl/sql procedure successfully completed.
elapsed: 00:00:32.48
方法三
使用 oracle 自带的包过程 dbms_comparison 比较
该包是 oracle 提供的包，可用于比较两个数据库中的数据库对象。此包还使您能够聚合数据库对象，以便它们在不同的数据库中保持一致。通常，此包用于在多个数据库共享一个数据库对象的环境中。当同一数据库对象的副本存在于多个数据库中时，该数据库对象是共享数据库对象。多个数据字典视图包含有关与包进行比较的信息。
dbms_compare 包进行数据验证的具体使用步骤如下。
1）创建比较任务。
2）执行比较任务。
3）手动修复不一致的数据。
此处以 scott 用户下的 emp 表为例，创建任务的命令如下：
begin
dbms_comparison.create_comparison(comparison_name => 'scott_emp_compare',
schema_name => 'scott',
object_name => 'emp',
dblink_name => 'prod_link');
end;
/
上述代码段中的参数说明如下。
·comparison_name：自定义对比名称。
·dblink_name：目标端与源端数据库连接。
带入创建的自定义名称 scott_emp_compare，执行比较任务，命令如下：
set serveroutput on
declare
consistent boolean;
compare_info dbms_comparison.comparison_type;
begin
consistent := dbms_comparison.compare(comparison_name => 'scott_emp_compare',
scan_info => compare_info,
perform_row_dif => true);
dbms_output.put_line('scan id: ' || compare_info.scan_id);
if consistent = true then
dbms_output.put_line('the table is equivalent');
else
dbms_output.put_line('tables are not equivalent… there is data divergence.');
dbms_output.put_line('check the dba_comparison and dba_comparison_scan_summary views for locate the differences for compare_id:' ||
compare_info.scan_id);
end if;
end;
/
--如果表数据一致则返回如下 equivalent
scan id: 1
the table is equivalent
--如果表数据不一致则返回如下 not equivalent 字样
scan id: 1
tables are not equivalent there is data divergence.
check the dba_comparison and dba_comparison_scan_summary views forlocate the differences for compare_id:2
not equivalent 程序包检测到数据差异，并记录到系统视图 dba_comparison、dba_comparison_scan_summary 和dba_comparison_row_dif 中。接下来查询 dba_comparison_row_dif，以确认不同步的数据。
select * from dba_comparison_row_dif;
然后，通过上面返回的 rowid 查询具体的数据，结果所示。
限制：对于包含要比较的数据库对象的数据库，数据库字符集必须相同。
dbms_comparison 包无法比较以下数据类型的列中的数据：
long、long raw、rowid、urowid、clob、nclob、blob、bfile
用户定义的类型（包括 object types, refs, varrays, and nested tables）
oracle 提供的类型（包括任何类型、xml 类型、空间类型和媒体类型）
不能比较 lob 大字段，我这环境刚好有 clob，而且还只能单表比较，故很少使用这个方法比较，更多详细信息可查看官方文档：
https://docs.oracle.com/en/database/oracle/oracle-database/19/arpls/dbms_comparison.html#guid-5197c17c-7197-4ae2-844e-8751d75e5879
方法四
使用 hash 函数进行数据对比
1、源端目标端两边分别创建存放 hash 数据的表
drop table system.get_has_value;
create table system.get_has_value (dbname varchar2(20),owner varchar2(30),table_name varchar2(100),value varchar2(100),error varchar2(2000));
2、创建需要验证的表
drop sequence system.sequence_checkout_table;
create sequence system.sequence_checkout_table start with 1 increment by 1 order cycle maxvalue 10 nocache;
drop table system.checkout_table;
create table system.checkout_table as select sys_context('userenv', 'instance_name') dbnme,owner,table_name, system.sequence_checkout_table.nextval groupid
from dba_tables where owner in ('prod_cc','prod_op','prod_cb','cuwb','ous','cc_gmp');
结果显示：
select owner, groupid, count (*)
from system.checkout_table group by owner, groupid,dbnme order by owner,groupid;
owner groupid count(*)
------------------------------ ---------- ----------
cuwb 1 1
cuwb 6 1
ous 1 28
ous 2 29
prod_cbmc 9 115
prod_cbmc 10 100
3、创建 hash 函数
grant select on sys.dba_tab_columns to system;
drop procedure system.get_hv_of_data;
create or replace procedure system.get_hv_of_data(
avc_owner varchar2,avc_table varchar2)
as
lvc_sql_text varchar2 (30000);
ln_hash_value number;
lvc_error varchar2 (100);
begin
select 'select /* parallel(a,25)*/sum(dbms_utility.get_hash_value('|| column_name_path|| ',0,power(2,30))) from '|| owner|| '.'|| table_name || ' a '
into lvc_sql_text from (select owner,table_name,column_name_path,row_number()over (partition by table_name order by table_name,curr_level desc)
column_name_path_rank
from (select owner,table_name,column_name,rank,level as curr_level,
ltrim (sys_connect_by_path (column_name, '||''|''||'),'||''|''||')
column_name_path from(select owner,table_name,'"' || column_name || '"' column_name,
row_number ()
over (partition by table_name
order by table_name, column_name)
rank
from dba_tab_columns
where owner=upper(avc_owner)
and table_name = upper (avc_table)
and data_type in ('timestamp(3)','interval day(3) to second(0)','timestamp(6)','nvarchar2','char',
'binary_double','nchar','date','raw','timestamp(6)','varchar2','number')
order by table_name, column_name)
connect by table_name = prior table_name
and rank -1 = prior rank))
where column_name_path_rank = 1;
execute immediate lvc_sql_text into ln_hash_value;
lvc_sql_text :='insert into system.get_has_value(owner,table_name,value) values(:x1,:x2,:x3)';
execute immediate lvc_sql_text using avc_owner, avc_table, ln_hash_value;
commit;
dbms_output.put_line (avc_owner || '.' || avc_table || ' ' || ln_hash_value);
exception
when no_data_found
then
lvc_error := 'no data found';
lvc_sql_text :='insert into system.get_has_value(owner,table_name,error) values(:x1,:x2,:x3)';
execute immediate lvc_sql_text using avc_owner, avc_table, lvc_error;
commit;
when others
then
lvc_sql_text :='insert into system.get_has_value(owner,table_name,value) values(:x1,:x2,:x3)';
execute immediate lvc_sql_text using avc_owner, avc_table, sqlerrm;
commit;
end;
/
vim check_source.sh
date
sqlplus system/oracle< 0)
)
order by table_name;
spool off
set serveroutput on
@source_check_$1.sql
exit;
eof
date
chmod x check_source.sh
nohup ./check_source.sh prod_cc >./source_cd_1.log 2>&1 &
nohup ./check_source.sh prod_cb >./source_cd_1.log 2>&1 &
nohup ./check_source.sh prod_op >./source_cd_1.log 2>&1 &
nohup ./check_source.sh ous >./source_cd_1.log 2>&1 &
nohup ./check_source.sh cuwb >./source_cd_1.log 2>&1 &
4、查看 hash 值
col table_name for a30
col value for a30
select owner,table_name,value,error from system.get_has_value;
select * from system.get_has_value where value is not null and rownum<=10;
select * from system.get_has_value where error is not null;
结果：运行 hash 计算函数脚本，在linux环境对所有表进行 hash 计算耗时比较久，空表没有计算出 hash 值，异常的小写表名没有计算出 hash 值。
sql> select count(*) from tab1;
count(*)
----------
0
方法五
sql developer 工具能够比对两个库的信息，比较费时，这里就不演示了。
先填写两个库的连接信息
选择要比对的用户及对象类型，例如表
然后点击完成，等待比较结果，也可后台比较。
全文完，希望可以帮到正在阅读的你，如果觉得有帮助，可以分享给你身边的朋友，同事，你关心谁就分享给谁，一起学习共同进步~~~
❤️ 欢迎关注我的公众号【jiekexu dba之路】，一起学习新知识！
————————————————————————————
公众号：jiekexu dba之路
csdn ：https://blog.csdn.net/jiekexu
墨天轮：https://www.modb.pro/u/4347
腾讯云：https://cloud.tencent.com/developer/user/5645107
————————————————————————————
最后修改时间：2022-09-08 14:10:55
「喜欢这篇文章，您的关注和赞赏是给作者最好的鼓励」
关注作者
【米乐app官网下载的版权声明】本文为墨天轮用户原创内容，转载时必须标注文章的来源（墨天轮），文章链接，文章作者等基本信息，否则作者和墨天轮有权追究责任。如果您发现墨天轮中有涉嫌抄袭或者侵权的内容，欢迎发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。