70: l_select_pi_sqlstring :=
71: 'SELECT name, comp_ref ' ||
72: 'FROM ' || asg_base.G_OLITE_SCHEMA ||'.' ||'c$pub_list_q';
73:
74: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
75: DBMS_SQL.PARSE (l_cursor_id, l_select_pi_sqlstring, DBMS_SQL.v7);
76: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem_name, 30);
77: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_comp_ref, 1);
78:
71: 'SELECT name, comp_ref ' ||
72: 'FROM ' || asg_base.G_OLITE_SCHEMA ||'.' ||'c$pub_list_q';
73:
74: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
75: DBMS_SQL.PARSE (l_cursor_id, l_select_pi_sqlstring, DBMS_SQL.v7);
76: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem_name, 30);
77: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_comp_ref, 1);
78:
79: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
72: 'FROM ' || asg_base.G_OLITE_SCHEMA ||'.' ||'c$pub_list_q';
73:
74: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
75: DBMS_SQL.PARSE (l_cursor_id, l_select_pi_sqlstring, DBMS_SQL.v7);
76: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem_name, 30);
77: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_comp_ref, 1);
78:
79: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
80: counter := 1;
73:
74: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
75: DBMS_SQL.PARSE (l_cursor_id, l_select_pi_sqlstring, DBMS_SQL.v7);
76: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem_name, 30);
77: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_comp_ref, 1);
78:
79: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
80: counter := 1;
81: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
75: DBMS_SQL.PARSE (l_cursor_id, l_select_pi_sqlstring, DBMS_SQL.v7);
76: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem_name, 30);
77: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_comp_ref, 1);
78:
79: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
80: counter := 1;
81: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
82: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pubitem_name);
83: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_comp_ref);
77: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 2, l_comp_ref, 1);
78:
79: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
80: counter := 1;
81: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
82: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pubitem_name);
83: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_comp_ref);
84: p_pubitem_tbl(counter).name := l_pubitem_name;
85: p_pubitem_tbl(counter).comp_ref := l_comp_ref;
78:
79: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
80: counter := 1;
81: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
82: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pubitem_name);
83: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_comp_ref);
84: p_pubitem_tbl(counter).name := l_pubitem_name;
85: p_pubitem_tbl(counter).comp_ref := l_comp_ref;
86: counter := counter +1;
79: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
80: counter := 1;
81: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
82: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pubitem_name);
83: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 2, l_comp_ref);
84: p_pubitem_tbl(counter).name := l_pubitem_name;
85: p_pubitem_tbl(counter).comp_ref := l_comp_ref;
86: counter := counter +1;
87: END LOOP;
85: p_pubitem_tbl(counter).comp_ref := l_comp_ref;
86: counter := counter +1;
87: END LOOP;
88:
89: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
90:
91: END get_pubitem_list;
92:
93: FUNCTION is_previous_synch_successful(p_user_name IN VARCHAR2,
899: 'WHERE ci.clid$$cs = :1 AND ' ||
900: ' ci.tranid$$ = :2 AND ' ||
901: ' ci.store = api.name';
902:
903: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
904: DBMS_SQL.PARSE (l_cursor_id, l_query_string, DBMS_SQL.v7);
905: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
906: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
907: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
900: ' ci.tranid$$ = :2 AND ' ||
901: ' ci.store = api.name';
902:
903: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
904: DBMS_SQL.PARSE (l_cursor_id, l_query_string, DBMS_SQL.v7);
905: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
906: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
907: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
908:
901: ' ci.store = api.name';
902:
903: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
904: DBMS_SQL.PARSE (l_cursor_id, l_query_string, DBMS_SQL.v7);
905: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
906: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
907: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
908:
909: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
902:
903: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
904: DBMS_SQL.PARSE (l_cursor_id, l_query_string, DBMS_SQL.v7);
905: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
906: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
907: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
908:
909: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
910: l_counter := 1;
903: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
904: DBMS_SQL.PARSE (l_cursor_id, l_query_string, DBMS_SQL.v7);
905: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
906: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
907: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
908:
909: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
910: l_counter := 1;
911:
905: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
906: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
907: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pub_name, 30);
908:
909: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
910: l_counter := 1;
911:
912: -- Go through all the publications whose pis were uploaded
913: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
909: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
910: l_counter := 1;
911:
912: -- Go through all the publications whose pis were uploaded
913: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
914: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
915:
916: SELECT wrapper_name into l_pub_callback
917: FROM asg_pub
910: l_counter := 1;
911:
912: -- Go through all the publications whose pis were uploaded
913: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
914: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
915:
916: SELECT wrapper_name into l_pub_callback
917: FROM asg_pub
918: WHERE name = l_pub_name;
933: 'asg_cons_qpkg',g_stmt_level);
934: END IF;
935: BEGIN
936: /*
937: l_cursor_id2 := DBMS_SQL.OPEN_CuRSOR();
938: DBMS_SQL.PARSE(l_cursor_id2, l_query_string2, DBMS_SQL.v7);
939: DBMS_SQL.DEFINE_COLUMN(l_cursor_id2, 1, l_pub_detect_conflict, 1);
940: l_cursor_ret2 := DBMS_SQL.EXECUTE(l_cursor_id2);
941: DBMS_SQL.COLUMN_VALUE(l_cursor_id2, 1, l_pub_detect_conflict);
934: END IF;
935: BEGIN
936: /*
937: l_cursor_id2 := DBMS_SQL.OPEN_CuRSOR();
938: DBMS_SQL.PARSE(l_cursor_id2, l_query_string2, DBMS_SQL.v7);
939: DBMS_SQL.DEFINE_COLUMN(l_cursor_id2, 1, l_pub_detect_conflict, 1);
940: l_cursor_ret2 := DBMS_SQL.EXECUTE(l_cursor_id2);
941: DBMS_SQL.COLUMN_VALUE(l_cursor_id2, 1, l_pub_detect_conflict);
942: DBMS_SQL.CLOSE_CURSOR(l_cursor_id2);
935: BEGIN
936: /*
937: l_cursor_id2 := DBMS_SQL.OPEN_CuRSOR();
938: DBMS_SQL.PARSE(l_cursor_id2, l_query_string2, DBMS_SQL.v7);
939: DBMS_SQL.DEFINE_COLUMN(l_cursor_id2, 1, l_pub_detect_conflict, 1);
940: l_cursor_ret2 := DBMS_SQL.EXECUTE(l_cursor_id2);
941: DBMS_SQL.COLUMN_VALUE(l_cursor_id2, 1, l_pub_detect_conflict);
942: DBMS_SQL.CLOSE_CURSOR(l_cursor_id2);
943: */
936: /*
937: l_cursor_id2 := DBMS_SQL.OPEN_CuRSOR();
938: DBMS_SQL.PARSE(l_cursor_id2, l_query_string2, DBMS_SQL.v7);
939: DBMS_SQL.DEFINE_COLUMN(l_cursor_id2, 1, l_pub_detect_conflict, 1);
940: l_cursor_ret2 := DBMS_SQL.EXECUTE(l_cursor_id2);
941: DBMS_SQL.COLUMN_VALUE(l_cursor_id2, 1, l_pub_detect_conflict);
942: DBMS_SQL.CLOSE_CURSOR(l_cursor_id2);
943: */
944: EXECUTE IMMEDIATE l_query_string2
937: l_cursor_id2 := DBMS_SQL.OPEN_CuRSOR();
938: DBMS_SQL.PARSE(l_cursor_id2, l_query_string2, DBMS_SQL.v7);
939: DBMS_SQL.DEFINE_COLUMN(l_cursor_id2, 1, l_pub_detect_conflict, 1);
940: l_cursor_ret2 := DBMS_SQL.EXECUTE(l_cursor_id2);
941: DBMS_SQL.COLUMN_VALUE(l_cursor_id2, 1, l_pub_detect_conflict);
942: DBMS_SQL.CLOSE_CURSOR(l_cursor_id2);
943: */
944: EXECUTE IMMEDIATE l_query_string2
945: INTO l_pub_detect_conflict
938: DBMS_SQL.PARSE(l_cursor_id2, l_query_string2, DBMS_SQL.v7);
939: DBMS_SQL.DEFINE_COLUMN(l_cursor_id2, 1, l_pub_detect_conflict, 1);
940: l_cursor_ret2 := DBMS_SQL.EXECUTE(l_cursor_id2);
941: DBMS_SQL.COLUMN_VALUE(l_cursor_id2, 1, l_pub_detect_conflict);
942: DBMS_SQL.CLOSE_CURSOR(l_cursor_id2);
943: */
944: EXECUTE IMMEDIATE l_query_string2
945: INTO l_pub_detect_conflict
946: USING p_user_name;
967: 'asg_cons_qpkg',g_stmt_level);
968: END IF;
969: END;
970: END LOOP;
971: DBMS_SQL.CLOSE_CURSOR(l_cursor_id);
972:
973: -- Some pubs need conflict detection
974: IF (l_counter > 1) THEN
975: p_detect_conflict := FND_API.G_TRUE;
1055: ' cpq.comp_ref <> ''Y'' AND ' ||
1056: ' api.detect_conflict = ''Y'' AND ' ||
1057: ' api.pub_name in (' || l_conf_pubs || ')';
1058:
1059: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1060: DBMS_SQL.PARSE (l_cursor_id, l_query_string, DBMS_SQL.v7);
1061: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
1062: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
1063: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem, 30);
1056: ' api.detect_conflict = ''Y'' AND ' ||
1057: ' api.pub_name in (' || l_conf_pubs || ')';
1058:
1059: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1060: DBMS_SQL.PARSE (l_cursor_id, l_query_string, DBMS_SQL.v7);
1061: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
1062: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
1063: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem, 30);
1064:
1057: ' api.pub_name in (' || l_conf_pubs || ')';
1058:
1059: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1060: DBMS_SQL.PARSE (l_cursor_id, l_query_string, DBMS_SQL.v7);
1061: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
1062: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
1063: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem, 30);
1064:
1065: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1058:
1059: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1060: DBMS_SQL.PARSE (l_cursor_id, l_query_string, DBMS_SQL.v7);
1061: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
1062: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
1063: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem, 30);
1064:
1065: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1066: l_counter := 1;
1059: l_cursor_id := DBMS_SQL.OPEN_CURSOR;
1060: DBMS_SQL.PARSE (l_cursor_id, l_query_string, DBMS_SQL.v7);
1061: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
1062: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
1063: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem, 30);
1064:
1065: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1066: l_counter := 1;
1067:
1061: DBMS_SQL.bind_variable(l_cursor_id,':1',p_user_name);
1062: DBMS_SQL.bind_variable(l_cursor_id,':2',p_upload_tranid);
1063: DBMS_SQL.DEFINE_COLUMN (l_cursor_id, 1, l_pubitem, 30);
1064:
1065: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1066: l_counter := 1;
1067:
1068: -- Go through all the publications whose pis were uploaded
1069: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1065: l_cursor_ret := DBMS_SQL.EXECUTE (l_cursor_id);
1066: l_counter := 1;
1067:
1068: -- Go through all the publications whose pis were uploaded
1069: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1070: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pubitem);
1071: p_pubitem_tbl(l_counter).name := l_pubitem;
1072: l_counter := l_counter +1;
1073: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1066: l_counter := 1;
1067:
1068: -- Go through all the publications whose pis were uploaded
1069: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 ) LOOP
1070: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pubitem);
1071: p_pubitem_tbl(l_counter).name := l_pubitem;
1072: l_counter := l_counter +1;
1073: IF(asg_helper.check_is_log_enabled(g_stmt_level)) THEN
1074: asg_helper.log('Pub item that will be checked for conflicts: ' ||
1099: asg_helper.log('Processing Purge SDQ','asg_cons_qpkg',g_stmt_level);
1100:
1101: l_qry_string := 'select distinct pub_name from asg_pub_item where item_id in '||
1102: ' ( select name from '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q )';
1103: l_cursor_id := dbms_sql.open_cursor();
1104: DBMS_SQL.parse(l_cursor_id,l_qry_string,DBMS_SQL.v7);
1105: DBMS_SQL.define_column(l_cursor_id,1,l_pub_name,30);
1106: l_ret_val := DBMS_SQL.execute(l_cursor_id);
1107:
1100:
1101: l_qry_string := 'select distinct pub_name from asg_pub_item where item_id in '||
1102: ' ( select name from '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q )';
1103: l_cursor_id := dbms_sql.open_cursor();
1104: DBMS_SQL.parse(l_cursor_id,l_qry_string,DBMS_SQL.v7);
1105: DBMS_SQL.define_column(l_cursor_id,1,l_pub_name,30);
1106: l_ret_val := DBMS_SQL.execute(l_cursor_id);
1107:
1108: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 )
1101: l_qry_string := 'select distinct pub_name from asg_pub_item where item_id in '||
1102: ' ( select name from '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q )';
1103: l_cursor_id := dbms_sql.open_cursor();
1104: DBMS_SQL.parse(l_cursor_id,l_qry_string,DBMS_SQL.v7);
1105: DBMS_SQL.define_column(l_cursor_id,1,l_pub_name,30);
1106: l_ret_val := DBMS_SQL.execute(l_cursor_id);
1107:
1108: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 )
1109: LOOP
1102: ' ( select name from '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q )';
1103: l_cursor_id := dbms_sql.open_cursor();
1104: DBMS_SQL.parse(l_cursor_id,l_qry_string,DBMS_SQL.v7);
1105: DBMS_SQL.define_column(l_cursor_id,1,l_pub_name,30);
1106: l_ret_val := DBMS_SQL.execute(l_cursor_id);
1107:
1108: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 )
1109: LOOP
1110: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
1104: DBMS_SQL.parse(l_cursor_id,l_qry_string,DBMS_SQL.v7);
1105: DBMS_SQL.define_column(l_cursor_id,1,l_pub_name,30);
1106: l_ret_val := DBMS_SQL.execute(l_cursor_id);
1107:
1108: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 )
1109: LOOP
1110: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
1111:
1112: l_tran_id := -200;
1106: l_ret_val := DBMS_SQL.execute(l_cursor_id);
1107:
1108: WHILE ( DBMS_SQL.FETCH_ROWS(l_cursor_id) > 0 )
1109: LOOP
1110: DBMS_SQL.COLUMN_VALUE (l_cursor_id, 1, l_pub_name);
1111:
1112: l_tran_id := -200;
1113:
1114: OPEN c_purgeSdq(p_clientid,l_pub_name);
1156: END if;
1157: CLOSE c_purgeSdq;
1158: END LOOP;
1159:
1160: dbms_sql.close_cursor(l_cursor_id);
1161: asg_helper.log('End processing purgeSDQ','asg_cons_qpkg',g_stmt_level);
1162: EXCEPTION
1163: WHEN OTHERS THEN
1164: asg_helper.log('Exception in process_purge_sdq: ' || sqlerrm,