天天看点

对分区表导入导出的水平,垂直切分

在工作中有时候碰到一些分区表,业务数据量很大,可能几百G,上T的规模,而且做数据的导入导出的时候,会感觉到exp/expdp的时候生成的dump文件太大了,做导入的时候也是很重的负担。比如500G的dump,你在使用imp做导入的时候,别无选择,只能看着日志里partition里的数据一个一个被导入。impdp可能稍微好点,还能指定个并行,但是问题又来了,一个500G的dump。impdp是在最后才做commit。对于数据空间和Undo,cpu资源都是挑战。

分区表有一个地方和普通表不同,对于每个分区可以单独做dml,不会影响其他的分区,当然了,你得指定分区名。

基于以上的情况,我写了一个脚本来完成exp/expdp,把一个很大的分区表按照分区生成对应的dump文件,如果分区有100个分区,那么就会有100个dump文件。在数据导入的时候,也可以分区导入,以分区的形式单独做导入,相当于把一个大的事物分成很多小的部分。可以看做是垂直切分。

比如说表big_table有100个分区,生成了100个dump,导出的时候一般比较快,导入的时候问题就来了。如果开启100个单独的进程去导入,系统负载不一定能接受,Undo的大小肯定不能保证这么多的大事务,很可能会有Undo空间的问题。

这个时候可以考虑开启几个并行的进程来做数据导入,比如开启5个进程来做数据导入,每个进程包含20个分区,这样会对系统的负载减轻不少,同时也能提高速度。可以看做是水平切分。

parallel_no=$5

target_schema=$4

for i in {1..${parallel_no}}

do

sqlplus -s $1

set linesize 150

set pages 0

set feedback off

set trimspool  on

spool $2_partition_parallel_$i.par_temp

select 'tables=' from dual;

spool off;

spool $2_partition_parallel_$i.par_temp append

 select table_name||':'||partition_name||',' from (

 select rownum,mod(rownum,${parallel_no})+1 parallel_no,table_name,partition_name,num_rows from user_tab_partitions where table_name=upper('$2') order by num_rows desc  nulls last

 )

where parallel_no=$i;

spool $2_partition_parallel_$i.par_temp2

spool $2_partition_parallel_$i.par_temp2 append

 select 'PRDAPPO'||'.'||table_name||':'||partition_name||',' from (

 where parallel_no=$i;

EOF

sed -e '/^$/d' -e '$s/.$//'  $2_partition_parallel_$i.par_temp>$2_partition_parallel_$i.par_imp

rm $2_partition_parallel_$i.par_temp

sed -e '/^$/d' -e '$s/.$//'  $2_partition_parallel_$i.par_temp2>$2_partition_parallel_$i.par_impdp

rm $2_partition_parallel_$i.par_temp2

echo exp $1 file=par${i}_$2.dmp log=par${i}_$2_exp.log  statistics=none grants=n constraints=n indexes=n  parfile=$2_partition_parallel_$i.par_imp buffer=9102000  "&" >> $2_partition_parallel_export.sh

echo imp $1 file=par${i}_$2.dmp log=par${i}_$2_imp.log  statistics=none grants=n constraints=n indexes=n  parfile=$2_partition_parallel_$i.par_imp buffer=91020000 ignore=Y commit=y "&" >> $2_partition_parallel_import.sh

echo expdp $1 directory=memo_dir dumpfile=par${i}_$2.dmp logfile=par${i}_$2_expdp.log parfile=$2_partition_parallel_$i.par_imp  exclude=statistics,constraint,ref_constraint,index,comment,grant  "  &" >> $2_partition_parallel_expdp.sh &

echo "nohup " impdp $1 directory=memo_dir dumpfile=par${i}_$2.dmp parallel=2 include=table_data logfile=par${i}_$2_impdp.log parfile=$2_partition_parallel_$i.par_impdp TABLE_EXISTS_ACTION=append REMAP_SCHEMA=prdappo:MIG_TEST DATA_OPTIONS=SKIP_CONSTRAINT_ERRORS   "  &" >> $2_partition_parallel_impdp.sh &

生成的parfile文件和parallel导入导出脚本如下:

-rw-r--r-- 1 testuser1 dba  1231 Jun 19 14:16 big_table_partition_parallel_1.par_imp

-rw-r--r-- 1 testuser1 dba  1687 Jun 19 14:16 big_table_partition_parallel_1.par_impdp

-rw-r--r-- 1 testuser1 dba  1253 Jun 19 14:16 big_table_partition_parallel_2.par_imp

-rw-r--r-- 1 testuser1 dba  1717 Jun 19 14:16 big_table_partition_parallel_2.par_impdp

-rw-r--r-- 1 testuser1 dba  1255 Jun 19 14:16 big_table_partition_parallel_3.par_imp

-rw-r--r-- 1 testuser1 dba  1719 Jun 19 14:16 big_table_partition_parallel_3.par_impdp

-rw-r--r-- 1 testuser1 dba  1255 Jun 19 14:16 big_table_partition_parallel_4.par_imp

-rw-r--r-- 1 testuser1 dba  1719 Jun 19 14:16 big_table_partition_parallel_4.par_impdp

-rw-r--r-- 1 testuser1 dba  1273 Jun 19 14:16 big_table_partition_parallel_5.par_imp

-rw-r--r-- 1 testuser1 dba  1737 Jun 19 14:16 big_table_partition_parallel_5.par_impdp

-rw-r--r-- 1 testuser1 dba  2150 Jun 19 14:16 big_table_partition_parallel_expdp.sh

-rw-r--r-- 1 testuser1 dba   905 Jun 19 14:16 big_table_partition_parallel_export.sh

-rw-r--r-- 1 testuser1 dba  1410 Jun 19 14:16 big_table_partition_parallel_impdp.sh

-rw-r--r-- 1 testuser1 dba  1010 Jun 19 15:08 big_table_partition_parallel_import.sh

-rw-r--r-- 1 testuser1 dba  5609 Jun 19 10:52 par1_big_table_expdp.log

-rw-r--r-- 1 testuser1 dba  5120 Jun 19 14:36 par1_big_table_exp.log

-rw-r--r-- 1 testuser1 dba     0 Jun 19 15:10 par1_big_table_imp.log

-rw-r--r-- 1 testuser1 dba  5688 Jun 19 10:52 par2_big_table_expdp.log

-rw-r--r-- 1 testuser1 dba  5200 Jun 19 14:37 par2_big_table_exp.log

-rw-r--r-- 1 testuser1 dba     0 Jun 19 15:10 par2_big_table_imp.log

-rw-r--r-- 1 testuser1 dba  5688 Jun 19 10:53 par3_big_table_expdp.log

-rw-r--r-- 1 testuser1 dba  5200 Jun 19 14:46 par3_big_table_exp.log

-rw-r--r-- 1 testuser1 dba     0 Jun 19 15:10 par3_big_table_imp.log

-rw-r--r-- 1 testuser1 dba  5688 Jun 19 10:53 par4_big_table_expdp.log

-rw-r--r-- 1 testuser1 dba  5200 Jun 19 14:38 par4_big_table_exp.log

-rw-r--r-- 1 testuser1 dba     0 Jun 19 15:10 par4_big_table_imp.log

-rw-r--r-- 1 testuser1 dba  5698 Jun 19 10:52 par5_big_table_expdp.log

-rw-r--r-- 1 testuser1 dba  5200 Jun 19 14:37 par5_big_table_exp.log

-rw-r--r-- 1 testuser1 dba     0 Jun 19 15:10 par5_big_table_imp.log