A Cooly Weblog
   ::  ::  ::  ::  :: 管理

【原创】BCP分页

Posted on 2006-07-17 17:59 acooly 阅读(198) 评论(0)  编辑  收藏 所属分类: Linux/Unix

   最近重庆移动BOSS1.0系统升级为BOSS1.5，原有与BOSS1.0相关的很多外围系统都需要做数据迁移，我们公司负责的渠道系统CMSS也需要做大量的数据迁移。在过程中，遇到一个问题。具体情况是：CMSS系统使用的是Sybase ASA 12.5数据库,BOSS1.5使用的是ORACLE，现在从sybase到oracle做数据迁移，有很多细节的问题会发生，比如日期格式问题等等，这些都好解决，最大的问题是BOSS1.5系统的迁移接口只能接受10万条记录的数据文件，但我们很多需要迁移的业务表都在几千万以上，没办法，为了解决这个问题，我只有使用向WEB系统查询时用的“分页”方式来处理我们的大业务表数据的导出，也就是BCP分页导入数据了。
   我是在Solaris上做了个shell程序来完成的。主要实现方式是：
   1.通过sybase的sp_spaceused系统存储过程得到大概的整表记录数，然后计算每页的起始记录位置。
   2.通过每页的起始记录位置，使用BCP工具导出每页数据到每个文件中。

代码如下：

1.按BOSS要求的命名方式生成文件名称(genfilename.sh)

 1 #  bash
  2 # author : zpu
  3 # generate file name
 4
 5
 6 function genfilename()
  7 {
  8 if  [  " $# "   !=   " 3 "  ] 
  9 then
 10   echo Usage : genfilename tablename dirname filesequ type{ 0 : datafile; 1 : validatefile}
 11    return   1
12 fi 
 13
14 TABLENAME = $ 1
15 DIRNAME = $ 2
16 PREFIX = ${ 1 } @_ ${ 2 }_
 17 if  [  " $4 "   !=   " 0 "  ]
 18 then
 19   PERFIX = ${ 1 }_${ 2 }_
 20 fi
 21 # echo $PREFIX
22 FID = $ 3
23 FID_LEN = `expr ${ # 3}`
24 POS = 00000
25 POS_LEN = 5  
 26
27 POS = `expr ${ POS : 0 : ( 5 - $FID_LEN )}` $FID
28 # echo $POS
29 echo ${PREFIX}${ POS }
 30 return   0
31 }
 32 genfilename $ 1  $ 2  $ 3



2.计算目标业务表的总记录数(gettbcount.sh)

 1 #  bash
  2 # author : zpu
  3 # to do:calu table counts 
  4
 5 # env
 6 SYBASE =/ app / sybase /
 7 SYBASE_ASE = ASE - 12_5
  8 SYBASE_OCS = OCS - 12_5 
  9
10 APP_HOME =/ app / sybase / cmss2boss
 11 DATA_TEMP =/ app / sybase / cmss2boss / temp
 12 DBRESULT = $APP_HOME / dbresult . txt
 13 .   $SYBASE / SYBASE . sh
 14 TABLE = $ 1  
 15
16 if  [  " $# "   !=   " 1 "  ]
 17 then
 18   echo Usage : getdbcount . sh tablename
 19    exit
20 fi 
 21
22 if  [  - f  " $DBRESULT "  ]
 23 then
 24   rm  - f  $DBRESULT
25 fi 
 26
27 isql  - SINFO1  - Ucmssuser  - Pinfocmss_  << EOF   >   $DBRESULT
28 sp_spaceused  $TABLE
29 go
 30 exit
31 EOF  
 32
33 if  [  - f  " $DBRESULT "  ]
 34 then
 35  cat  $DBRESULT | grep   $TABLE | awk  ' {print $2} '   
 36 fi 

 

3.FTP数据文件到接口机器(ftp.sh)

 1 #  bash
  2 # author : zpu
  3 # ftp data file to BOSS 
 4
 5 IP = 10.191 . xxx . xxx
  6 USER = myftp
  7 PSWD = myftp
  8 DATA_PATH =/ app / sybase / cmss2boss / temp
  9 cd  $DATA_PATH
10 ftp  - n  $IP   << EOF
11 u  $USER   $PSWD
12 bin
 13 prompt
 14 mput  *
15 EOF

 

4.主程序，分页生成数据文件(main.sh)

 

 1 # !/bin/sh
  2 # todo: main.sh 
 3
 4 if  [  " $# "   !=   " 1 "  ]
  5 then
  6   echo Usage : main . sh tablename
  7    exit
 8 fi 
  9
10 #  env
11 SYBASE =/ app / sybase /
12 SYBASE_ASE = ASE - 12_5
 13 SYBASE_OCS = OCS - 12_5 
 14
15 APP_HOME =/ app / sybase / cmss2boss
 16 DATA_TEMP =/ app / sybase / cmss2boss / temp
 17 # . $SYBASE/SYBASE.sh
18 TBCOUNT = ` $APP_HOME / getdbcount . sh IC_STOCK_DETAIL`
 19 PAGECOUNT = 1
20 PAGESIZE = 100000  
 21
22 TABLENAME = $ 1
23 OVERFLAG_FILENAME = COMPLETE 
 24
25 if  [  " `expr $TBCOUNT % $PAGESIZE` "   !=   " 0 "  ]
 26 then
 27   PAGECOUNT = `expr  $TBCOUNT   /   $PAGESIZE `
 28   PAGECOUNT = `expr  $PAGECOUNT   +   1 `
 29 else
30   PAGECOUNT = `expr  $TBCOUNT   /  PAGESIZE`
 31 fi 
 32
33 echo  $PAGECOUNT  
 34
35 i = 1
36 while  [  $i   - le  $PAGECOUNT  ];  do
37   echo bcp page  $i
38   FILENAME = ` $APP_HOME / genfilename . sh  $TABLENAME  ROOT  $i   0 `
 39   START = `expr  $i   -   1 `
 40   START = `expr  $START   \*   $PAGESIZE `
 41   START = `expr  $START   +   1 `
 42   END = `expr  $i   \*   $PAGESIZE `
 43   echo star : $START
44   echo end : $END
45   bcp CMSS .. $TABLENAME  out  $DATA_TEMP / $FILENAME   - c  - t "  "   - r " \r\n "   - F $START   - L $END   - SINFO1  - Ucmssuser  - Pinfocmss_
 46   VALIDATE_FILENAME = ` $APP_HOME / genfilename . sh  $TABLENAME  ROOT  $i   1 `
 47   touch  $DATA_TEMP / ${VALIDATE_FILENAME}
 48   i = `expr  $i   +   1 ` 
 49 done
 50 # complete flag file
51 touch  $DATA_TEMP / ${OVERFLAG_FILENAME} 
 52
53 $APP_PATH / ftp . sh 
 54
55 rm  - f  $DATA_TEMP /*  
 56

 


 


 


只有注册用户登录后才能发表评论。
网站导航: