APPS.ASG_CONS_QPKG dependencies on ASG_PUB

Line 634: from asg_pub_item where item_id=l_curr_pubitem;

630: 'asg_cons_qpkg',g_stmt_level);
631: END IF;
632: ELSE
633: select base_object_name,base_owner into l_view_name,l_owner_name
634: from asg_pub_item where item_id=l_curr_pubitem;
635: l_curr_pubitem:=l_pubitem_tbl(l_loopvar).name;
636: l_qry_string2:='select count(*) from '||l_owner_name||'.'||l_view_name;
637: EXECUTE IMMEDIATE l_qry_string2 into l_rec_count1;
638: l_total:=l_total+l_rec_count1;

Line 796: ' (select a.name from asg_pub_item a,asg_pub b' ||

792: 'asg_cons_qpkg', g_stmt_level);
793: END IF;
794: l_dml := 'DELETE FROM '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q ' ||
795: ' WHERE name IN ' ||
796: ' (select a.name from asg_pub_item a,asg_pub b' ||
797: ' where a.pub_name=b.name and b.custom=''Y'')';
798: EXECUTE IMMEDIATE l_dml;
799: END IF;
800:

Line 892: ' asg_pub_item api ' ||

888: -- Ok, some pub items are uploaded which need conflict detection
889: -- Call the publication level wrapper.
890: /* l_query_string := 'SELECT distinct api.pub_name ' ||
891: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||
892: ' asg_pub_item api ' ||
893: 'WHERE ci.clid$$cs = ''' || p_user_name || ''' AND ' ||
894: ' ci.tranid$$ = ' || p_upload_tranid || ' AND ' ||
895: ' ci.store = api.name';*/
896: l_query_string := 'SELECT distinct api.pub_name ' ||

Line 898: ' asg_pub_item api ' ||

894: ' ci.tranid$$ = ' || p_upload_tranid || ' AND ' ||
895: ' ci.store = api.name';*/
896: l_query_string := 'SELECT distinct api.pub_name ' ||
897: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||
898: ' asg_pub_item api ' ||
899: 'WHERE ci.clid$$cs = :1 AND ' ||
900: ' ci.tranid$$ = :2 AND ' ||
901: ' ci.store = api.name';
902:

Line 917: FROM asg_pub

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;
919:
920: -- Find the callback return value
921: /*

Line 1000: ' asg_pub_item api ' ||

996: -- and will not be complete refreshed
997: l_query_string := 'SELECT count(*) ' ||
998: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||
999: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
1000: ' asg_pub_item api ' ||
1001: 'WHERE ci.clid$$cs = :1 AND ' ||
1002: ' ci.tranid$$ = :2 AND ' ||
1003: ' ci.store = api.name AND ' ||
1004: ' ci.store = cpq.name AND ' ||

Line 1039: ' asg_pub_item api ' ||

1035: BEGIN
1036: /* l_query_string := 'SELECT ci.store ' ||
1037: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci , ' ||
1038: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
1039: ' asg_pub_item api ' ||
1040: 'WHERE ci.clid$$cs = ''' || p_user_name || ''' AND ' ||
1041: ' ci.tranid$$ = ' || p_upload_tranid || ' AND ' ||
1042: ' ci.store = api.name AND ' ||
1043: ' ci.store = cpq.name AND ' ||

Line 1050: ' asg_pub_item api ' ||

1046: ' api.pub_name in (' || l_conf_pubs || ')';*/
1047: l_query_string := 'SELECT ci.store ' ||
1048: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci , ' ||
1049: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
1050: ' asg_pub_item api ' ||
1051: 'WHERE ci.clid$$cs = :1 AND ' ||
1052: ' ci.tranid$$ = :2 AND ' ||
1053: ' ci.store = api.name AND ' ||
1054: ' ci.store = cpq.name AND ' ||

Line 1101: l_qry_string := 'select distinct pub_name from asg_pub_item where item_id in '||

1097: l_ret_val NUMBER;
1098: BEGIN
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);

Line 1126: ' ( select item_id from asg_pub_item where '||

1122: asg_helper.log('Setting user '||p_clientid||' to complete refresh for '||
1123: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);
1124: l_qry_string1 := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||
1125: ' set comp_ref = ''Y'' where name in '||
1126: ' ( select item_id from asg_pub_item where '||
1127: ' pub_name = :1 )';
1128: EXECUTE IMMEDIATE l_qry_string1
1129: USING l_pub_name;
1130: UPDATE asg_purge_sdq

Line 1140: ' ( select item_id from asg_pub_item where '||

1136: asg_helper.log('Re-setting user '||p_clientid||' to complete refresh for '||
1137: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);
1138: l_qry_string1 := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||
1139: ' set comp_ref = ''Y'' where name in '||
1140: ' ( select item_id from asg_pub_item where '||
1141: ' pub_name = :1 )';
1142: EXECUTE IMMEDIATE l_qry_string1
1143: USING l_pub_name;
1144: UPDATE asg_purge_sdq

Line 1271: FROM asg_pub_item

1267: END IF;
1268:
1269: SELECT base_object_name, primary_key_column, conflict_callout
1270: INTO l_piv, l_primary_key_columns, l_conflict_callout
1271: FROM asg_pub_item
1272: WHERE name = p_pubitem;
1273:
1274: l_client_wins := asg_base.G_CLIENT_WINS;
1275: l_server_wins := asg_base.G_SERVER_WINS;