APPS.ASG_CONS_QPKG dependencies on ASG_PUB_ITEM

Line 593: from asg_pub_item where item_id=l_curr_pubitem;

589: 'asg_cons_qpkg',g_stmt_level);
590: END IF;
591: ELSE
592: select base_object_name,base_owner into l_view_name,l_owner_name
593: from asg_pub_item where item_id=l_curr_pubitem;
594: l_curr_pubitem:=l_pubitem_tbl(l_loopvar).name;
595: l_qry_string2:='select count(*) from '||l_owner_name||'.'||l_view_name;
596: EXECUTE IMMEDIATE l_qry_string2 into l_rec_count1;
597: l_total:=l_total+l_rec_count1;

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

751: 'asg_cons_qpkg', g_stmt_level);
752: END IF;
753: l_dml := 'DELETE FROM '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q ' ||
754: ' WHERE name IN ' ||
755: ' (select a.name from asg_pub_item a,asg_pub b' ||
756: ' where a.pub_name=b.name and b.custom=''Y'')';
757: EXECUTE IMMEDIATE l_dml;
758: END IF;
759:

Line 851: ' asg_pub_item api ' ||

847: -- Ok, some pub items are uploaded which need conflict detection
848: -- Call the publication level wrapper.
849: /* l_query_string := 'SELECT distinct api.pub_name ' ||
850: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||
851: ' asg_pub_item api ' ||
852: 'WHERE ci.clid$$cs = ''' || p_user_name || ''' AND ' ||
853: ' ci.tranid$$ = ' || p_upload_tranid || ' AND ' ||
854: ' ci.store = api.name';*/
855: l_query_string := 'SELECT distinct api.pub_name ' ||

Line 857: ' asg_pub_item api ' ||

853: ' ci.tranid$$ = ' || p_upload_tranid || ' AND ' ||
854: ' ci.store = api.name';*/
855: l_query_string := 'SELECT distinct api.pub_name ' ||
856: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||
857: ' asg_pub_item api ' ||
858: 'WHERE ci.clid$$cs = :1 AND ' ||
859: ' ci.tranid$$ = :2 AND ' ||
860: ' ci.store = api.name';
861:

Line 959: ' asg_pub_item api ' ||

955: -- and will not be complete refreshed
956: l_query_string := 'SELECT count(*) ' ||
957: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci, ' ||
958: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
959: ' asg_pub_item api ' ||
960: 'WHERE ci.clid$$cs = :1 AND ' ||
961: ' ci.tranid$$ = :2 AND ' ||
962: ' ci.store = api.name AND ' ||
963: ' ci.store = cpq.name AND ' ||

Line 998: ' asg_pub_item api ' ||

994: BEGIN
995: /* l_query_string := 'SELECT ci.store ' ||
996: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci , ' ||
997: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
998: ' asg_pub_item api ' ||
999: 'WHERE ci.clid$$cs = ''' || p_user_name || ''' AND ' ||
1000: ' ci.tranid$$ = ' || p_upload_tranid || ' AND ' ||
1001: ' ci.store = api.name AND ' ||
1002: ' ci.store = cpq.name AND ' ||

Line 1009: ' asg_pub_item api ' ||

1005: ' api.pub_name in (' || l_conf_pubs || ')';*/
1006: l_query_string := 'SELECT ci.store ' ||
1007: 'FROM ' || asg_base.G_OLITE_SCHEMA || '.c$inq ci , ' ||
1008: asg_base.G_OLITE_SCHEMA || '.c$pub_list_q cpq, ' ||
1009: ' asg_pub_item api ' ||
1010: 'WHERE ci.clid$$cs = :1 AND ' ||
1011: ' ci.tranid$$ = :2 AND ' ||
1012: ' ci.store = api.name AND ' ||
1013: ' ci.store = cpq.name AND ' ||

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

1056: l_ret_val NUMBER;
1057: BEGIN
1058: asg_helper.log('Processing Purge SDQ','asg_cons_qpkg',g_stmt_level);
1059:
1060: l_qry_string := 'select distinct pub_name from asg_pub_item where item_id in '||
1061: ' ( select name from '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q )';
1062: l_cursor_id := dbms_sql.open_cursor();
1063: DBMS_SQL.parse(l_cursor_id,l_qry_string,DBMS_SQL.v7);
1064: DBMS_SQL.define_column(l_cursor_id,1,l_pub_name,30);

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

1081: asg_helper.log('Setting user '||p_clientid||' to complete refresh for '||
1082: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);
1083: l_qry_string1 := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||
1084: ' set comp_ref = ''Y'' where name in '||
1085: ' ( select item_id from asg_pub_item where '||
1086: ' pub_name = :1 )';
1087: EXECUTE IMMEDIATE l_qry_string1
1088: USING l_pub_name;
1089: UPDATE asg_purge_sdq

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

1095: asg_helper.log('Re-setting user '||p_clientid||' to complete refresh for '||
1096: ' publication '||l_pub_name,'asg_cons_qpkg',g_stmt_level);
1097: l_qry_string1 := 'update '||asg_base.G_OLITE_SCHEMA||'.c$pub_list_q '||
1098: ' set comp_ref = ''Y'' where name in '||
1099: ' ( select item_id from asg_pub_item where '||
1100: ' pub_name = :1 )';
1101: EXECUTE IMMEDIATE l_qry_string1
1102: USING l_pub_name;
1103: UPDATE asg_purge_sdq

Line 1230: FROM asg_pub_item

1226: END IF;
1227:
1228: SELECT base_object_name, primary_key_column, conflict_callout
1229: INTO l_piv, l_primary_key_columns, l_conflict_callout
1230: FROM asg_pub_item
1231: WHERE name = p_pubitem;
1232:
1233: l_client_wins := asg_base.G_CLIENT_WINS;
1234: l_server_wins := asg_base.G_SERVER_WINS;