281: 'WHERE clid$$cs = :1 AND ' ||
282: ' tranid$$ = :2 ' ||
283: ' ORDER BY store';
284:
285: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
286: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
287: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
288: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
289: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
282: ' tranid$$ = :2 ' ||
283: ' ORDER BY store';
284:
285: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
286: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
287: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
288: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
289: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
290: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
283: ' ORDER BY store';
284:
285: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
286: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
287: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
288: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
289: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
290: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
291:
284:
285: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
286: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
287: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
288: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
289: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
290: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
291:
292: counter := 1;
285: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
286: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
287: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
288: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
289: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
290: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
291:
292: counter := 1;
293: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
286: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
287: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
288: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
289: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
290: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
291:
292: counter := 1;
293: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
294: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
289: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
290: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
291:
292: counter := 1;
293: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
294: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
295: l_pubitems_tbl(counter) := l_store;
296: counter := counter +1;
297: END LOOP;
290: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
291:
292: counter := 1;
293: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
294: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
295: l_pubitems_tbl(counter) := l_store;
296: counter := counter +1;
297: END LOOP;
298:
295: l_pubitems_tbl(counter) := l_store;
296: counter := counter +1;
297: END LOOP;
298:
299: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
300:
301: counter := 1;
302: counter2:= 1;
303: FOR curr_index2 IN 1..l_pubitems_tbl.count LOOP
504: 'WHERE clid$$cs = :1 AND ' ||
505: ' tranid$$ = :2 ' ||
506: ' ORDER BY store';
507:
508: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
509: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
510: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
511: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
512: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
505: ' tranid$$ = :2 ' ||
506: ' ORDER BY store';
507:
508: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
509: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
510: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
511: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
512: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
513: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
506: ' ORDER BY store';
507:
508: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
509: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
510: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
511: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
512: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
513: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
514:
507:
508: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
509: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
510: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
511: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
512: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
513: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
514:
515: counter := 1;
508: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
509: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
510: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
511: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
512: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
513: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
514:
515: counter := 1;
516: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
509: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
510: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
511: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
512: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
513: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
514:
515: counter := 1;
516: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
517: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
512: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
513: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
514:
515: counter := 1;
516: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
517: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
518: l_pubitems_tbl(counter) := l_store;
519: counter := counter +1;
520: END LOOP;
513: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
514:
515: counter := 1;
516: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
517: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
518: l_pubitems_tbl(counter) := l_store;
519: counter := counter +1;
520: END LOOP;
521:
518: l_pubitems_tbl(counter) := l_store;
519: counter := counter +1;
520: END LOOP;
521:
522: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
523:
524: FOR curr_index IN 1..l_pubitems_tbl.count LOOP
525: curr_pubitem := l_pubitems_tbl(curr_index);
526: compact_curr_inqtable(p_user_name, p_start_tranid, p_end_tranid,
547: 'tranid$$ NOT IN ' ||
548: '(SELECT tranid ' ||
549: ' FROM asg_users_inqinfo ' ||
550: ' WHERE device_user_name = :user_name)';
551: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
552: DBMS_SQL.PARSE (l_cursor_id, l_select_tranid_sqlstring, DBMS_SQL.v7);
553: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
554: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
555: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
548: '(SELECT tranid ' ||
549: ' FROM asg_users_inqinfo ' ||
550: ' WHERE device_user_name = :user_name)';
551: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
552: DBMS_SQL.PARSE (l_cursor_id, l_select_tranid_sqlstring, DBMS_SQL.v7);
553: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
554: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
555: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
556:
549: ' FROM asg_users_inqinfo ' ||
550: ' WHERE device_user_name = :user_name)';
551: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
552: DBMS_SQL.PARSE (l_cursor_id, l_select_tranid_sqlstring, DBMS_SQL.v7);
553: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
554: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
555: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
556:
557: counter := 1;
550: ' WHERE device_user_name = :user_name)';
551: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
552: DBMS_SQL.PARSE (l_cursor_id, l_select_tranid_sqlstring, DBMS_SQL.v7);
553: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
554: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
555: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
556:
557: counter := 1;
558: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
551: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
552: DBMS_SQL.PARSE (l_cursor_id, l_select_tranid_sqlstring, DBMS_SQL.v7);
553: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
554: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
555: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
556:
557: counter := 1;
558: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
559: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_tranid);
554: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
555: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
556:
557: counter := 1;
558: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
559: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_tranid);
560: l_tranids_tbl(counter) := l_tranid;
561: counter := counter +1;
562: END LOOP;
555: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
556:
557: counter := 1;
558: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
559: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_tranid);
560: l_tranids_tbl(counter) := l_tranid;
561: counter := counter +1;
562: END LOOP;
563:
560: l_tranids_tbl(counter) := l_tranid;
561: counter := counter +1;
562: END LOOP;
563:
564: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
565: END get_new_tranids;
566:
567: -- Returns the list of all clients with the specified inq record types
568: -- dirty for unprocessed new records
690: 'WHERE clid$$cs = :1 AND ' ||
691: ' tranid$$ = :2 '||
692: ' ORDER BY store';
693:
694: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
695: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
696: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
697: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
698: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
691: ' tranid$$ = :2 '||
692: ' ORDER BY store';
693:
694: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
695: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
696: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
697: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
698: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
699: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
692: ' ORDER BY store';
693:
694: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
695: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
696: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
697: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
698: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
699: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
700:
693:
694: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
695: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
696: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
697: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
698: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
699: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
700:
701: counter := 1;
694: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
695: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
696: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
697: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
698: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
699: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
700:
701: counter := 1;
702: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
695: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
696: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
697: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
698: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
699: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
700:
701: counter := 1;
702: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
703: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
698: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
699: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
700:
701: counter := 1;
702: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
703: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
704: x_pubitems_tbl(counter) := l_store;
705: counter := counter +1;
706: END LOOP;
699: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
700:
701: counter := 1;
702: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
703: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
704: x_pubitems_tbl(counter) := l_store;
705: counter := counter +1;
706: END LOOP;
707:
704: x_pubitems_tbl(counter) := l_store;
705: counter := counter +1;
706: END LOOP;
707:
708: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
709:
710: IF (x_pubitems_tbl IS NULL) THEN
711: counter :=1;
712: ELSE
724: ' WHERE clid$$cs = :user_name AND ' ||
725: ' tranid$$ = :tranid) ' ||
726: ' ORDER BY object_name';
727:
728: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
729: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
730: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
731: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
732:
725: ' tranid$$ = :tranid) ' ||
726: ' ORDER BY object_name';
727:
728: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
729: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
730: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
731: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
732:
733: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
726: ' ORDER BY object_name';
727:
728: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
729: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
730: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
731: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
732:
733: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
734: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
727:
728: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
729: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
730: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
731: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
732:
733: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
734: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
735:
729: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
730: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
731: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
732:
733: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
734: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
735:
736: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
737: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
730: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
731: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
732:
733: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
734: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
735:
736: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
737: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
738: x_pubitems_tbl(counter) := l_obj_name;
732:
733: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
734: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
735:
736: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
737: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
738: x_pubitems_tbl(counter) := l_obj_name;
739: counter := counter +1;
740: END LOOP;
733: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
734: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
735:
736: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
737: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
738: x_pubitems_tbl(counter) := l_obj_name;
739: counter := counter +1;
740: END LOOP;
741:
738: x_pubitems_tbl(counter) := l_obj_name;
739: counter := counter +1;
740: END LOOP;
741:
742: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
743:
744: END get_all_pub_items;
745:
746: -- get the names of all publication items that have
779: ' FROM asg_pub_item ' ||
780: ' WHERE pub_name = :3) ' ||
781: ' ORDER BY store';
782:
783: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
784: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
785: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
786: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
787: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
780: ' WHERE pub_name = :3) ' ||
781: ' ORDER BY store';
782:
783: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
784: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
785: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
786: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
787: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
788: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
781: ' ORDER BY store';
782:
783: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
784: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
785: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
786: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
787: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
788: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
789: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
782:
783: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
784: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
785: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
786: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
787: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
788: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
789: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
790:
783: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
784: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
785: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
786: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
787: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
788: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
789: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
790:
791: counter := 1;
784: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
785: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
786: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
787: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
788: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
789: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
790:
791: counter := 1;
792: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
785: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
786: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
787: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
788: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
789: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
790:
791: counter := 1;
792: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
793: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
788: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
789: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
790:
791: counter := 1;
792: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
793: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
794: x_pubitems_tbl(counter) := l_store;
795: counter := counter +1;
796: END LOOP;
789: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
790:
791: counter := 1;
792: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
793: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
794: x_pubitems_tbl(counter) := l_store;
795: counter := counter +1;
796: END LOOP;
797:
794: x_pubitems_tbl(counter) := l_store;
795: counter := counter +1;
796: END LOOP;
797:
798: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
799:
800: IF (x_pubitems_tbl IS NULL) THEN
801: counter :=1;
802: ELSE
818: ' WHERE clid$$cs = :user_name AND ' ||
819: ' tranid$$ = :tranid) ' ||
820: ' ORDER BY object_name';
821:
822: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
823: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
826: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
819: ' tranid$$ = :tranid) ' ||
820: ' ORDER BY object_name';
821:
822: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
823: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
826: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
827:
820: ' ORDER BY object_name';
821:
822: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
823: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
826: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
827:
828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
821:
822: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
823: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
826: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
827:
828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
822: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
823: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
826: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
827:
828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
830:
824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
826: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
827:
828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
830:
831: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
832: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
826: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
827:
828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
830:
831: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
832: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
833: x_pubitems_tbl(counter) := l_obj_name;
827:
828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
830:
831: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
832: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
833: x_pubitems_tbl(counter) := l_obj_name;
834: counter := counter +1;
835: END LOOP;
828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
830:
831: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
832: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
833: x_pubitems_tbl(counter) := l_obj_name;
834: counter := counter +1;
835: END LOOP;
836:
833: x_pubitems_tbl(counter) := l_obj_name;
834: counter := counter +1;
835: END LOOP;
836:
837: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
838:
839: sort_by_weight(p_pubname, x_pubitems_tbl);
840:
841: END get_all_pub_items;
877: ' FROM asg_pub_item ' ||
878: ' WHERE pub_name = :5) ' ||
879: ' ORDER BY store';
880:
881: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
882: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
883: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
884: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
885: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
878: ' WHERE pub_name = :5) ' ||
879: ' ORDER BY store';
880:
881: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
882: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
883: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
884: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
885: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
886: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
879: ' ORDER BY store';
880:
881: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
882: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
883: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
884: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
885: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
886: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
887: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
880:
881: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
882: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
883: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
884: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
885: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
886: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
887: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
888: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
881: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
882: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
883: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
884: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
885: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
886: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
887: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
888: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
889: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
882: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
883: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
884: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
885: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
886: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
887: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
888: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
889: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
890:
883: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
884: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
885: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
886: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
887: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
888: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
889: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
890:
891: counter := 1;
884: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
885: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
886: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
887: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
888: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
889: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
890:
891: counter := 1;
892: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
885: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
886: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
887: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
888: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
889: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
890:
891: counter := 1;
892: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
893: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
888: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
889: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
890:
891: counter := 1;
892: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
893: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
894: x_pubitems_tbl(counter) := l_store;
895: counter := counter +1;
896: END LOOP;
889: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
890:
891: counter := 1;
892: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
893: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
894: x_pubitems_tbl(counter) := l_store;
895: counter := counter +1;
896: END LOOP;
897:
894: x_pubitems_tbl(counter) := l_store;
895: counter := counter +1;
896: END LOOP;
897:
898: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
899:
900: sort_by_weight(p_pubname, x_pubitems_tbl);
901:
902: END get_all_dirty_pub_items;
1366: 'WHERE clid$$cs = :1 AND ' ||
1367: ' tranid$$ = :2 ' ||
1368: ' ORDER BY store';
1369:
1370: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1371: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1372: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1373: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1374: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1367: ' tranid$$ = :2 ' ||
1368: ' ORDER BY store';
1369:
1370: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1371: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1372: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1373: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1374: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1375: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1368: ' ORDER BY store';
1369:
1370: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1371: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1372: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1373: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1374: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1375: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1376:
1369:
1370: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1371: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1372: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1373: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1374: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1375: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1376:
1377: counter := 1;
1370: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1371: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1372: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1373: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1374: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1375: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1376:
1377: counter := 1;
1378: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1371: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1372: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1373: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1374: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1375: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1376:
1377: counter := 1;
1378: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1379: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1374: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1375: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1376:
1377: counter := 1;
1378: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1379: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1380: l_pubitems_tbl(counter) := l_store;
1381: counter := counter +1;
1382: END LOOP;
1375: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1376:
1377: counter := 1;
1378: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1379: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1380: l_pubitems_tbl(counter) := l_store;
1381: counter := counter +1;
1382: END LOOP;
1383:
1380: l_pubitems_tbl(counter) := l_store;
1381: counter := counter +1;
1382: END LOOP;
1383:
1384: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
1385:
1386: -- Found some dirty pub-items for this
1387: IF (l_pubitems_tbl IS NOT NULL) AND
1388: (l_pubitems_tbl.count > 0) THEN
1542: l_select_users_sqlstring :=
1543: 'SELECT distinct clid$$cs clientid ' ||
1544: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq';
1545:
1546: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1547: DBMS_SQL.PARSE (l_cursor_id, l_select_users_sqlstring, DBMS_SQL.v7);
1548: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_user_name, 30);
1549: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1550:
1543: 'SELECT distinct clid$$cs clientid ' ||
1544: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq';
1545:
1546: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1547: DBMS_SQL.PARSE (l_cursor_id, l_select_users_sqlstring, DBMS_SQL.v7);
1548: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_user_name, 30);
1549: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1550:
1551: counter := 1;
1544: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq';
1545:
1546: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1547: DBMS_SQL.PARSE (l_cursor_id, l_select_users_sqlstring, DBMS_SQL.v7);
1548: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_user_name, 30);
1549: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1550:
1551: counter := 1;
1552: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1545:
1546: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1547: DBMS_SQL.PARSE (l_cursor_id, l_select_users_sqlstring, DBMS_SQL.v7);
1548: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_user_name, 30);
1549: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1550:
1551: counter := 1;
1552: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1553: IF counter =1 THEN
1548: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_user_name, 30);
1549: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1550:
1551: counter := 1;
1552: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1553: IF counter =1 THEN
1554: log('begin_apply: Following users have uploaded new data',g_stmt_level);
1555: END IF;
1556: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_user_name);
1552: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1553: IF counter =1 THEN
1554: log('begin_apply: Following users have uploaded new data',g_stmt_level);
1555: END IF;
1556: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_user_name);
1557: l_users_tbl(counter) := l_user_name;
1558: log('begin_apply: ' || l_users_tbl(counter),g_stmt_level);
1559: counter := counter +1;
1560: END LOOP;
1558: log('begin_apply: ' || l_users_tbl(counter),g_stmt_level);
1559: counter := counter +1;
1560: END LOOP;
1561:
1562: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
1563:
1564: IF counter = 1 THEN
1565: log('begin_apply: Did not find any user with dirty data',g_stmt_level);
1566: OPEN c_deferred;
1635: 'b.store = :seq_name AND ' ||
1636: 'a.clid$$cs = b.clid$$cs AND ' ||
1637: 'a.tranid$$ = b.tranid$$';
1638:
1639: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1640: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1641: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1642: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1643: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1636: 'a.clid$$cs = b.clid$$cs AND ' ||
1637: 'a.tranid$$ = b.tranid$$';
1638:
1639: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1640: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1641: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1642: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1643: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1644:
1637: 'a.tranid$$ = b.tranid$$';
1638:
1639: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1640: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1641: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1642: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1643: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1644:
1645: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1638:
1639: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1640: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1641: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1642: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1643: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1644:
1645: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1646: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1639: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1640: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1641: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1642: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1643: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1644:
1645: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1646: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1647: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1641: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1642: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1643: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1644:
1645: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1646: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1647: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1648:
1649: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1642: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1643: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1644:
1645: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1646: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1647: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1648:
1649: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1650: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1643: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1644:
1645: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1646: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1647: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1648:
1649: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1650: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1651: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1645: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1646: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1647: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1648:
1649: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1650: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1651: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1652:
1653: IF(MOD(l_curr_val, 1000000) = l_client_num) THEN
1646: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1647: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1648:
1649: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1650: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1651: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1652:
1653: IF(MOD(l_curr_val, 1000000) = l_client_num) THEN
1654: l_update_seq_sqlstring := 'UPDATE asg_sequence_partitions ' ||
1647: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1648:
1649: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1650: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1651: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1652:
1653: IF(MOD(l_curr_val, 1000000) = l_client_num) THEN
1654: l_update_seq_sqlstring := 'UPDATE asg_sequence_partitions ' ||
1655: 'SET curr_val = :1 ' ||
1670: log ('Updating sequence for user: ' || p_user_name ||
1671: ' sequence: ' || l_seq_name);
1672: END LOOP;
1673:
1674: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
1675: IF counter =1 THEN
1676: log('No sequences need to be updated',g_stmt_level);
1677: END IF;
1678:
1795: 'WHERE clid$$cs = :1 AND ' ||
1796: ' tranid$$ = :2 ' ||
1797: ' ORDER BY store';
1798:
1799: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1800: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1801: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1802: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1803: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1796: ' tranid$$ = :2 ' ||
1797: ' ORDER BY store';
1798:
1799: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1800: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1801: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1802: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1803: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1804: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1797: ' ORDER BY store';
1798:
1799: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1800: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1801: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1802: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1803: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1804: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1805:
1798:
1799: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1800: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1801: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1802: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1803: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1804: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1805:
1806: counter := 1;
1799: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1800: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1801: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1802: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1803: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1804: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1805:
1806: counter := 1;
1807: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1800: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1801: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1802: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1803: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1804: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1805:
1806: counter := 1;
1807: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1808: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1803: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1804: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1805:
1806: counter := 1;
1807: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1808: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1809: l_pubitems_tbl(counter) := l_store;
1810: counter := counter +1;
1811: END LOOP;
1804: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1805:
1806: counter := 1;
1807: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1808: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1809: l_pubitems_tbl(counter) := l_store;
1810: counter := counter +1;
1811: END LOOP;
1812:
1809: l_pubitems_tbl(counter) := l_store;
1810: counter := counter +1;
1811: END LOOP;
1812:
1813: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
1814: --12.1
1815: counter := 1;
1816: counter2:= 1;
1817: FOR curr_index2 IN 1..l_pubitems_tbl.count LOOP
1935: ' asg_pub b ' ||
1936: 'WHERE a.clientid = :user_name AND ' ||
1937: ' a.template = b.name';
1938:
1939: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1940: DBMS_SQL.PARSE (l_cursor_id, l_select_pub_sqlstring, DBMS_SQL.v7);
1941: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1942:
1943: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
1936: 'WHERE a.clientid = :user_name AND ' ||
1937: ' a.template = b.name';
1938:
1939: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1940: DBMS_SQL.PARSE (l_cursor_id, l_select_pub_sqlstring, DBMS_SQL.v7);
1941: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1942:
1943: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
1944: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
1937: ' a.template = b.name';
1938:
1939: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1940: DBMS_SQL.PARSE (l_cursor_id, l_select_pub_sqlstring, DBMS_SQL.v7);
1941: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1942:
1943: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
1944: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
1945: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1939: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1940: DBMS_SQL.PARSE (l_cursor_id, l_select_pub_sqlstring, DBMS_SQL.v7);
1941: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1942:
1943: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
1944: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
1945: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1946:
1947: counter :=1;
1940: DBMS_SQL.PARSE (l_cursor_id, l_select_pub_sqlstring, DBMS_SQL.v7);
1941: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1942:
1943: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
1944: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
1945: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1946:
1947: counter :=1;
1948: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1941: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1942:
1943: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
1944: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
1945: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1946:
1947: counter :=1;
1948: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1949: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
1944: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
1945: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1946:
1947: counter :=1;
1948: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1949: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
1950: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_wrapper_name);
1951: l_userpub_tbl(counter) := l_pub_name;
1952: l_pubhandler_tbl(counter) := l_wrapper_name;
1945: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1946:
1947: counter :=1;
1948: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1949: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
1950: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_wrapper_name);
1951: l_userpub_tbl(counter) := l_pub_name;
1952: l_pubhandler_tbl(counter) := l_wrapper_name;
1953: counter := counter +1;
1946:
1947: counter :=1;
1948: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1949: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
1950: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_wrapper_name);
1951: l_userpub_tbl(counter) := l_pub_name;
1952: l_pubhandler_tbl(counter) := l_wrapper_name;
1953: counter := counter +1;
1954: END LOOP;
1952: l_pubhandler_tbl(counter) := l_wrapper_name;
1953: counter := counter +1;
1954: END LOOP;
1955:
1956: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
1957:
1958: -- User is subscribed to atleast one publication we know of
1959: IF counter >1 THEN
1960: FOR curr_index IN 1..l_userpub_tbl.count LOOP