Oracle Data Integrator 标量函数用法

Question

我的源数据库架构中有一个标量函数，我使用它来获取指定帐户的余额。

NVL(MYGL.F_GET_LAST_ACC_BALANCE(ACCOUNTS.ACC_NO, TRUNC(SYSDATE), 1),0)

在 ODI 映射中，我想使用此函数来获取帐户余额，然后将它们加载到我的 DWH 数据库中。

我正在将 IKM Oracle Insert 与 DbLink 结合使用。

我尝试在映射内使用 EXPRESSION，但这并没有给我结果，因为 ODI 尝试在 DWH 端而不是源端执行 MYGL.F_GET_LAST_ACC_BALANCE。 MYGL.F_GET_LAST_ACC_BALANCE 在源数据库中定义。

这是生成的查询

INSERT 
  /*+  APPEND PARALLEL  */ 
  INTO DWH.FACT_ACCOUNTS
  (
    REPORT_DATE ,
    ACC_NO ,
    ACC_PROD_CODE ,
    REAL_BALANCE ,
    LAST_BALANCE 
  ) 
SELECT 
  TRUNC(SYSDATE) ,
  ACCOUNTS.ACC_NO ,
  ACCOUNTS.ACC_PROD_CODE ,
  ACCOUNTS.ACC_BALANCE ,
  (NVL(MYGL.F_GET_LAST_ACC_BALANCE(ACCOUNTS.ACC_NO, TRUNC(SYSDATE), 1),0))  
FROM 
  <schema>.<table>@<dblink_to_source> ACCOUNTS   

它需要什么

INSERT 
  /*+  APPEND PARALLEL  */ 
  INTO DWH.FACT_ACCOUNTS
  (
    REPORT_DATE ,
    ACC_NO ,
    ACC_PROD_CODE ,
    REAL_BALANCE ,
    LAST_BALANCE 
  ) 
SELECT 
  TRUNC(SYSDATE) ,
  ACCOUNTS.ACC_NO ,
  ACCOUNTS.ACC_PROD_CODE ,
  ACCOUNTS.ACC_BALANCE ,
  (NVL(MYGL.F_GET_LAST_ACC_BALANCE@<dblink_to_source>(ACCOUNTS.ACC_NO, TRUNC(SYSDATE), 1),0))  
FROM 
  <schema>.<table>@<dblink_to_source> ACCOUNTS  

Answer 1

可能您需要的东西对于使用预定义的 Oracle KM 来说太自定义了。

我认为解决方案是使用另一个 IKM，它不使用 DBLINK，而是使用 JDBC 连接(通过物理模式中定义的 jdbc 直接连接到源)。

这样，您的代码将直接在源上执行，并且函数将被识别。