DBA Data[Home] [Help]

APPS.AMS_DMSELECTION_PVT dependencies on AMS_DM_INT_SRC_STG_GT

Line 1303: EXECUTE IMMEDIATE 'TRUNCATE TABLE ' || l_ams_schema || '.ams_dm_int_src_stg_gt ';

1299: -- EXECUTE IMMEDIATE 'TRUNCATE TABLE ' || l_ams_schema || '.ams_dm_target_stg';
1300: EXECUTE IMMEDIATE 'TRUNCATE TABLE ' || l_ams_schema || '.ams_dm_target_stg_gt';
1301:
1302: -- EXECUTE IMMEDIATE 'TRUNCATE TABLE ' || l_ams_schema || '.ams_dm_inter_source_stg';
1303: EXECUTE IMMEDIATE 'TRUNCATE TABLE ' || l_ams_schema || '.ams_dm_int_src_stg_gt ';
1304:
1305: EXCEPTION
1306: WHEN FND_API.G_EXC_ERROR THEN
1307: x_return_status := FND_API.G_RET_STS_ERROR;

Line 1402: -- - add target_value column to AMS_DM_INT_SRC_STG_GT to capture

1398:
1399:
1400: --
1401: -- NOTE
1402: -- - add target_value column to AMS_DM_INT_SRC_STG_GT to capture
1403: -- the calculated target_value from populate_target_staging to avoid
1404: -- duplicate effort in update_source_target
1405: -- History
1406: -- 16-Feb-2001 choang Created.

Line 1407: -- 06-jun-2002 choang added support of target_value in AMS_DM_INT_SRC_STG_GT

