Shell练习（4）_表的世代管理和存储过程

#!/bin/shnow=`date +"%Y%m%d %A %T"`echo "${now}    ／START AnalyzeTest">>D:/IDBCDB/test/tablechangeTest/TestMaster.log# 一ファイルの指定spoolFile="D:/IDBCDB/test/AnalyzeTest/TablechangeTest.log"# DB接情の取得confFile="D:/IDBCDB/test/AnalyzeTest/oracon_newbiz.conf"userid=`grep '^userid' ${confFile} | cut -d= -f2`passwd=`grep '^passwd' ${confFile} | cut -d= -f2`constr=`grep '^constr' ${confFile} | cut -d= -f2`svaddr=`grep '^svaddr' ${confFile} | cut -d= -f2`port=`grep '^port' ${confFile} | cut -d= -f2`# DB接テスト#CLASSPATH="${ORACLE_HOME}/jdbc/lib/classes12.zip;"#export CLASSPATHjava connectTest ${svaddr} ${port} ${constr} ${userid} ${passwd}echo $?if [ $? -ne 0 ];then        exit 1fi# SQLの行$ORACLE_HOME/bin/sqlplus -s ${userid}/${passwd}@${constr}  << END > /dev/null 2>&1spool ${spoolFile}/* 前月テブルを空にして、名称（今月テブル用）に改名する（2部用）*/define num_out=0variable num_varnumbercol out_data new_value num_outDECLAREddl_cursor number;/* 内部????????*/PROCEDURE s_dbms_sql(t_nameINVARCHAR2)ISBEGIN/* 前月テブルのTRUNCATE*/ddl_cursor := DBMS_SQL.OPEN_CURSOR;DBMS_SQL.PARSE(ddl_cursor,'truncate table P1_' || t_name,dbms_sql.v7);DBMS_SQL.CLOSE_CURSOR(ddl_cursor);/* 前月テブルを名称に改名*/ddl_cursor := DBMS_SQL.OPEN_CURSOR;DBMS_SQL.PARSE(ddl_cursor,'rename P1_' || t_name || ' to TP_' || t_name,dbms_sql.v7);DBMS_SQL.CLOSE_CURSOR(ddl_cursor);:num_var := 0;END s_dbms_sql;BEGINs_dbms_sql('GUIMING_TABLE_20100312');EXCEPTIONWHEN OTHERS THEN DBMS_SQL.CLOSE_CURSOR(ddl_cursor);:num_var := 1;END;/select :num_var out_data from dual;exit num_outspool offENDif [ $? -ne 0 ];thenexit 1finow=`date +"%Y%m%d %A %T"`echo "${now}    ＼END   AnalyzeTest">>D:/IDBCDB/test/tablechangeTest/TestMaster.log

#!/bin/shnow=`date +"%Y%m%d %A %T"`echo "${now}    ／START AnalyzeTest">>D:/IDBCDB/test/tablechangeTest/TestMaster.log# 一ファイルの指定spoolFile="D:/IDBCDB/test/AnalyzeTest/TablechangeTest.log"# DB接情の取得confFile="D:/IDBCDB/test/AnalyzeTest/oracon_newbiz.conf"userid=`grep '^userid' ${confFile} | cut -d= -f2`passwd=`grep '^passwd' ${confFile} | cut -d= -f2`constr=`grep '^constr' ${confFile} | cut -d= -f2`svaddr=`grep '^svaddr' ${confFile} | cut -d= -f2`port=`grep '^port' ${confFile} | cut -d= -f2`# DB接テスト#CLASSPATH="${ORACLE_HOME}/jdbc/lib/classes12.zip;"#export CLASSPATHjava connectTest ${svaddr} ${port} ${constr} ${userid} ${passwd}echo $?if [ $? -ne 0 ];then        exit 1fi# SQLの行$ORACLE_HOME/bin/sqlplus -s ${userid}/${passwd}@${constr}  << END > /dev/null 2>&1spool ${spoolFile}/* 今月テブルを前月テブルに改名し、名称をつけたテブルを今月テブルに改名（2部用）*/define num_out=0variable num_varnumbercol out_data new_value num_outDECLAREddl_cursor number;/* 内部????????*/PROCEDURE s_dbms_sql(t_nameINVARCHAR2)ISBEGIN/* 今月テブルを前月テブルに改名*/ddl_cursor := DBMS_SQL.OPEN_CURSOR;DBMS_SQL.PARSE(ddl_cursor,'rename' || t_name || ' to P1_' || t_name,dbms_sql.v7);DBMS_SQL.CLOSE_CURSOR(ddl_cursor);/* 名称にしたテブルを今月テブルに改名*/ddl_cursor := DBMS_SQL.OPEN_CURSOR;DBMS_SQL.PARSE(ddl_cursor,'rename TP_' || t_name || ' to ' || t_name,dbms_sql.v7);DBMS_SQL.CLOSE_CURSOR(ddl_cursor);:num_var := 0;END s_dbms_sql;BEGINs_dbms_sql('GUIMING_TABLE_20100312');EXCEPTIONWHEN OTHERS THEN DBMS_SQL.CLOSE_CURSOR(ddl_cursor);:num_var := 1;END;/select :num_var out_data from dual;exit num_outspool offENDif [ $? -ne 0 ];thenexit 1finow=`date +"%Y%m%d %A %T"`echo "${now}    ＼END   AnalyzeTest">>D:/IDBCDB/test/tablechangeTest/TestMaster.log

