摘要:之前项目中用的触发器来实现数据解析,但是最近客户反应,会报错,所以我们从新设计了一下,通过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
)CREATE OR REPLACE PROCEDURE MIP.JOB_PRO_TEMP
ASTEMP_ID   NUMBER;
BEGINSELECT   NVL (MAX (ID), 0) INTO TEMP_ID FROM MBINMSGS_TEMP;INSERT INTO MBINMSGS_TEMPSELECT   *FROM   MBINMSGSWHERE   MBINMSGS.ID > TEMP_ID;--insert into MBINMSGS_TEST select * from MBINMSGS;COMMIT;
EXCEPTIONWHEN OTHERSTHENDBMS_OUTPUT.PUT_LINE ('Exception happened,data was rollback');ROLLBACK;
END;
/
var job_num number;
begindbms_job.submit(:job_num,'JOB_PRO_TEMP;',SYSDATE,'sysdate+1/24/60');
end;
commit;SELECT * FROM USER_JOBS;检查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;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