285: 'WHERE clid$$cs = :1 AND ' ||
286: ' tranid$$ = :2 ' ||
287: ' ORDER BY store';
288:
289: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
290: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
291: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
292: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
293: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
286: ' tranid$$ = :2 ' ||
287: ' ORDER BY store';
288:
289: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
290: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
291: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
292: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
293: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
294: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
287: ' ORDER BY store';
288:
289: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
290: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
291: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
292: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
293: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
294: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
295:
288:
289: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
290: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
291: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
292: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
293: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
294: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
295:
296: counter := 1;
289: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
290: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
291: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
292: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
293: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
294: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
295:
296: counter := 1;
297: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
290: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
291: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
292: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
293: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
294: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
295:
296: counter := 1;
297: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
298: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
293: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
294: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
295:
296: counter := 1;
297: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
298: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
299: l_pubitems_tbl(counter) := l_store;
300: counter := counter +1;
301: END LOOP;
294: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
295:
296: counter := 1;
297: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
298: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
299: l_pubitems_tbl(counter) := l_store;
300: counter := counter +1;
301: END LOOP;
302:
299: l_pubitems_tbl(counter) := l_store;
300: counter := counter +1;
301: END LOOP;
302:
303: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
304:
305: counter := 1;
306: counter2:= 1;
307: FOR curr_index2 IN 1..l_pubitems_tbl.count LOOP
509: ' tranid$$ = :2 AND ' ||
510: ' store in (select item_id from asg_pub_item) ' ||
511: ' ORDER BY store';
512:
513: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
514: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
515: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
516: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
517: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
510: ' store in (select item_id from asg_pub_item) ' ||
511: ' ORDER BY store';
512:
513: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
514: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
515: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
516: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
517: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
518: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
511: ' ORDER BY store';
512:
513: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
514: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
515: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
516: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
517: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
518: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
519:
512:
513: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
514: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
515: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
516: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
517: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
518: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
519:
520: counter := 1;
513: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
514: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
515: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
516: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
517: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
518: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
519:
520: counter := 1;
521: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
514: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
515: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
516: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
517: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
518: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
519:
520: counter := 1;
521: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
522: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
517: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_compact_tranid);
518: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
519:
520: counter := 1;
521: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
522: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
523: l_pubitems_tbl(counter) := l_store;
524: counter := counter +1;
525: END LOOP;
518: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
519:
520: counter := 1;
521: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
522: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
523: l_pubitems_tbl(counter) := l_store;
524: counter := counter +1;
525: END LOOP;
526:
523: l_pubitems_tbl(counter) := l_store;
524: counter := counter +1;
525: END LOOP;
526:
527: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
528:
529: FOR curr_index IN 1..l_pubitems_tbl.count LOOP
530: curr_pubitem := l_pubitems_tbl(curr_index);
531: compact_curr_inqtable(p_user_name, p_start_tranid, p_end_tranid,
552: 'tranid$$ NOT IN ' ||
553: '(SELECT tranid ' ||
554: ' FROM asg_users_inqinfo ' ||
555: ' WHERE device_user_name = :user_name)';
556: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
557: DBMS_SQL.PARSE (l_cursor_id, l_select_tranid_sqlstring, DBMS_SQL.v7);
558: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
559: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
560: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
553: '(SELECT tranid ' ||
554: ' FROM asg_users_inqinfo ' ||
555: ' WHERE device_user_name = :user_name)';
556: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
557: DBMS_SQL.PARSE (l_cursor_id, l_select_tranid_sqlstring, DBMS_SQL.v7);
558: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
559: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
560: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
561:
554: ' FROM asg_users_inqinfo ' ||
555: ' WHERE device_user_name = :user_name)';
556: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
557: DBMS_SQL.PARSE (l_cursor_id, l_select_tranid_sqlstring, DBMS_SQL.v7);
558: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
559: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
560: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
561:
562: counter := 1;
555: ' WHERE device_user_name = :user_name)';
556: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
557: DBMS_SQL.PARSE (l_cursor_id, l_select_tranid_sqlstring, DBMS_SQL.v7);
558: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
559: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
560: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
561:
562: counter := 1;
563: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
556: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
557: DBMS_SQL.PARSE (l_cursor_id, l_select_tranid_sqlstring, DBMS_SQL.v7);
558: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
559: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
560: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
561:
562: counter := 1;
563: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
564: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_tranid);
559: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_tranid);
560: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
561:
562: counter := 1;
563: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
564: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_tranid);
565: l_tranids_tbl(counter) := l_tranid;
566: counter := counter +1;
567: END LOOP;
560: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
561:
562: counter := 1;
563: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
564: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_tranid);
565: l_tranids_tbl(counter) := l_tranid;
566: counter := counter +1;
567: END LOOP;
568:
565: l_tranids_tbl(counter) := l_tranid;
566: counter := counter +1;
567: END LOOP;
568:
569: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
570: END get_new_tranids;
571:
572: -- Returns the list of all clients with the specified inq record types
573: -- dirty for unprocessed new records
696: ' tranid$$ = :2 AND '||
697: ' store in (select item_id from asg_pub_item) ' ||
698: ' ORDER BY store';
699:
700: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
701: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
702: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
703: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
704: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
697: ' store in (select item_id from asg_pub_item) ' ||
698: ' ORDER BY store';
699:
700: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
701: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
702: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
703: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
704: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
705: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
698: ' ORDER BY store';
699:
700: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
701: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
702: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
703: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
704: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
705: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
706:
699:
700: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
701: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
702: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
703: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
704: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
705: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
706:
707: counter := 1;
700: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
701: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
702: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
703: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
704: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
705: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
706:
707: counter := 1;
708: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
701: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
702: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
703: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
704: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
705: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
706:
707: counter := 1;
708: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
709: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
704: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
705: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
706:
707: counter := 1;
708: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
709: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
710: x_pubitems_tbl(counter) := l_store;
711: counter := counter +1;
712: END LOOP;
705: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
706:
707: counter := 1;
708: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
709: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
710: x_pubitems_tbl(counter) := l_store;
711: counter := counter +1;
712: END LOOP;
713:
710: x_pubitems_tbl(counter) := l_store;
711: counter := counter +1;
712: END LOOP;
713:
714: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
715:
716: IF (x_pubitems_tbl IS NULL) THEN
717: counter :=1;
718: ELSE
730: ' WHERE clid$$cs = :user_name AND ' ||
731: ' tranid$$ = :tranid) ' ||
732: ' ORDER BY object_name';
733:
734: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
735: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
736: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
737: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
738:
731: ' tranid$$ = :tranid) ' ||
732: ' ORDER BY object_name';
733:
734: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
735: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
736: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
737: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
738:
739: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
732: ' ORDER BY object_name';
733:
734: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
735: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
736: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
737: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
738:
739: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
740: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
733:
734: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
735: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
736: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
737: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
738:
739: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
740: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
741:
735: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
736: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
737: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
738:
739: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
740: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
741:
742: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
743: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
736: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
737: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
738:
739: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
740: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
741:
742: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
743: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
744: x_pubitems_tbl(counter) := l_obj_name;
738:
739: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
740: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
741:
742: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
743: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
744: x_pubitems_tbl(counter) := l_obj_name;
745: counter := counter +1;
746: END LOOP;
739: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
740: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
741:
742: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
743: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
744: x_pubitems_tbl(counter) := l_obj_name;
745: counter := counter +1;
746: END LOOP;
747:
744: x_pubitems_tbl(counter) := l_obj_name;
745: counter := counter +1;
746: END LOOP;
747:
748: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
749:
750: END get_all_pub_items;
751:
752: -- get the names of all publication items that have
785: ' FROM asg_pub_item ' ||
786: ' WHERE pub_name = :3) ' ||
787: ' ORDER BY store';
788:
789: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
790: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
791: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
792: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
793: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
786: ' WHERE pub_name = :3) ' ||
787: ' ORDER BY store';
788:
789: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
790: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
791: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
792: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
793: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
794: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
787: ' ORDER BY store';
788:
789: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
790: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
791: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
792: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
793: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
794: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
795: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
788:
789: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
790: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
791: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
792: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
793: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
794: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
795: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
796:
789: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
790: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
791: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
792: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
793: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
794: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
795: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
796:
797: counter := 1;
790: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
791: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
792: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
793: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
794: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
795: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
796:
797: counter := 1;
798: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
791: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
792: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
793: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
794: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
795: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
796:
797: counter := 1;
798: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
799: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
794: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_pubname);
795: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
796:
797: counter := 1;
798: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
799: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
800: x_pubitems_tbl(counter) := l_store;
801: counter := counter +1;
802: END LOOP;
795: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
796:
797: counter := 1;
798: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
799: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
800: x_pubitems_tbl(counter) := l_store;
801: counter := counter +1;
802: END LOOP;
803:
800: x_pubitems_tbl(counter) := l_store;
801: counter := counter +1;
802: END LOOP;
803:
804: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
805:
806: IF (x_pubitems_tbl IS NULL) THEN
807: counter :=1;
808: ELSE
824: ' WHERE clid$$cs = :user_name AND ' ||
825: ' tranid$$ = :tranid) ' ||
826: ' ORDER BY object_name';
827:
828: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
829: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
830: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
831: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
832: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
825: ' tranid$$ = :tranid) ' ||
826: ' ORDER BY object_name';
827:
828: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
829: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
830: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
831: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
832: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
833:
826: ' ORDER BY object_name';
827:
828: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
829: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
830: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
831: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
832: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
833:
834: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
827:
828: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
829: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
830: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
831: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
832: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
833:
834: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
835: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
828: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
829: DBMS_SQL.PARSE (l_cursor_id, l_select_obj_sqlstring, DBMS_SQL.v7);
830: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
831: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
832: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
833:
834: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
835: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
836:
830: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
831: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
832: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
833:
834: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
835: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
836:
837: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
838: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
831: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
832: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':pubname', p_pubname );
833:
834: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
835: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
836:
837: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
838: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
839: x_pubitems_tbl(counter) := l_obj_name;
833:
834: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
835: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
836:
837: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
838: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
839: x_pubitems_tbl(counter) := l_obj_name;
840: counter := counter +1;
841: END LOOP;
834: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_obj_name, 30);
835: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
836:
837: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
838: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_obj_name);
839: x_pubitems_tbl(counter) := l_obj_name;
840: counter := counter +1;
841: END LOOP;
842:
839: x_pubitems_tbl(counter) := l_obj_name;
840: counter := counter +1;
841: END LOOP;
842:
843: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
844:
845: sort_by_weight(p_pubname, x_pubitems_tbl);
846:
847: END get_all_pub_items;
883: ' FROM asg_pub_item ' ||
884: ' WHERE pub_name = :5) ' ||
885: ' ORDER BY store';
886:
887: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
888: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
889: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
890: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
891: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
884: ' WHERE pub_name = :5) ' ||
885: ' ORDER BY store';
886:
887: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
888: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
889: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
890: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
891: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
892: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
885: ' ORDER BY store';
886:
887: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
888: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
889: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
890: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
891: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
892: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
893: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
886:
887: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
888: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
889: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
890: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
891: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
892: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
893: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
894: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
887: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
888: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
889: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
890: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
891: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
892: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
893: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
894: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
895: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
888: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
889: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
890: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
891: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
892: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
893: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
894: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
895: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
896:
889: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
890: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
891: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
892: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
893: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
894: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
895: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
896:
897: counter := 1;
890: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
891: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
892: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
893: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
894: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
895: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
896:
897: counter := 1;
898: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
891: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
892: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':3', p_user_name);
893: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':4', p_tranid);
894: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
895: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
896:
897: counter := 1;
898: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
899: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
894: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':5', p_pubname);
895: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
896:
897: counter := 1;
898: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
899: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
900: x_pubitems_tbl(counter) := l_store;
901: counter := counter +1;
902: END LOOP;
895: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
896:
897: counter := 1;
898: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
899: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
900: x_pubitems_tbl(counter) := l_store;
901: counter := counter +1;
902: END LOOP;
903:
900: x_pubitems_tbl(counter) := l_store;
901: counter := counter +1;
902: END LOOP;
903:
904: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
905:
906: sort_by_weight(p_pubname, x_pubitems_tbl);
907:
908: END get_all_dirty_pub_items;
1379: ' tranid$$ = :2 AND ' ||
1380: ' store in (select item_id from asg_pub_item) ' ||
1381: ' ORDER BY store';
1382:
1383: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1384: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1385: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1386: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1387: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1380: ' store in (select item_id from asg_pub_item) ' ||
1381: ' ORDER BY store';
1382:
1383: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1384: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1385: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1386: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1387: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1388: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1381: ' ORDER BY store';
1382:
1383: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1384: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1385: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1386: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1387: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1388: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1389:
1382:
1383: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1384: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1385: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1386: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1387: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1388: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1389:
1390: counter := 1;
1383: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1384: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1385: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1386: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1387: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1388: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1389:
1390: counter := 1;
1391: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1384: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1385: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1386: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1387: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1388: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1389:
1390: counter := 1;
1391: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1392: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1387: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1388: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1389:
1390: counter := 1;
1391: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1392: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1393: l_pubitems_tbl(counter) := l_store;
1394: counter := counter +1;
1395: END LOOP;
1388: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1389:
1390: counter := 1;
1391: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1392: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1393: l_pubitems_tbl(counter) := l_store;
1394: counter := counter +1;
1395: END LOOP;
1396:
1393: l_pubitems_tbl(counter) := l_store;
1394: counter := counter +1;
1395: END LOOP;
1396:
1397: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
1398:
1399: -- Found some dirty pub-items for this
1400: IF (l_pubitems_tbl IS NOT NULL) AND
1401: (l_pubitems_tbl.count > 0) THEN
1556: 'SELECT distinct clid$$cs clientid ' ||
1557: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ' ||
1558: ' WHERE store in (select item_id from asg_pub_item) ';
1559:
1560: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1561: DBMS_SQL.PARSE (l_cursor_id, l_select_users_sqlstring, DBMS_SQL.v7);
1562: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_user_name, 100);
1563: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1564:
1557: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ' ||
1558: ' WHERE store in (select item_id from asg_pub_item) ';
1559:
1560: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1561: DBMS_SQL.PARSE (l_cursor_id, l_select_users_sqlstring, DBMS_SQL.v7);
1562: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_user_name, 100);
1563: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1564:
1565: counter := 1;
1558: ' WHERE store in (select item_id from asg_pub_item) ';
1559:
1560: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1561: DBMS_SQL.PARSE (l_cursor_id, l_select_users_sqlstring, DBMS_SQL.v7);
1562: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_user_name, 100);
1563: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1564:
1565: counter := 1;
1566: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1559:
1560: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1561: DBMS_SQL.PARSE (l_cursor_id, l_select_users_sqlstring, DBMS_SQL.v7);
1562: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_user_name, 100);
1563: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1564:
1565: counter := 1;
1566: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1567: IF counter =1 THEN
1562: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_user_name, 100);
1563: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1564:
1565: counter := 1;
1566: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1567: IF counter =1 THEN
1568: log('begin_apply: Following users have uploaded new data',g_stmt_level);
1569: END IF;
1570: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_user_name);
1566: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1567: IF counter =1 THEN
1568: log('begin_apply: Following users have uploaded new data',g_stmt_level);
1569: END IF;
1570: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_user_name);
1571: l_users_tbl(counter) := l_user_name;
1572: log('begin_apply: ' || l_users_tbl(counter),g_stmt_level);
1573: counter := counter +1;
1574: END LOOP;
1572: log('begin_apply: ' || l_users_tbl(counter),g_stmt_level);
1573: counter := counter +1;
1574: END LOOP;
1575:
1576: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
1577:
1578: IF counter = 1 THEN
1579: log('begin_apply: Did not find any user with dirty data',g_stmt_level);
1580: OPEN c_deferred;
1710: 'b.store = :seq_name AND ' ||
1711: 'a.clid$$cs = b.clid$$cs AND ' ||
1712: 'a.tranid$$ = b.tranid$$';
1713:
1714: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1715: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1716: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1717: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1718: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1711: 'a.clid$$cs = b.clid$$cs AND ' ||
1712: 'a.tranid$$ = b.tranid$$';
1713:
1714: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1715: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1716: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1717: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1718: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1719:
1712: 'a.tranid$$ = b.tranid$$';
1713:
1714: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1715: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1716: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1717: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1718: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1719:
1720: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1713:
1714: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1715: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1716: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1717: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1718: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1719:
1720: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1721: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1714: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1715: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1716: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1717: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1718: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1719:
1720: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1721: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1722: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1716: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1717: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1718: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1719:
1720: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1721: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1722: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1723:
1724: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1717: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1718: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1719:
1720: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1721: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1722: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1723:
1724: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1725: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1718: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1719:
1720: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1721: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1722: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1723:
1724: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1725: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1726: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1720: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1721: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1722: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1723:
1724: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1725: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1726: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1727:
1728: IF(MOD(l_curr_val, 1000000) = l_client_num) THEN
1721: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1722: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1723:
1724: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1725: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1726: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1727:
1728: IF(MOD(l_curr_val, 1000000) = l_client_num) THEN
1729: l_update_seq_sqlstring := 'UPDATE asg_sequence_partitions ' ||
1722: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1723:
1724: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1725: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1726: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1727:
1728: IF(MOD(l_curr_val, 1000000) = l_client_num) THEN
1729: l_update_seq_sqlstring := 'UPDATE asg_sequence_partitions ' ||
1730: 'SET curr_val = :1 ' ||
1745: log ('process_sequences_bc:Updating sequence for user: ' || p_user_name ||
1746: ' sequence: ' || l_seq_name);
1747: END LOOP;
1748:
1749: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
1750: IF counter =1 THEN
1751: log('process_sequences_bc: No sequences need to be updated',g_stmt_level);
1752: END IF;
1753:
1817: 'b.store = :seq_name AND ' ||
1818: 'a.clid$$cs = b.clid$$cs AND ' ||
1819: 'a.tranid$$ = b.tranid$$';
1820:
1821: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1822: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1823: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1818: 'a.clid$$cs = b.clid$$cs AND ' ||
1819: 'a.tranid$$ = b.tranid$$';
1820:
1821: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1822: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1823: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1826:
1819: 'a.tranid$$ = b.tranid$$';
1820:
1821: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1822: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1823: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1826:
1827: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1820:
1821: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1822: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1823: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1826:
1827: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1821: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1822: DBMS_SQL.PARSE (l_cursor_id, l_select_seq_sqlstring, DBMS_SQL.v7);
1823: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1826:
1827: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1823: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
1824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1826:
1827: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1830:
1831: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1824: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':tranid', p_tranid );
1825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1826:
1827: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1830:
1831: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1832: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1825: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':seq_name', l_sequence );
1826:
1827: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1830:
1831: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1832: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1833: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1827: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_seq_name, 30);
1828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1830:
1831: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1832: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1833: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1834:
1835: IF(MOD(l_curr_val, 1000000) = l_client_num) THEN
1828: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_curr_val);
1829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1830:
1831: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1832: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1833: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1834:
1835: IF(MOD(l_curr_val, 1000000) = l_client_num) THEN
1836: l_update_seq_sqlstring := 'UPDATE asg_sequence_partitions ' ||
1829: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1830:
1831: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1832: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_seq_name);
1833: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_curr_val);
1834:
1835: IF(MOD(l_curr_val, 1000000) = l_client_num) THEN
1836: l_update_seq_sqlstring := 'UPDATE asg_sequence_partitions ' ||
1837: 'SET curr_val = :1 ' ||
1852: log ('Updating sequence for user: ' || p_user_name ||
1853: ' sequence: ' || l_seq_name);
1854: END LOOP;
1855:
1856: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
1857: IF counter =1 THEN
1858: log('No sequences need to be updated',g_stmt_level);
1859: END IF;
1860:
1984: ' AND NOT EXISTS (SELECT 1 FROM asg_users_inqarchive ' ||
1985: ' WHERE device_user_name = ci.clid$$cs AND TRANID =ci.tranid$$) '||
1986: ' ORDER BY store';
1987:
1988: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1989: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1990: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1991: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1992: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1985: ' WHERE device_user_name = ci.clid$$cs AND TRANID =ci.tranid$$) '||
1986: ' ORDER BY store';
1987:
1988: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1989: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1990: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1991: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1992: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1993: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1986: ' ORDER BY store';
1987:
1988: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1989: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1990: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1991: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1992: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1993: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1994:
1987:
1988: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1989: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1990: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1991: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1992: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1993: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1994:
1995: counter := 1;
1988: l_cursor_id1 := DBMS_SQL.OPEN_CURSOR;
1989: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1990: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1991: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1992: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1993: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1994:
1995: counter := 1;
1996: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1989: DBMS_SQL.PARSE (l_cursor_id1, l_select_store_sqlstring, DBMS_SQL.v7);
1990: DBMS_SQL.DEFINE_COLUMN (l_cursor_id1, 1, l_store, 30);
1991: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':1', p_user_name);
1992: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1993: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1994:
1995: counter := 1;
1996: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1997: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1992: DBMS_SQL.BIND_VARIABLE(l_cursor_id1, ':2', p_tranid);
1993: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1994:
1995: counter := 1;
1996: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1997: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1998: l_pubitems_tbl(counter) := l_store;
1999: counter := counter +1;
2000: END LOOP;
1993: l_cursor_ret1 := DBMS_SQL.EXECUTE (l_cursor_id1);
1994:
1995: counter := 1;
1996: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id1) > 0 ) LOOP
1997: DBMS_SQL.COLUMN_VALUE (l_cursor_id1, 1, l_store);
1998: l_pubitems_tbl(counter) := l_store;
1999: counter := counter +1;
2000: END LOOP;
2001:
1998: l_pubitems_tbl(counter) := l_store;
1999: counter := counter +1;
2000: END LOOP;
2001:
2002: DBMS_SQL.CLOSE_CURSOR(l_cursor_id1);
2003: --12.1
2004: counter := 1;
2005: counter2:= 1;
2006: FOR curr_index2 IN 1..l_pubitems_tbl.count LOOP
2124: ' asg_pub b ' ||
2125: 'WHERE a.clientid = :user_name AND ' ||
2126: ' a.template = b.name';
2127:
2128: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
2129: DBMS_SQL.PARSE (l_cursor_id, l_select_pub_sqlstring, DBMS_SQL.v7);
2130: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
2131:
2132: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
2125: 'WHERE a.clientid = :user_name AND ' ||
2126: ' a.template = b.name';
2127:
2128: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
2129: DBMS_SQL.PARSE (l_cursor_id, l_select_pub_sqlstring, DBMS_SQL.v7);
2130: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
2131:
2132: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
2133: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
2126: ' a.template = b.name';
2127:
2128: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
2129: DBMS_SQL.PARSE (l_cursor_id, l_select_pub_sqlstring, DBMS_SQL.v7);
2130: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
2131:
2132: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
2133: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
2134: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
2128: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
2129: DBMS_SQL.PARSE (l_cursor_id, l_select_pub_sqlstring, DBMS_SQL.v7);
2130: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
2131:
2132: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
2133: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
2134: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
2135:
2136: counter :=1;
2129: DBMS_SQL.PARSE (l_cursor_id, l_select_pub_sqlstring, DBMS_SQL.v7);
2130: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
2131:
2132: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
2133: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
2134: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
2135:
2136: counter :=1;
2137: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
2130: DBMS_SQL.BIND_VARIABLE (l_cursor_id, ':user_name', p_user_name );
2131:
2132: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
2133: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
2134: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
2135:
2136: counter :=1;
2137: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
2138: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
2133: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_wrapper_name, 30);
2134: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
2135:
2136: counter :=1;
2137: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
2138: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
2139: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_wrapper_name);
2140: l_userpub_tbl(counter) := l_pub_name;
2141: l_pubhandler_tbl(counter) := l_wrapper_name;
2134: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
2135:
2136: counter :=1;
2137: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
2138: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
2139: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_wrapper_name);
2140: l_userpub_tbl(counter) := l_pub_name;
2141: l_pubhandler_tbl(counter) := l_wrapper_name;
2142: counter := counter +1;
2135:
2136: counter :=1;
2137: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
2138: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
2139: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_wrapper_name);
2140: l_userpub_tbl(counter) := l_pub_name;
2141: l_pubhandler_tbl(counter) := l_wrapper_name;
2142: counter := counter +1;
2143: END LOOP;
2141: l_pubhandler_tbl(counter) := l_wrapper_name;
2142: counter := counter +1;
2143: END LOOP;
2144:
2145: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
2146:
2147: -- User is subscribed to atleast one publication we know of
2148: IF counter >1 THEN
2149: FOR curr_index IN 1..l_userpub_tbl.count LOOP