PowerBuilder 12.5 sql 游标事务大小错误

Question

我遇到了一个大问题并试图找到解决方法。我在 PB12.5 中有一个适用于 sql 和 oracle dbs 的应用程序..（有很多数据）

我在某个点使用 CURSOR，但应用程序仅在 sql 中崩溃。在 PB 中使用调试我发现由于巨大的事务大小，sql 连接返回 -1。但我想逐行获取我的数据.. 是否有任何解决方法来获取分页等数据？我的意思是让我们先获取前 1000 行，然后再获取其他 1000 行，依此类推.. 我希望你理解我想要实现的目标（打破获取过程，尽可能减少事务大小），这是我的代码

DECLARE trans_Curs CURSOR FOR 
 SELECT associate_trans.trans_code  
 FROM associate_trans  
WHERE associate_trans.usage_code = :ggs_vars.usage  ORDER BY associate_trans.trans_code ;

  OPEN trans_Curs;
  FETCH  trans_Curs INTO :ll_transId;

  DO WHILE sqlca.sqlcode = 0
  ll_index += 1
        hpb_1.Position = ll_index
        if not guo_associates.of_asstrans_updatemaster( ll_transId, ls_error) then
        ROLLBACK;
        CLOSE trans_Curs;
      SetPointer(Arrow!)
      MessageBox("Update Process", "Problem with the update process on~r~n" + sqlca.sqlerrtext)
    cb_2.Enabled = TRUE
    return
 end if
 FETCH trans_Curs INTO :ll_transId;
 LOOP
 CLOSE trans_Curs; 

Answer 1

由于您的源表的结构没有完全呈现，我将在这里做一些假设。

假设记录包含一个可以用作参考的唯一字段（可以是计数器或时间戳）。我在这里假设该字段是时间戳。

我们还假设 PB 接受带参数的游标（并非所有解决方案都这样做；如果不是，则有简单的解决方法）。

您可以将光标修改为：

[注意：我还假设此处介绍的语法对您的环境有效；如果没有，适应很简单]

DECLARE TopTime TIMESTAMP ;
DECLARE trans_Curs CURSOR FOR 
         SELECT ots.associate_trans.trans_code  
           FROM ots.associate_trans  
          WHERE ots.associate_trans.usage_code = :ggs_vars.usage
            AND ots.associate_trans.Timestamp  < TopTime
          ORDER BY ots.associate_trans.trans_code 
          LIMIT 1000 ;
:
:
IF (p_Start_Timestamp IS NULL) THEN
    TopTime = CURRENT_TIMESTAMP() ;
ELSE
    TopTime = p_Start_Timestamp  ;
END IF ;

OPEN trans_Curs;
FETCH  trans_Curs INTO :ll_transId;
:
:

在上面：

1. p_Start_Timestamp 是接收到的时间戳参数，最初为空，然后将包含在上一次调用中获取的 OLDEST 时间戳，

2. CURRENT_TIMESTAMP() 是您的环境返回当前时间戳的函数。

此解决方案仅适用于您需要朝一个方向前进（即从现在到过去）并且您将所有获取的记录累积到内部缓冲区中以防您需要向上滚动再次。

希望这能让事情更清楚。

Answer 2

首先感谢 FDavidov 的努力，所以我设法使用动态数据存储而不是游标来做到这一点，所以这是我的解决方案，以防其他人需要。

    String ls_sql, ls_syntax, ls_err
    Long ll_row
    DataStore lds_info      

    ls_sql = "SELECT associate_trans.trans_code  "  &
                + " FROM associate_trans " &
                + "  WHERE  associate_trans.usage_code = '" + ggs_vars.usage +"' "&
                + " ORDER BY associate_trans.trans_code"
    ls_syntax = SQLCA.SyntaxFromSQL( ls_sql, "", ls_err )

    IF ls_err <> '' THEN
    MessageBox( 'Error...', ls_err )
    RETURN
    END IF

    lds_info = CREATE DataStore
    lds_info.Create( ls_syntax, ls_err )
    lds_info.SetTransObject( SQLCA )
    lds_info.Retrieve( )        

        DO WHILE sqlca.sqlcode = 0 and ll_row <= ll_count               
                FOR ll_row = 1 TO ll_count
                    ll_transId = lds_info.GetItemNumber( ll_row, 'trans_code' )                         
                        ll_index += 1
                        hpb_1.Position = ll_index
                        do while yield(); loop
                        if not guo_associates.of_asstrans_updatemaster( ll_transId, ls_error) then
                            ROLLBACK;
                            DESTROY lds_info
                            SetPointer(Arrow!)
                            MessageBox("Update Process", "Problem with the update process on~r~n" + sqlca.sqlerrtext)
                            cb_2.Enabled = TRUE
                            return
                        end if              
                    NEXT
                    DESTROY lds_info                    
        LOOP