anchor.diff:                                     {error, _Error} -> undefined;
                                      BindVals0 -> BindVals0
                                   end, 
  -    case dderloci:exec(Connection, Query, BindVals, ?GET_ROWNUM_LIMIT) of
  +    case dderloci:exec(Connection, Query, BindVals, imem_sql_expr:rownum_limit()) of
           {ok, #stmtResult{stmtCols = Clms, stmtRef = StmtRef, rowFun = RowFun}, _} ->
               Columns = gen_adapter:build_column_csv(oci,Clms),
               From ! {reply_csv, FileName, Columns, first},
  
positive.code: -spec process_query(tuple()|binary(), tuple(), pid()) -> list().
  process_query({Query, BindVals}, {oci_port, _, _} = Connection, SessPid) ->
      process_query(check_funs(dderloci:exec(Connection, Query, BindVals,
                                             ?GET_ROWNUM_LIMIT)),
                    Query, BindVals, Connection, SessPid);
  process_query(Query, {oci_port, _, _} = Connection, SessPid) ->
      process_query(check_funs(dderloci:exec(Connection, Query,
                                             ?GET_ROWNUM_LIMIT)),
                    Query, [], Connection, SessPid).
  
  -spec process_query(term(), binary(), list(), tuple(), pid()) -> list().
  
negative.code:                                    {error, _Error} -> undefined;
                                     BindVals0 -> BindVals0
                                 end,
                      case dderloci:exec(Connection, Query, BindVals, imem_sql_expr:rownum_limit()) of
                          {ok, #stmtResult{} = StmtRslt, TableName} ->
                              dderloci:add_fsm(StmtRslt#stmtResult.stmtRef, FsmStmt),
                              FsmCtx = generate_fsmctx_oci(StmtRslt, Query, BindVals, Connection, TableName),
  