在循环期间重新初始化 PL/SQL 中的变量/记录

Question

为了为 ETL 过程创建 PL/SQL 解析器（其中数据主要是位置编码），我需要逐行读取文件并将记录添加到内存中（包范围）表中进入当前记录或进入新记录。

让我简单解释一下场景和语法规则： 我需要解析银行对齐消息，该消息具有公共标准格式（找不到英文文档，只能 此 和其他意大利文档，而这应该是欧盟范围内的标准）。无论如何，这里有一些规则解释：

• 文件中的每条记录长度为 120 个字符
• 每个文件以“AL”（对齐）记录开头
• 每个文件以“EF”（文件结束）记录结尾
• 每个对齐消息以“12”开头” 记录并以“70”记录结尾
• 根据“12”记录的类型，消息可以由其他记录的不同组合组成，例如“30”和“40”、“50”、“45”、 “50”和"45" "50"

示例（结构化）：

AL record
    12 record
        45 record
    70 record
    12 record
        45 record
        50 record
    70 record
EF record

我已经声明了 CHAR(120) 的 MESSAGE PL/SQL 表，该表将封装 12 到 70 之间的记录（包括），这些将在稍后阶段进行处理。现在我有一个可以在 Java 中轻松解决的循环问题。

如何在 PL/SQL 中重新初始化变量？这是一个伪 Java 示例，说明我

String line;
List<String> alignment_message;
List<AlignmentMessage> table;
while (line = readline()) {
    if (line.substring(1,2)=="12") //Begin of message 
        alignment_message = new MESSAGE(); //******HOW DO I DO THIS????
    alignment_message.add(line); //Don't care about NPE ;-)

    if (line.substring(1,2)=="70") //End of message
        table.add(alignment_message);
}

当前需要在 PL/SQL 过程中声明一个 MESSAGE 类型的变量 msg。如果我对此变量执行 INSERT 操作，然后将此变量 INSERT 插入包含 MESSAGE 类型列（以及一对我用于预处理的其他列），如何将新的 INSERT 执行到 fresh 新的 msg 变量中？

谢谢

Answer 1

如果您已将 MESSAGE 声明为 TABLE OF CHAR(120)、TABLE OF CHAR(120) INDEX BY BINARY_INTEGER 或 VARRAY( ...) OF CHAR(120)，那么你可以做

msg.DELETE;

DELETE 嵌套表上的方法，索引表和变量删除其中的所有元素。

当您 INSERT msg 到表中时，Oracle 似乎存储了它的副本，而不是对其的引用。从 msg 中删除所有元素不会导致表中的数据突然消失。

或者，如果 MESSAGE 是 TABLE OF CHAR(120) 或 VARRAY(...) OF CHAR(120)，您可以调用MESSAGE() 构造函数，即

msg := MESSAGE();

Answer 2

declare
  type message_t is table of char(120);
  v_message message_t := message_t('12 record', /* start */
                                   '40 record',
                                   '70 record', /* end */
                                   '12 record', /* start */
                                   '50 record',
                                   '51 record',
                                   '70 record'  /* end */
                                   );
  v_almessage message_t := message_t();
  v_i number := v_message.first;
begin
  while v_i <= v_message.last loop
    if v_message(v_i) = '12 record' then /* start of a block */
      dbms_output.put_line('start of a block');

      loop
        v_i := v_i + 1;

        if v_message(v_i) = '70 record' then /* end of a block */
          dbms_output.put_line('end of a block');

          /* Do whatever processing you need to do. I just print collected
          messages. */
          for j in v_almessage.first .. v_almessage.last loop
            dbms_output.put_line('aligment message: ' || v_almessage(j)); 
          end loop;

          /* Reset collected messages. */
          v_almessage := message_t();

          exit;
        end if;

        /* Collect block's aligment messages. */
        v_almessage.extend(1);
        v_almessage(v_almessage.last) := v_message(v_i);
      end loop;

    end if;

    v_i := v_i + 1;
  end loop;

end;
/

印刷：

start of a block
end of a block
aligment message: 40 record
start of a block
end of a block
aligment message: 50 record
aligment message: 51 record