--exprot date from oracle
exp tbcy/123456@TestB1 file=OM_chetian.dmp log=20.log tables=chey indexes=n GRANTS=n CONSTRAINTS=n TRIGGERS=n--import date to oracle(ignore:已经存在的表忽略)imp com/123456@pdb1 file=OM_chetian.dmp log=20.log tables=chey indexes=n GRANTS=n CONSTRAINTS=n TRIGGERS=n ignore=y------------------------------------------------------------------------------------------------------------------删除表:drop lc_chetest purge;--正真删除表并发创建索引: create index inx_che_oid on loc_chetest (oid) tablespace d_log_01 nologging parallel 16; 关闭并发:alter index inx_che_oid noparallel;并发创建临时表: create table inf_che_all_his_1010 tablespace d_space nologging parallel 16 as select b.oid,b.name, b.addr, b.phone,'0' status, sysdate his_date,0 deal_flag, 0 limitflag from sducy.inf_che_all b where exists ( select 1 from sducy.user_account c where c.acctid=b.acctid);关闭并发: alter table inf_che_all_his_1010 noparallel;说明:
新老库表数据割接,把老库的数据割接到新库中。 1.表字段相同:直接exp老表数据,然后imp老表数据到新库中(或者c++直接跨库搬迁数据) 2.表字段不同: 2.1).新核对新老表字段映射关系,数据映射关系表格。 2.2).老库需要多张表映射一张新表数据的,根据表关系,查询多个表关联查询,组合成一张临时新表(添加处理数据状态:flag) 2.3).exp临时新表,然后再imp老表数据到新库 2.4).循环编译新库临时表待处理数据,获取正式表的字段信息插入到正式表中,更临时表处理状态(0:待处理;1:处理成功;5:数据已经存在重复;9:处理失败)------------------------------------------------------------------------------------------------------------------样例:1支付关系表 2.已经割接数据表 3.账号表 4.用户表要求:1.割接支付关系表到新库中
2.前期有小批量割接数据 3.确保支付关系中的账户是有效的。 4.确认账号是有用户在使用的。(即:有人使用的有效账号,这样的支付关系才需要割接)other说明:1)由于多表关联,且都是大表,即使开并发也处理不动,将多表关联拆成多次关联,创建临时表,提高效率。
步奏:1.捞取支付关系表,先过滤已经割接数据 create table 临时表1 tablespace d_space nologging parallel 16 as select b.oid,b.name, b.addr, b.phone,'0' status, sysdate his_date,0 deal_flag, 0 limitflag from 支付关系表 b where not exists ( select 1 from 已经割接表 c where c.payoid=b.payid); --关闭临时表1并发2.捞取临时表1,过滤账号id不存在的数据,创建临时表2 create table 临时表2 tablespace d_space nologging parallel 16 as select b.* from 临时表1 b where exists ( select 1 from 账号表 c where c.acctid=b.acctid); --关闭临时表2并发3.捞取临时表2,过滤账号不被用户使用的数据,创建临时表3 create table 临时表1 tablespace d_space nologging parallel 16 as select b.* from 临时表2 b where exists ( select 1 from 用户表 c where c.acctid=b.acctid and active = 0); --关闭临时表2并发4.为临时表3创建处理状态标识. alter table 创建临时表3 add flag varchar2(1);--也可以在创建临时表是,直接添加flag5.将临时表3导出,在导入到新库中6.写一个块程序,捞取临时表,入库到线网业务表。
declare n_commitcnt := 0;--5000 begin n_commitcnt :=0; for cur in (select rowid,t.* from 临时表 where flag =0 )--or flag is null loop begin --参数校验处理,如时间校验null,数据唯一性校验等 --当数据重复时,update 临时表 falg=5 where rowid = cur.rowid; ..... insert 线网表 ; 更新临时表处理标识 update 临时表 falg=1 where rowid = cur.rowid; if n_commit >= 500 then n_commit := 0; end if; exception when others then update 临时表 falg=9 where rowid = cur.rowid; end; end loop; commit;end;/说明:1)临时表数据量大,无索引,更新时使用rowid提供运行效率。7.割接数据处理结果跟踪 select /*+ parallel 10*/flag,count(*) from 临时表 group by flag;8.当线网表数据无唯一性约束时,可能存在相同数据的重复数据,需要进行去重处理(分两步)8.1):捞取重复数据: create table mg_重复数据 nologging tablespace d_user parallel 16 as select users_id ,0 flag from user t where rowid >(select mix(rowid) from user a where a.user_id = t.user_id and t.regon = t.regon);8.2):删除重复数据注释:由于数据量较大,采取开通道0-19 ,并行处理提高效率。declare n_commitcnt := 0;--5000 v_count number(6); v_userid varchar(32); begin n_commitcnt :=0; v_count :=0; v_userid :=''; for cur in (select rowid,t.* from mg_重复数据 where flag =0 and mod(user_id,20) = 0)--开通道0-19 ,并行处理提高效率。 loop begin --数据唯一性校验等 select count(*) into v_count from user where user_id = cur.user_id and inst_id = '88888888'; -- if v_count>0 then delete user where user_id = cur.user_id and inst_id = '88888888'; else delete user t where rowid <>(select max(rowid) from user a where a.user_id = cur.user_id and t.regon = cur.regon); end if; insert 线网表 ; 更新临时表处理标识 update mg_重复数据 falg=1 where rowid = cur.rowid; if n_commit >= 500 then n_commit := 0; end if; exception when others then update mg_重复数据 falg=9 where rowid = cur.rowid; end; end loop; commit;end;/8.3检查结果 select /*+ parallel 10*/flag,count(*) from mg_重复数据 group by flag;其他: 块逻辑卡死问题查询,根据执行计划,思考优化方法,优化性能sql --登陆sql用户,查询执行sql,查看一直卡死的sql_id select a.sql_id,a.SQL_TEXT,t.EVENT,t.* from v$session t, v$sql a where t.sql_id = a.sql_id and t.OSUSER='cn_xiaocai'; --根据sqlID——查询执行计划 select * from table(dbms_xplan.display_cursor('fkduybquzyq',0,'typical'));