插入一个表并使用 shell 脚本更新另一个表

Question

我的 shell 脚本有问题。我想将数据从文件插入到 table1（空），然后将 table1 与 table2 进行比较并更新一些字段。

第一部分是正确的，但第二部分不起作用。 它起作用的唯一方法是，如果在第一部分之后我截断 table1 并再次运行脚本。

我想一次完成所有事情（插入数据并更新）

我的脚本：

    #!/bin/ksh    
DATE=`date +"%Y%m%d"`
PATH_LD=$HOME/myscripts/script_anuk
    PATH_BIN=$HOME/bin/myscripts/script_anuk
    PATH_LOG=$HOME/log/myscripts/script_anuk


    logfile=$PATH_LOG/script_anuk$FECHA.log
    logfileMod=$PATH_LOG/script_anuk_mod$FECHA.log

    # Insert 

    sqlldr parfile=$PATH_LD/script_anuk_param.par USERID=$CONSQLPLUS

    # Update
      sqlplus -s $CONSQLPLUS << EOF!

     SET SERVEROUTPUT ON

     SET FEEDBACK OFF
    exec declare cursor d1 is select d.book, d.phone,d.pencil from table1 d,table2 n where d.book = n.book; whow number:=0;begin for r1 in d1 loop update table2 set phone=r1.phone,pencil=r1.pencil where book = r1.book; whow := whow + 1;if mod(whow,10000) = 0 then commit; end if;end loop;end;
    exit
    EOF!

我的.par

Par
USERID=/
CONTROL=$HOME/myscripts/script_anuk/script_anuk_param.ctl
DATA=$HOME/myscripts/script_anuk/data1.dat
LOG=$HOME/log/myscripts/script_anuk/script_anuk_param.log
BAD=$HOME/myscripts/script_anuk/error/script_anuk_param.bad
DISCARD=$HOME/myscripts/script_anuk/error/script_anuk_param.dsc
ERRORS=1000000
ROWS=500
DIRECT=FALSE

我的 .ctl

Ctl
LOAD DATA
INFILE *
INTO TABLE table1
APPEND
FIELDS TERMINATED BY ';'
(book  , 
phone         ,
pencil)
)

你能帮帮我吗？谢谢！ :)

Answer 1

我正在查看您的匿名块，并通过 SQL*Plus 会话成功运行它：

  1  declare
  2        cursor d1 is
  3        select d.book, d.phone,d.pencil
  4        from table1 d,table2 n
  5        where d.book = n.book;
  6  
  7        whow number:=0;
  8        begin
  9          for r1 in d1 loop
 10            update table2
 11            set phone=r1.phone,
 12                pencil=r1.pencil
 13            where book = r1.book;
 14  
 15          whow := whow + 1;
 16          if mod(whow,10000) = 0 then
 17            commit;
 18          end if;
 19       end loop;
 20       commit;
 21       end;
 22  /

注意我没有在declare 之前调用exec，我在末尾添加了一个commit 以确保在退出之前提交所有行，并且我需要一个/ 来完成和执行该块。我认为这是您遇到的问题的症结所在。

您可能还希望将 STDOUT 和 STDERR 重定向到一个文件，以捕获 SQL*Plus 会话信息。尝试将您的 sqlplus 行更改为：

sqlplus -s $CONSQLPLUS >>$logfile 2>&1 << EOF!

这不是必需的，但可以帮助您解决问题。

Answer 2

这是数据

drop table table1;
drop table table2;
create table table1 (book varchar2(5), phone varchar2(10), pencil varchar2(10));
create table table2 (book varchar2(5), phone varchar2(10), pencil varchar2(10));
insert into table1 values ('Book1','Phone1','Pencil1');
insert into table1 values ('Book2','Phone2','Pencil2');
insert into table2 values ('Book1','Phone1','oops');
insert into table2 values ('Book3','Phone3','Pencil3');
commit;

select * from table1;

BOOK  PHONE      PENCIL   
----- ---------- ----------
Book1 Phone1     Pencil1   
Book2 Phone2     Pencil2   

select * from table2;

BOOK  PHONE      PENCIL   
----- ---------- ----------
Book1 Phone1     oops      
Book3 Phone3     Pencil3   

如果 BOOK 在两个表中都是唯一的，那么您可以改为在脚本中执行此操作

update table2 t2
set (phone, pencil) = 
  (select t1.phone, t1.pencil
  from table1 t1
  where t1.book = t2.book)
;

注意 - 如果 BOOK 不是主键或唯一键，那么只要 t1 中有 >1 行与 BOOK 上的 t2 中的行匹配，此更新就会失败并出现错误。