找出结构不同的表，并生成卸出数据的SQL脚本
通过以下步骤，找到在新旧数据库中都存在，并且结构发生了变化的table，并生成重新卸出数据的SQL语句。
# 根据数据库的SCHEMA文件，取得指定table的SCHEMA
# : table名称
# : 数据库的SCHEMA文件，需要先做格式化
# : 输出的表的SCHEMA文件
gettableschema()
{
#echo "table name: "
#echo "dbschema name: "
#echo "outfile name: "
awk -v_tblname= 'BEGIN{isThisTable = 0;}{
if( == "create" && == "table" && match(, """_tblname""") > 0)
{
isThisTable = 1;
printf("create table %s (n", _tblname); #### )
}
else if(isThisTable == 1)
{
if(match(, ";") > 0)
{
isThisTable = 0;
if( == "in")
printf("; n", );
else
printf("%sn", );
}
else if(match(, "timestamp not null with default ,") > 0)
{
printf("%s timestamp not null with default current timestamp , n", );
}
else
{
printf("%sn", );
}
}
}' >
}
# 生成卸出指定表的数据的SQL脚本
# . 旧数据库的SCHEMA文件
# . 新数据库的SCHEMA文件
# . 输出的卸出指定表的数据的SQL脚本文件名
# . 指定的表名
# . db2move卸出文件时的清单文件
genunloadsql()
{
TMPSQLFILE=.tmpsql.sql.sql
TMPNEWTBLFLD=.tmpfld.fld.fld
rm -f $
# 1. 用新的表结构创建一个临时表
awk '{
if(NR > 1)
{
gsub(""", "", ); # remove character "
printf("%sn", );
}
else
{
printf("create table sihitranstmptbl (n"); # )
}
}' > $
# 2. 生成insert into transtmptbl (...) select ... from <oldtbl>的SQL
# 2.1. 生成新旧两个表的字段列表
awk '{
if(NR > 1 && != ";")
{
gsub(""", "", ); # remove character "
printf("%sn", );
}
}' > $
isFirstFeild=1
Select=""
Into=""
for fldname in `cat $`
do
grep ""$"" 1>/dev/null 2>&1
if [ $? -eq 0 ]
then
# 2.2. 取出在新旧两表中都有的字段名，加入到select子句和into子句中
if [ $ -eq 0 ]
then
Select="$,"
Into="$,"
fi
Select="$ $"
Into="$ $"
isFirstFeild=0
else
# 2.3. 取出仅在新表中出现的字段，如果该字段不允许null，
# 且没有设置default值，则按以下原则取默认值放到select子句中，
# 并将字段名放到into子句中
grep ""$"" | grep "not null" 1>/dev/null 2>&1
if [ $? -eq 0 ]
then
grep ""$"" | grep "with default" 1>/dev/null 2>&1
if [ ! $? -eq 0 ]
then
if [ $ -eq 0 ]
then
Select="$,"
Into="$,"
fi
# 计算默认值
# 对于新增的字符型字段，默认值为''；
# 对于新增的数值型字段，默认值为0；
# 对于新增的TIMESTAMP字段，默认值为'';
# 对于新增的SERIAL开字段，默认值为0；
# 对于新增的DATE字段，默认值为；
# 对于新增的DATETIME字段，默认值为；
Const=`grep ""$"" | awk '{
if(match(, "int") > 0) # integer, smallint, bigint
printf("0");
else if(match(, "numeric") > 0)
printf("0.0");
else if(match(, "decimal") > 0)
printf("0.0");
else if(match(, "double") > 0)
printf("0.0");
else if(match(, "float") > 0)
printf("0.0");
else if(match(, "real") > 0)
printf("0.0");
else if(match(, "char") > 0) # char, varchar
printf("" "");
else if( == "timestamp")
printf("current timestamp");
else if( == "date")
printf("current date");
else if( == "time")
printf("current time");
else
printf("" "");
}'`
Select="$ $"
Into="$ $"
isFirstFeild=0
fi
fi
fi
done
tablefullname=`grep -i """" | awk -F"!" '{printf("%s", );}'`
echo "insert into sihitranstmptbl ($) select $ from
$ ;" >> $
# 3. 将临时表中的数据导出到文件中
Unloadfile=`grep -i """" | awk -F"!" '{printf("%s", );}'`
echo "export to $ of ixf select * from sihitranstmptbl ;"
>> $
# 4. 删除临时表
echo "drop table sihitranstmptbl ;" >> $
cat $ >>
rm -f $
rm -f $
}
echo "table in both database:"
TABLEINBOTH="`echo $ | tr [:upper:] [:lower:]`"
echo > $
for tblname in $
do
gettableschema $ $ $
gettableschema $ $ $
diff $ $ 1>/dev/null 2>&1
if [ ! $? -eq 0 ]
then
# 如果有不同，则生成卸出数据的SQL脚本
echo "different table:" $
genunloadsql $ $
$ $ $
else
echo "same table:" $
fi
done
其中，TABLEINBOTH是由上一步（找出仅在旧库或者新库中独有的表）的副产品。
注意，上述程序中，并没有处理新旧table中均有并且字段类型不同的字段，这种情况可以在卸出数据时按需要手工编辑生成的SQL脚本。
生成的SQL脚本名称叫"unload.sql"。在PC机上的DB2命令窗口中执行：
db2 -z result.txt -tvf unload.sql
其中，"-z"选项将执行结果同时输出到屏幕及文件result.txt中。执行结束时，需要查看result.txt，如果其中有错误提示，请按需要修改unload.sql。修改之后，再重新执行上述命令，直到所有SQL命令均执行无错为止。