Shell_Oracle Erp和其他系统Interface资料传输通过Shell进行控制(案例)

简介: 2014-06-26 Created By BaoXinjian 一、摘要 当不同的系统资料进行交换,可以很多种方式,如MQ,DBLink 当接触一些信息安全比较严的项目,很多公司都是采用unix shell直接进行抛转文件的方式进行 使用unix shell抛传文件的时,就必须区分哪些文...

2014-06-26 Created By BaoXinjian

一、摘要


当不同的系统资料进行交换,可以很多种方式,如MQ,DBLink

当接触一些信息安全比较严的项目,很多公司都是采用unix shell直接进行抛转文件的方式进行

使用unix shell抛传文件的时,就必须区分哪些文件已被读取,哪些文件未被读取,读取成功之后文件如何处理,读取失败后的文件如何处理

 

之前做的一个保险项目,其处理不同系统之间所有的interface data资料,都是通过unix shell去控制,其安全性会比较高

本文只是介绍程式的基本结构,不纠结与语法,真正的控制Shell文件会涉及到跟多的部分,如验证,初始化环境变量等等

Step1. 通过一个unix shell去读取一个文件夹interface下所有的文件名,

Step2. 将其插入到一个contorl table中,插入之前先判断该文件名是否存在,如果存在就不再插入,避免重复记录

Step3. 通过utl_file读取contorl table中未被处理的data file

Step4. 读取文件成功后,将该文件transfer到另一个文件夹success

Step5. 读取文件失败后,将该文件transfer到另一个文件夹failed

 

二、案例实现


案例:从另外系统抛传interface dat files资料,并存放在/home/applvis/bts/interface中,通过unix shell去控制文件读取

Step1. 建立control table,用以测试unix shell将未读取的文件名存放至该表中

 1 create table bxj_interface_control_tb(
 2 batch_id number,
 3 file_seq number,
 4 file_name varchar2(240),
 5 record_count number,
 6 success_record number,
 7 failure_record number,
 8 process_status varchar2(50),
 9 request_id number,
10 user_id number,
11 user_name varchar2(240),
12 creation_date date
13 )
14 
15 create sequence bxj_batch_id_sq start with 1000

Step2. 确认存放interface dat资料文件夹下有5个文件,所以当unix shell处理后,这个5个文件必须存放至contorl表中

Step3. 确认存在的三个interface存放dat资料、log存放Shell运行的日志、sql存放SQL执行文件

Step4. 最关键的一步,建立Unix Shell,本人不是DBA出生,虽然学过Bash语法,但是不省精通,大家凑活着看

 1 #/bin/bash  
 2 # +--------------------------------------------+  
 3 # + An example of calling host concurrent      +   
 4 # + Author: Gavin.Bao                          +                                
 5 # +--------------------------------------------+  
 6 #  
 7 # ---------------------------------  
 8 #  Define variable
 9 # ---------------------------------
