0

提供任何更好的将 UPSERT 插入表格的方法：

  • 以 ~1 行/秒的速度插入数据
  • 表名是动态的，使用传递给它的 ObjectID 参数生成

以下过程抛出：“ORA-00942：表或视图不存在”

CREATE OR REPLACE PROCEDURE
PROCEDURE "SPINSERTDATA"
(
  pObjectID IN RAW,
  pDateTime IN TIMESTAMP,
  pValue IN BINARY_DOUBLE,
)
AS
BEGIN
  Declare
    vQueryInsert VARCHAR2(1000);
    vQueryUpdate VARCHAR2(1000);
    vTableName VARCHAR2(30);
  Begin      
      vTableName := FGETTABLENAME(POBJECTID => pObjectID);
      vQueryUpdate := 'UPDATE '      || vTableName || ' SET "VALUE" = :1';
      vQueryInsert := 'INSERT INTO ' || vTableName || ' ("DTTIME", "VALUE") VALUES (:1, :2)';

      EXECUTE IMMEDIATE vQueryInsert USING pDateTime, pValue;
        EXCEPTION
          WHEN DUP_VAL_ON_INDEX THEN 
            EXECUTE IMMEDIATE vQueryUpdate USING pValue;
  End;
END "SPINSERTDATA";
  • 显然 MERGE 不起作用，因为 TableName 不能是动态的？？？
  • 我是一个新手，我的第三个月的编码，我通过 STACKOVERFLOW 和谷歌搜索了 3 天，尝试了各种有趣和绝望的解决方案......如果你找到一个非常相关的链接，我将不胜感激。
4

3 回答 3

4

MERGE 与本机动态 SQL (EXECUTE IMMEDIATE) 完美配合：

create table so_test(pk number not null primary key, value varchar2(20));

insert into so_test(pk, value) values(1, 'one');

declare
  l_SQL varchar2(4000);
  l_tablename varchar2(4000) default 'so_test';
begin
  l_SQL := 'merge into ' || l_tablename || ' target' ||
    ' using (select 1 pk, ''eins'' value from dual union all
             select 2 pk, ''zwei'' value from dual) source
      on (target.pk = source.pk)
      when matched then 
        update set target.value = source.value
      when not matched then
        insert values(source.pk, source.value)      
  ';
  dbms_output.put_line(l_sql);
  execute immediate l_SQL;
end;

您能否发布使用 MERGE 时收到的错误消息？

于 2011-07-20T13:10:37.687 回答
2

您应该考虑编写此代码以使用静态 SQL，而不是在运行时传递表名。您是否有正当理由不知道在运行时之前要合并到哪个表中？

至于调试问题...

您的代码中如何定义函数 FGETTABLENAME？这就是我想出的模仿这种情况的方法。我建议使用 %type （而不是数字类型的 RAW）声明并从过程名称中删除双引号。

    create or replace function FGETTABLENAME(
        POBJECTID in user_objects.object_id%type
    ) return user_objects.object_name%type
    as
      v_object_name user_objects.object_name%type;
    begin
      select object_name
        into v_object_name
        from all_objects
        where object_id = pobjectid;
       return v_object_name;
    end;
    /

SQL> select object_id, object_name from user_objects;

 OBJECT_ID OBJECT_NAME
---------- --------------------------------------------
     52641 TFIVE
     52644 SPINSERTDATA
     52643 PROCEDURE
     52645 FGETTABLENAME
     52554 GET_SAL_EMP
     52559 T1

SQL> select FGETTABLENAME(52641) from dual;

FGETTABLENAME(52641)
--------------------------------------------
TFIVE

您可以在之后将 DBMS_OUTPUT.PUT_LINE 语句添加到您的代码中 

vTableName := FGETTABLENAME(POBJECTID => pObjectID); 

and 

vQueryUpdate := 'UPDATE '      || vTableName || ' SET "VALUE" = :1';
      vQueryInsert := 'INSERT INTO ' || vTableName || ' ("DTTIME", "VALUE") VALUES (:1, :2)';

或跟踪您的代码以查看向您的数据库触发的实际 SQL 语句。

于 2011-07-20T13:24:27.793 回答
2

首先，您的 UPDATE 中没有 WHERE，因此它将更新表的每一行。

其次，您是否使用了大小写混合的表名。如果你做一个

CREATE TABLE "testOne" (ID NUMBER);

那么表名将存储为 testOne。但是当你这样做时，UPDATE testOne将被视为UPDATE TESTONE并且你会得到一个“没有这样的表”错误。

避免使用大小写混合的表名。如果您绝对必须，那么您需要在动态 SQL 语句中引用它们

于 2011-07-21T00:11:12.763 回答