1:创建临时表,并按一定的数据create table ZXX.TEST_TIME( T_TIME VARCHAR2(50), T_STATUS VARCHAR2(1))插入数据如:insert into ZXX.TEST_TIME values('2013-08-08 00:00:00','0');T_STATUS 初始都为0
2:创建存储过程create or replace procedure pro_import_clmxxas v_now_time number; --记录当前时间 type rec is table of clmxx_3%rowtype;--can not sa.clmxx_3%rowtype; --定义数据类型 recs rec; --申明数组 cursor c_exec_time is select * from zxx.test_time where t_status='0' and rownum < 2;--申明显示游标 type c_clmxx is ref cursor; --申明动态游标 l_c_clmxx c_clmxx;begin v_now_time :=to_number(to_char(sysdate,'hh24')); ----记录当前时间的小时来判断是晚上还是白天 if (v_now_time > 17) or (v_now_time < 7) then for r_exec_time in c_exec_time loop update zxx.test_time set t_status='2' where t_time=r_exec_time.t_time; --锁定正在导入数据,防止后启动存储再次执行 commit; open l_c_clmxx for select * from sa.clmxx_3 where jgsj >= to_date(r_exec_time.t_time,'yyyy-mm-dd hh24:mi:ss') and jgsj < to_date(r_exec_time.t_time,'yyyy-mm-dd hh24:mi:ss')+1; --打开动态游标 while (true) loop fetch l_c_clmxx bulk collect into recs limit 1000;--每次存放1000个记录到数组中 forall i in 1 .. recs.count insert into sa.clmxx values recs(i);--插入数组中的数据 commit; exit when l_c_clmxx%notfound; end loop; close l_c_clmxx; update zxx.test_time set t_status='1' where t_time=r_exec_time.t_time;--更新status状态 commit; end loop; end if;end;
3:创建jobdeclarejob number;begin --每30分钟执行一次 sys.dbms_job.submit(job,'pro_import_clmxx;',sysdate,'sysdate+30/1440');end;job详细信息,参考我的经验:http://jingyan.baidu.com/article/a3761b2bbbdd2f1577f9aa75.html
4:验证以上步骤创建完成之后,一定要验证是否导入数据
- 1
一定时间段内并发导入数据(oracle动态游标使用)
- 2
颈椎术后康复训练有哪些
- 3
缓解女性痛经的方法是什么
- 4
治疗胆结石必须手术吗 ,是有什么原因形成的?
- 5
尿道炎最佳治疗方法是什么
- 6
反复被霉菌性阴道炎困扰,怎么治?
- 7
治疗糜烂型脚气的注意事项
- 8
得了阴道炎怎么办?平时要注意什么?
- 9
体质的好坏怎样区别
- 10
大蒜锈病的发病条件和发病途径是什么?
- 11
不会泰语怎么去泰国旅游
- 12
导入仪对皮肤有什么损害?
- 13
O型腿怎么矫正
- 14
过敏性紫癜肾炎治疗
- 15
去泰国怎么玩
- 16
逆战没有声音怎么办
- 17
经营者以什么手段侵犯商业秘密
- 18
【金融学院】,有了抵押物也不一定保险(3)
- 19
商业秘密是否被员工侵犯怎样认定?
- 20
汉之殇怒放刘备攻略
- 21
《攻城掠地》如何过刘备副本