10 export ORA_USER_PASS=$1
11 export ORA_USER_ID=$2
12 export ORA_LOGIN_NAME=$3
13 export ORA_REQUEST_ID=$4
14 
15 export FOLDER_PATH="/home/applvis/bts/interface/"
16 export INTERFACE_PATH="/home/applvis/bts/interface"
17 export SQL_PATH="/home/applvis/bts/sql"
18 export LOG_PATH="/home/applvis/bts/log"
19 
20 # -------------------------------------------
21 #  Loop the file name and store it into array
22 # -------------------------------------------
23 x=0        
24 for filename in ${FOLDER_PATH}*;
25 do   
26   array[$x]=`basename $filename`  
27   let "x+=1"
28 done
29 
30 for interface_name in ${array[*]}
31 do
32   echo $interface_name
33 done
34 
35 # ---------------------------------  
36 #  Prepare plsql script  
37 # ---------------------------------
38 echo "set serveroutput on size 1000000" > $SQL_PATH/bxjinterface.sql  
39 echo "set feed off" >> $SQL_PATH/bxjinterface.sql  
40 echo "declare" >> $SQL_PATH/bxjinterface.sql
41 echo "  n_count number;" >> $SQL_PATH/bxjinterface.sql
42 echo "  n_batch_id number := &1;" >> $SQL_PATH/bxjinterface.sql
43 echo "  v_file_name varchar2(240) := '&2';" >> $SQL_PATH/bxjinterface.sql
44 echo "begin" >> $SQL_PATH/bxjinterface.sql  
45 echo "  select count(*) into n_count " >> $SQL_PATH/bxjinterface.sql  
46 echo "    from bxj_interface_control_tb where file_name = v_file_name;" >> $SQL_PATH/bxjinterface.sql  
47 echo "  if (n_count = 0) then" >> $SQL_PATH/bxjinterface.sql
48 echo "    insert into bxj_interface_control_tb " >> $SQL_PATH/bxjinterface.sql  
49 echo "    values (bxj_batch_id_sq.nextval,n_batch_id,v_file_name,0,0,0,'N',$ORA_REQUEST_ID,$ORA_USER_ID,'$ORA_LOGIN_NAME',sysdate);" >>$SQL_PATH/bxjinterface.sql
50 echo "  end if;" >>$SQL_PATH/bxjinterface.sql
51 echo "  commit;" >>$SQL_PATH/bxjinterface.sql
52 echo "  dbms_output.put_line('Excuted Sucessfully.');" >> $SQL_PATH/bxjinterface.sql  
53 echo "exception when others then" >> $SQL_PATH/bxjinterface.sql  
54 echo "  rollback;" >> $SQL_PATH/bxjinterface.sql  
55 echo "  dbms_output.put_line('Executed Failed');" >> $SQL_PATH/bxjinterface.sql  
56 echo "  dbms_output.put_line('SQLCODE='||SQLCODE);" >> $SQL_PATH/bxjinterface.sql  
57 echo "  dbms_output.put_line('SQLERRM='||SQLERRM);" >> $SQL_PATH/bxjinterface.sql  
58 echo "end;" >> $SQL_PATH/bxjinterface.sql  
59 echo "/" >> $SQL_PATH/bxjinterface.sql
60 
61 # -------------------------------------------  
62 #  Execute plsql script and generate the log
63 # -------------------------------------------  
64 if [ -s $SQL_PATH/bxjinterface.sql ]; then
65   echo -e "Running SQL script to find out bdump directory... \n"   
66   length=${#array[@]}
67   echo $length
68   for((i=0;i<$length;i++))
69   do
70     $ORACLE_HOME/bin/sqlplus -s apps/apps >> $LOG_PATH/bxjinterface.log << EOF  
71     @$SQL_PATH/bxjinterface.sql $i '${array[$i]}'
72 EOF
73 done
74 fi
75 
76 # --------------------------------  
77 #  show log file
78 # --------------------------------  
79 echo "Check the reslut "
80 echo "------------------------"
81 cat $LOG_PATH/bxjinterface.log
82 
83 echo "bxj shell end"

 

三、案例测试


Test1. 调用建立的Shell文件,读取文件名

 Test2. Unix Shell执行时,产生的Log文件

Test2. Unix Shell执行时,产生的SQL文件

Test3. 查看Contorl table中是否存在5个文件名

 

 

ERP技术讨论群: 288307890
技术交流,技术讨论,欢迎加入
Technology Blog Created By Oracle ERP - 鲍新建
相关文章
|
5月前
|
Oracle 关系型数据库 数据库
Oracle数据恢复—Oracle数据库文件有坏快损坏的数据恢复案例
一台Oracle数据库打开报错,报错信息: “system01.dbf需要更多的恢复来保持一致性,数据库无法打开”。管理员联系我们数据恢复中心寻求帮助,并提供了Oracle_Home目录的所有文件。用户方要求恢复zxfg用户下的数据。 由于数据库没有备份,无法通过备份去恢复数据库。
|
5月前
|
存储 Oracle 关系型数据库
oracle数据恢复—Oracle数据库文件大小变为0kb的数据恢复案例
存储掉盘超过上限,lun无法识别。管理员重组存储的位图信息并导出lun,发现linux操作系统上部署的oracle数据库中有上百个数据文件的大小变为0kb。数据库的大小缩水了80%以上。 取出&并分析oracle数据库的控制文件。重组存储位图信息,重新导出控制文件中记录的数据文件,发现这些文件的大小依然为0kb。
|
4月前
|
存储 Oracle 关系型数据库
服务器数据恢复—华为S5300存储Oracle数据库恢复案例
服务器存储数据恢复环境: 华为S5300存储中有12块FC硬盘,其中11块硬盘作为数据盘组建了一组RAID5阵列,剩下的1块硬盘作为热备盘使用。基于RAID的LUN分配给linux操作系统使用,存放的数据主要是Oracle数据库。 服务器存储故障: RAID5阵列中1块硬盘出现故障离线,热备盘自动激活开始同步数据,在同步数据的过程中又一块硬盘离线,RAID5阵列瘫痪,上层LUN无法使用。
|
6月前
|
监控 网络协议 Shell
ip和ip网段攻击拦截系统-绿叶结界防火墙系统shell脚本
这是一个名为“小绿叶技术博客扫段攻击拦截系统”的Bash脚本,用于监控和拦截TCP攻击。通过抓取网络数据包监控可疑IP,并利用iptables和firewalld防火墙规则对这些IP进行拦截。同时,该系统能够查询数据库中的白名单,确保合法IP不受影响。此外,它还具备日志记录功能,以便于后续分析和审计。
131 6
|
5月前
|
运维 监控 Shell
深入理解Linux系统下的Shell脚本编程
【10月更文挑战第24天】本文将深入浅出地介绍Linux系统中Shell脚本的基础知识和实用技巧,帮助读者从零开始学习编写Shell脚本。通过本文的学习,你将能够掌握Shell脚本的基本语法、变量使用、流程控制以及函数定义等核心概念,并学会如何将这些知识应用于实际问题解决中。文章还将展示几个实用的Shell脚本例子,以加深对知识点的理解和应用。无论你是运维人员还是软件开发者,这篇文章都将为你提供强大的Linux自动化工具。
|
6月前
|
存储 Oracle 关系型数据库
数据库数据恢复—Oracle ASM磁盘组故障数据恢复案例
Oracle数据库数据恢复环境&故障: Oracle ASM磁盘组由4块磁盘组成。Oracle ASM磁盘组掉线 ,ASM实例不能mount。 Oracle数据库故障分析&恢复方案: 数据库数据恢复工程师对组成ASM磁盘组的磁盘进行分析。对ASM元数据进行分析发现ASM存储元数据损坏,导致磁盘组无法挂载。
|
7月前
|
Oracle 关系型数据库 数据库
数据库数据恢复—Oracle数据库文件出现坏块的数据恢复案例
打开oracle数据库报错“system01.dbf需要更多的恢复来保持一致性,数据库无法打开”。 数据库没有备份,无法通过备份去恢复数据库。用户方联系北亚企安数据恢复中心并提供Oracle_Home目录中的所有文件,急需恢复zxfg用户下的数据。 出现“system01.dbf需要更多的恢复来保持一致性”这个报错的原因可能是控制文件损坏、数据文件损坏,数据文件与控制文件的SCN不一致等。数据库恢复工程师对数据库文件进一步检测、分析后,发现sysaux01.dbf文件损坏,有坏块。 修复并启动数据库后仍然有许多查询报错,export和data pump工具使用报错。从数据库层面无法修复数据库。
数据库数据恢复—Oracle数据库文件出现坏块的数据恢复案例
|
7月前
|
Oracle 关系型数据库 数据库
Oracle数据恢复—异常断电导致Oracle数据库数据丢失的数据恢复案例
Oracle数据库故障: 机房异常断电后,Oracle数据库启库报错:“system01.dbf需要更多的恢复来保持一致性,数据库无法打开”。数据库没有备份,归档日志不连续。用户方提供了Oracle数据库的在线文件,需要恢复zxfg用户的数据。 Oracle数据库恢复方案: 检测数据库故障;尝试挂起并修复数据库;解析数据文件。
|
6月前
|
Oracle 关系型数据库 数据库
oracle数据恢复—Oracle数据库文件损坏导致数据库打不开的数据恢复案例
打开oracle数据库时报错,报错信息:“system01.dbf需要更多的恢复来保持一致性,数据库无法打开”。急需恢复zxfg用户下的数据。 出现上述报错的原因有:控制文件损坏、数据文件损坏、数据文件与控制文件的SCN不一致等。数据恢复工程师对数据库文件做进一步检测分析后发现sysaux01.dbf文件有坏块。修复sysaux01.dbf文件,启动数据库依然有许多查询报错。export和data pump工具无法使用,查询告警日志并分析报错,确认发生上述错误的原因就是sysaux01.dbf文件损坏。由于该文件损坏,从数据库层面无法修复数据库。由于system和用户表空间的数据文件是正常的,
|
10月前
|
Shell
5.Electron之shell(使用系统默认浏览器打开网页)
5.Electron之shell(使用系统默认浏览器打开网页)
267 1

推荐镜像

更多
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等