1403: -- the calculated target_value from populate_target_staging to avoid
1404: -- duplicate effort in update_source_target
1405: -- History
1406: -- 16-Feb-2001 choang Created.
1407: -- 06-jun-2002 choang added support of target_value in AMS_DM_INT_SRC_STG_GT
1408: -- to replace logic of update_source(); added calculation
1409: -- of target value for alternative data sources.
1410: PROCEDURE populate_source (
1411: p_arc_object_for IN VARCHAR2,

Line 1441: FROM ams_dm_int_src_stg_gt

1437: CURSOR c_recs IS
1438: SELECT COUNT(*),
1439: NVL (SUM (DECODE (target_value, l_target_value, 1, 0)), 0)
1440: -- FROM ams_dm_inter_source_stg
1441: FROM ams_dm_int_src_stg_gt
1442: WHERE arc_object_used_by = p_arc_object_for
1443: AND object_used_by_id = p_object_for_id
1444: AND enabled_flag = 'Y'
1445: ;

Line 1562: INSERT INTO ams_dm_int_src_stg_gt (

1558:
1559:
1560: -- The first should be type INCLUDE
1561: -- INSERT INTO ams_dm_inter_source_stg (
1562: INSERT INTO ams_dm_int_src_stg_gt (
1563: arc_object_used_by,
1564: object_used_by_id,
1565: party_id,
1566: enabled_flag,

Line 1592: INSERT INTO ams_dm_int_src_stg_gt (

1588:
1589: -- handle include
1590: IF l_sources_rec.list_action_type = 'INCLUDE' THEN
1591: --INSERT INTO ams_dm_inter_source_stg (
1592: INSERT INTO ams_dm_int_src_stg_gt (
1593: arc_object_used_by,
1594: object_used_by_id,
1595: party_id,
1596: enabled_flag,

Line 1616: FROM ams_dm_int_src_stg_gt i

1612: AND t.party_id = p.party_id
1613: AND p.party_type = l_party_type
1614: AND NOT EXISTS (SELECT 1
1615: -- FROM ams_dm_inter_source_stg i
1616: FROM ams_dm_int_src_stg_gt i
1617: WHERE i.arc_object_used_by = t.arc_object_used_by
1618: AND i.object_used_by_id = t.object_used_by_id
1619: AND i.party_id = t.party_id)
1620: ;

Line 1624: DELETE FROM ams_dm_int_src_stg_gt i

1620: ;
1621: -- handle exclude
1622: ELSIF l_sources_rec.list_action_type = 'EXCLUDE' THEN
1623: -- DELETE FROM ams_dm_inter_source_stg i
1624: DELETE FROM ams_dm_int_src_stg_gt i
1625: WHERE arc_object_used_by = p_arc_object_for
1626: AND object_used_by_id = p_object_for_id
1627: AND EXISTS (SELECT 1
1628: FROM ams_dm_target_stg_gt t -- ams_dm_target_stg t

Line 1638: DELETE FROM ams_dm_int_src_stg_gt i

1634: ;
1635: -- handle intersect
1636: ELSIF l_sources_rec.list_action_type = 'INTERSECT' THEN
1637: -- DELETE FROM ams_dm_inter_source_stg i
1638: DELETE FROM ams_dm_int_src_stg_gt i
1639: WHERE arc_object_used_by = p_arc_object_for
1640: AND object_used_by_id = p_object_for_id
1641: AND NOT EXISTS (SELECT 1
1642: -- FROM ams_dm_target_stg t

Line 1658: INSERT INTO ams_dm_int_src_stg_gt (

1654: END LOOP;
1655: CLOSE c_sources;
1656: ELSE
1657: -- INSERT INTO ams_dm_inter_source_stg (
1658: INSERT INTO ams_dm_int_src_stg_gt (
1659: arc_object_used_by,
1660: object_used_by_id,
1661: party_id,
1662: enabled_flag,

Line 1719: FROM ams_dm_int_src_stg_gt

1715: p_object_for_id,
1716: party_id,
1717: target_value
1718: -- FROM ams_dm_inter_source_stg
1719: FROM ams_dm_int_src_stg_gt
1720: WHERE arc_object_used_by = p_arc_object_for
1721: AND object_used_by_id = p_object_for_id
1722: AND enabled_flag = 'Y'
1723: ;

Line 1788: WHERE org_party_id NOT IN (SELECT distinct party_id from ams_dm_int_src_stg_gt WHERE arc_object_used_by = p_arc_object_for AND

1784: -- DELETE FROM ams_dm_org_contacts_stg
1785: -- DELETE FROM ams_dm_orgcont_stg_gt
1786: DELETE FROM ams_dm_org_contacts
1787: -- WHERE org_party_id NOT IN (SELECT distinct party_id from ams_dm_inter_source_stg WHERE arc_object_used_by = p_arc_object_for AND
1788: WHERE org_party_id NOT IN (SELECT distinct party_id from ams_dm_int_src_stg_gt WHERE arc_object_used_by = p_arc_object_for AND
1789: object_used_by_id = p_object_for_id);
1790:
1791: IF (AMS_DEBUG_HIGH_ON) THEN
1792: AMS_Utility_PVT.debug_message ('In populate_source synchronize org_cotacts with org');

Line 2649: FROM ams_dm_int_src_stg_gt

2645:
2646: CURSOR c_total_records (p_arc_object IN VARCHAR2, p_object_id IN NUMBER) IS
2647: SELECT COUNT(*)
2648: -- FROM ams_dm_inter_source_stg
2649: FROM ams_dm_int_src_stg_gt
2650: WHERE arc_object_used_by = p_arc_object
2651: AND object_used_by_id = p_object_id
2652: ;
2653: BEGIN

Line 2680: UPDATE ams_dm_int_src_stg_gt

2676: END IF;
2677:
2678: IF l_row_selection_type = L_SELECTION_TYPE_STANDARD THEN
2679: -- UPDATE ams_dm_inter_source_stg
2680: UPDATE ams_dm_int_src_stg_gt
2681: SET enabled_flag = 'Y'
2682: WHERE arc_object_used_by = p_arc_object_for
2683: AND object_used_by_id = p_object_for_id
2684: AND rownum <= NVL (l_max_records, l_total_records)

Line 2743: FROM ams_dm_int_src_stg_gt

2739:
2740: CURSOR c_randomized_sources (p_arc_object IN VARCHAR2, p_object_id IN NUMBER) IS
2741: SELECT party_id
2742: -- FROM ams_dm_inter_source_stg
2743: FROM ams_dm_int_src_stg_gt
2744: WHERE arc_object_used_by = p_arc_object
2745: AND object_used_by_id = p_object_id
2746: ORDER BY random_generated_num
2747: ;

Line 2763: UPDATE ams_dm_int_src_stg_gt

2759: -- days and seconds representation of sysdate.
2760: DBMS_RANDOM.initialize (TO_NUMBER (TO_CHAR (SYSDATE, 'DDSSSS')));
2761:
2762: -- UPDATE ams_dm_inter_source_stg
2763: UPDATE ams_dm_int_src_stg_gt
2764: SET random_generated_num = DBMS_RANDOM.random
2765: WHERE arc_object_used_by = p_arc_object_for
2766: AND object_used_by_id = p_object_for_id
2767: ;

Line 2780: UPDATE ams_dm_int_src_stg_gt

2776: -- Bulk update the records ordered by the randomly generated number.
2777: -- This simulates a random order of the records.
2778: FORALL i IN l_object_ids.FIRST..l_object_ids.LAST
2779: -- UPDATE ams_dm_inter_source_stg
2780: UPDATE ams_dm_int_src_stg_gt
2781: SET enabled_flag = 'Y'
2782: WHERE arc_object_used_by = p_arc_object_for
2783: AND object_used_by_id = p_object_for_id
2784: AND party_id = l_object_ids(i);

Line 2819: UPDATE ams_dm_int_src_stg_gt

2815: -- 1) update all records but only set enabled_flag = Y for the nth row
2816: -- 2) update all records with enabled_flag = Y, but set all records
2817: -- greater than max to N
2818: -- UPDATE ams_dm_inter_source_stg
2819: UPDATE ams_dm_int_src_stg_gt
2820: SET enabled_flag = DECODE (MOD (rownum, p_every_nth_row), 0, 'Y', 'N')
2821: WHERE arc_object_used_by = p_arc_object_for
2822: AND object_used_by_id = p_object_for_id
2823: ;

Line 2830: UPDATE ams_dm_int_src_stg_gt

2826: -- or equal to the max requested rows, then no records
2827: -- need to be updated with N
2828: IF l_total_random_rows > l_local_max_rows THEN
2829: -- UPDATE ams_dm_inter_source_stg
2830: UPDATE ams_dm_int_src_stg_gt
2831: SET enabled_flag = DECODE (SIGN (l_local_max_rows - rownum), -1, 'N', 'Y')
2832: WHERE arc_object_used_by = p_arc_object_for
2833: AND object_used_by_id = p_object_for_id
2834: AND enabled_flag = 'Y'