?

世代管理：

这是ETL里边一个很普遍的应用。

表分为前世代表，现世代表，后世代表。

现世代表主要是现在应用的表，前世代表主要是对现世代的以前数据的备份。

看第一个Shell将一个前世代表清空，然后改名为一个中间表。

第二个Shell把中间表改为现世代表，然后把现世代表更名为前世代表。

这样就完成了数据的备份。和清空现世代表，准备先一次数据的接收。

?

存储过程：

Shell中定义内部存储过程。

define num_out=0variable num_varnumbercol out_data new_value num_outDECLAREddl_cursor number;/* 内部????????*/PROCEDURE s_dbms_sql(t_nameINVARCHAR2)ISBEGIN/* 今月テブルを前月テブルに改名*/ddl_cursor := DBMS_SQL.OPEN_CURSOR;DBMS_SQL.PARSE(ddl_cursor,'rename' || t_name || ' to P1_' || t_name,dbms_sql.v7);DBMS_SQL.CLOSE_CURSOR(ddl_cursor);/* 名称にしたテブルを今月テブルに改名*/ddl_cursor := DBMS_SQL.OPEN_CURSOR;DBMS_SQL.PARSE(ddl_cursor,'rename TP_' || t_name || ' to ' || t_name,dbms_sql.v7);DBMS_SQL.CLOSE_CURSOR(ddl_cursor);:num_var := 0;END s_dbms_sql;BEGINs_dbms_sql('GUIMING_TABLE_20100312');EXCEPTIONWHEN OTHERS THEN DBMS_SQL.CLOSE_CURSOR(ddl_cursor);:num_var := 1;END;/select :num_var out_data from dual;exit num_outspool offEND

?

有关DBMS_SQL应用说明：

?

PL/SQL中使用动态SQL编程

在PL/SQL程序设计过程中，会遇到很多必须使用动态sql的地方，oracle系统所提供的DMBS_SQL包可以帮助你解决问题。
(一)介绍
DBMS_SQL系统包提供了很多函数及过程,现在简要阐述其中使用频率较高的几种:

function open_cursor:打开一个动态游标,并返回一个整型;

procedure close_cursor(c in out integer);关闭一个动态游标,参数为open_cursor所打开的游标;

procedure parse(c in integer, statement in varchar2, language_flag in integer):对动态游标所提供的sql语句进行解析,参数C表示游标,statement为sql语句,language-flag为解析sql语句所用oracle版本,一般有V6,V7跟native(在不明白所连database版本时,使用native);

procedure define_column(c in integer, position in integer, column any datatype, [column_size in integer]):定义动态游标所能得到的对应值,其中c为动态游标,positon为对应动态sql中的位置(从1开始),column为该值所对应的变量,可以为任何类型,column_size只有在column为定义长度的类型中使用如VARCHAR2,CHAR等(该过程有很多种情况,此处只对一般使用到的类型进行表述);

function execute(c in integer):执行游标,并返回处理一个整型,代表处理结果(对insert,delete,update才有意义,而对select语句而言可以忽略);

function fetch_rows(c in integer):对游标进行循环取数据,并返回一个整数,为0时表示已经取到游标末端;

procedure column_value(c in integer, position in integer, value):将所取得的游标数据赋值到相应的变量,c为游标,position为位置,value则为对应的变量;

procedure bind_variable(c in integer, name in varchar2, value):定义动态sql语句(DML)中所对应字段的值,c为游标,name为字段名称,value为字段的值;

以上是在程序中经常使用到的几个函数及过程,其他函数及过程请参照oracle所提供定义语句dbmssql.sql

(二)一般过程
对于一般的select操作,如果使用动态的sql语句则需要进行以下几个步骤:
open cursor--->parse--->define column--->excute--->fetch rows--->close cursor;
而对于dml操作(insert,update)则需要进行以下几个步骤:
open cursor--->parse--->bind variable--->execute--->close cursor;
对于delete操作只需要进行以下几个步骤:
open cursor--->parse--->execute--->close cursor;

?

?