摘要:之前项目中用的触发器来实现数据解析,但是最近客户反应,会报错,所以我们从新设计了一下,通过oracle里面的job来解决这一问题,这样就不会对原来的数据表做操作,只对临时表操作,就不会对客户那边的上级服务器产生影响了,详细请看下面: 一:首先
摘要:之前项目中用的触发器来实现数据解析,但是最近客户反应,会报错,所以我们从新设计了一下,通过oracle里面的job来解决这一问题,这样就不会对原来的数据表做操作,只对临时表操作,就不会对客户那边的上级服务器产生影响了,详细请看下面:
一:首先建个主表:mbinmsgs(这里的用户是mip)
create table mip.mbinmsgs( id number(30) not null, mbinmsgs_clob_msg clob, mbinmsgs_date_received date, mbinmsgs_date_processed date, mbinmsgs_subsystem_name varchar2(100 byte), mbinmsgs_subsystem_date_sent date, servicename varchar2(30 byte) not null)
二:其次建个临时表用来存储主表过来的数据:mbinmsgs_temp
create table mip.mbinmsgs_temp( id number(30) not null, mbinmsgs_clob_msg clob, mbinmsgs_date_received date, mbinmsgs_date_processed date, mbinmsgs_subsystem_name varchar2(100 byte), mbinmsgs_subsystem_date_sent date, servicename varchar2(30 byte) not null)
三:建立同步数据的存储过程:job_pro_tempcreate or replace procedure mip.job_pro_tempas temp_id number;begin select nvl (max (id), 0) into temp_id from mbinmsgs_temp; insert into mbinmsgs_temp select * from mbinmsgs where mbinmsgs.id > temp_id; --insert into mbinmsgs_test select * from mbinmsgs; commit;exception when others then dbms_output.put_line ('exception happened,data was rollback'); rollback;end;/
四:建立定时执行存储过程的job:var job_num number;begin dbms_job.submit(:job_num,'job_pro_temp;',sysdate,'sysdate+1/24/60');end;commit;
五:查看新建的job是否正确运行:select * from user_jobs;
六:可能有的人会说我建了job但是不能运行,那说明你的job没有运行,我在这个过程中就遇到了这个的问题,最后经过查找,解决了,办法如下:检查oracle的job运行环境:如果为0表示不运行job,oracle一般默认安装完为10,但是我安装oracle以后就不知道为什么是0。 查看进程数(这里是用system管理员账号登录) show parameter job_queue_processes; 修改进程数(如果你的是0,才需要按照以下语句修改): 我这里改为10模拟以下这个操作; 在pl/sql的command窗口中输入以下语句: alter system set job_queue_processes=10 scope=both; 修改完以后我们查看一下,如果为10那就说明好了,然后你把刚才建的job删除了,在重新建立一个job: show parameter job_queue_processes;
七:删除job的方法:exec dbms_job.remove(81);
说明:这里的数字81是对应dba_jobs表中当前要删除的job记录所在行的job字段的值;
更加详细的关于oracle的job请看:http://www.cnblogs.com/java-pan/archive/2012/09/16/oracle_job.html