如何解决Oracle Rac数据不同步问题
发布网友
发布时间：2022-04-29 22:07
共2个回答
懂视网
时间：2022-04-30 02:28
插入数据的存储过程语句如下：
begin
declare v_i int;v_procname varchar(50);v_employeeinfotbl varchar(50);strsql varchar(4000);
begin
v_i := 0;
while v_i < 10 loop
v_procname := ‘pr_insertdata‘||substr(to_char(v_i),1,1);
v_employeeinfotbl := ‘tb_employeeinfo‘||substr(to_char(v_i),1,1);
v_i := v_i + 1;
strsql := ‘create or replace procedure ‘||v_procname||‘(
v_employeeno in varchar2,
v_employeeage in int,
v_retcode out int -- 0_success, 1,2_fail
)
as
v_employeecnt int;
begin
v_retcode := 0;
select count(*) into v_employeecnt from ‘||v_employeeinfotbl||‘ where employeeno = v_employeeno;
if v_employeecnt > 0 then -- the employeeno is already in DB
begin
v_retcode := 1;
return;
end;
else -- the employeeno is not in DB
begin
insert into ‘||v_employeeinfotbl||‘(employeeno, employeeage) values(v_employeeno, v_employeeage);
end;
end if;
exception when others then
begin
rollback;
v_retcode := 2;
return;
end;
end;‘;
execute immediate strsql;
end loop;
end;
end;
/
我们在PL/SQL Developer软件上执行了以上SQL语句(注意：先建表，后建存储过程)之后，利用以下SQL语句向tb_employeeinfo6表中插入数据：
set serveroutput on
declare v_retcode int;
begin
pr_insertdata6(‘123456‘, 25, v_retcode);
dbms_output.put_line( v_retcode);
end;
/执行“select * from tb_employeeinfo6;”语句查询数据，结果如下：
SQL> select * from tb_employeeinfo6;
EMPLOYEENO EMPLOYEEAGE
---------------------------
123456 25可见，数据插入成功。
接着，我们利用以下命令行从Linux系统上登录到ORACLE数据库中(注意：username是指数据库用户名，password是指数据库密码，databaseservername是指数据库服务名)：
sqlplus /nolog
connect username/password@databaseservername然后执行如下查询语句：
select * from tb_employeeinfo6;发现返回的值为空，即该数据表中没有数据。
真是奇怪了，为什么同样的查询语句，两边的执行结果不一致呢？
我们回过头来详细阅读了建表和建存储过程的代码，没看出有明显的问题。我们将该问题告诉了一位工作多年的老员工，请他来帮我们分析问题的原因所在。他详细看了我们的SQL语句之后，便指出存储过程的代码有点问题，在向表中插入数据之后忘记提交了。也就是说，存储过程中的“insert…”语句之后应该加上“commit;”。
难道就是这个“commit;”语句惹的祸吗？
三、问题原因
我们将存储过程的代码修改为如下：
begin
declare v_i int;v_procname varchar(50);v_employeeinfotbl varchar(50);strsql varchar(4000);
begin
v_i := 0;
while v_i < 10 loop
v_procname := ‘pr_insertdata‘||substr(to_char(v_i),1,1);
v_employeeinfotbl := ‘tb_employeeinfo‘||substr(to_char(v_i),1,1);
v_i := v_i + 1;
strsql := ‘create or replace procedure ‘||v_procname||‘(
v_employeeno in varchar2,
v_employeeage in int,
v_retcode out int -- 0_success, 1,2_fail
)
as
v_employeecnt int;
begin
v_retcode := 0;
select count(*) into v_employeecnt from ‘||v_employeeinfotbl||‘ where employeeno = v_employeeno;
if v_employeecnt > 0 then -- the employeeno is already in DB
begin
v_retcode := 1;
return;
end;
else -- the employeeno is not in DB
begin
insert into ‘||v_employeeinfotbl||‘(employeeno, employeeage) values(v_employeeno, v_employeeage);
commit;
end;
end if;
exception when others then
begin
rollback;
v_retcode := 2;
return;
end;
end;‘;
execute immediate strsql;
end loop;
end;
end;
/接着，我们在PL/SQL Developer软件上执行了以上SQL语句，并利用以下SQL语句向tb_employeeinfo9表中插入数据：
set serveroutput on
declare v_retcode int;
begin
pr_insertdata9(‘123469‘, 25, v_retcode);
dbms_output.put_line( v_retcode);
end;
/同样在该软件上执行“select * from tb_ employeeinfo9;”语句查询数据，结果如下：
SQL> select * from tb_employeeinfo9;
EMPLOYEENO EMPLOYEEAGE
--------------------------
123469 25然后在Linux系统上执行“select * from tb_employeeinfo9;”语句，结果如下：
SQL> select * from tb_employeeinfo9;
EMPLOYEENO EMPLOYEEAGE
------------------------
123469 25可见，数据被成功插入到员工信息表中。
四、总结
对于本次因为“commit;”而引发的问题，我们的总结如下：
第一，在动手编写代码之前，一定要对语法规则了然于心，不要让一个小小的问题引起整个软件功能的异常。
第二，在软件开发中，经验十分的重要。一个新人花几个小时不能解决的问题，一个老手可能几分钟就搞定了。因此，在遇到自己不能解决的问题的时候，我们一定要勤于开口，多多向有经验的老员工请教。
本人微信公众号：zhouzxi，请扫描以下二维码：
一起ORACLE数据库中数据查询结果不一致问题的排查过程
标签：
热心网友
时间：2022-04-29 23:36
一台web Server,一个是纯JAVA APP 程序
数据库两台做成RAC的形式. web Server与APP 程序都通过oci(rac)的方式连接数据库.
出了这样的怪问题,webServer更新或是插图入一条数据,后面紧跟着的在APP中就查询不到,等到用工具查询就没有问题.
初步怀疑
1. RAC方式下面的数据库两个instance的同步没做好?
查询相关资料发现在与MAX_COMMIT_PROPAGATION_DELAY有关.
最大提交传播时延(MAX_COMMIT_PROPAGATION_DELAY,简称MCPD),在ORACLE RAC(或OPS)环境中才使用,表示在RAC系统中,一个instance系统提交产生的最新系统改变码(SCN),能够以多快的速度反应到另一个instance中.
举例说明,RAC系统,有A,B两个实例(instance),A、B本地系统改变码为SCN1,A更新数据DATA1提交, LGWR操作完成后,A本地系统改变码为SCN2,经过不大于MAX_COMMIT_PROPAGATION_DELAY时间后,B系统本地改变码才变为SCN2.
Global Cache ServICes 将刷新RAC中的SCN.不管SCN是否及时刷新,后续的数据查询都不会因此产生数据库错误.但,在此时间内,有可能查询结果不是最新数据,产生读一致性(read consistency)问题.
RAC环境中的所有实例,此参数值必须相同.
ORACLE8i后,建议常用的两个值是0和700(默认),其他数值皆不建议.其实,这两个数值就代表了RAC环境中,两种SCN 产生机制:
Lamport Scheme和 Broadcast on Commit scheme.
设置为默认值700,表示采用Lamport Scheme,SCN改变不会完全同步,同步将在 7秒钟内完成,而不是总等待7秒钟后才完成.如果系统比较空闲,同步可能在0.5秒(甚至更短时间)内完成;不管系统多繁忙,同步时间也不可能超过7秒.不难理解,采用此模式,整个RAC系统的运行效率较高.
设置为0,表示采用Broadcast on Commit scheme,SCN改变完全同步.每当commit时(即LGWR 写redo log时):
- LGWR发送消息更新全局SCN(global SCN),
- LGWR 发送消息给每个活动的实例更新其本地SCN(LOCal SCN).
有资料说,只要MCPD < 700,系统将采用Broadcast on Commit scheme.
Lamport Scheme能够适应绝大部分应用的要求,只有个别实时性特别高的业务,才需要Broadcast on Commit scheme.通过分析,不难理解,Broadcast on Commit scheme将需要更多的系统资源.
