DBA Data[Home] [Help]

APPS.AD_PARALLEL_UPDATES_PKG dependencies on AD_PARALLEL_UPDATES

Line 1: package body ad_parallel_updates_pkg as

1: package body ad_parallel_updates_pkg as
2: -- $Header: adprupdb.pls 120.7.12010000.2 2009/09/18 09:04:24 bbhumire ship $
3:
4: SUBTYPE update_info_type IS ad_parallel_updates%ROWTYPE;
5:

Line 4: SUBTYPE update_info_type IS ad_parallel_updates%ROWTYPE;

1: package body ad_parallel_updates_pkg as
2: -- $Header: adprupdb.pls 120.7.12010000.2 2009/09/18 09:04:24 bbhumire ship $
3:
4: SUBTYPE update_info_type IS ad_parallel_updates%ROWTYPE;
5:
6: --
7: -- Global cache for the current Parallel Update Record and Options.
8: --

Line 77: FROM ad_parallel_updates

73: BEGIN
74: g_cache.ui_initialized := FALSE;
75: SELECT *
76: INTO g_cache.update_info
77: FROM ad_parallel_updates
78: WHERE owner = p_owner
79: AND table_name = p_table_name
80: AND script_name = p_script_name;
81: g_cache.ui_initialized := TRUE;

Line 203: from ad_parallel_updates

199:
200: begin
201: select null
202: into l_initialized
203: from ad_parallel_updates
204: where owner = X_owner
205: and table_name = X_table
206: and script_name = X_script;
207:

Line 210: insert into ad_parallel_updates (

206: and script_name = X_script;
207:
208: exception
209: when NO_DATA_FOUND then
210: insert into ad_parallel_updates (
211: update_id,
212: update_type,
213: owner, script_name, table_name,
214: object_id,

Line 218: select ad_parallel_updates_s.nextval,

214: object_id,
215: id_column, num_workers, creation_date,
216: db_block_size, avg_row_len,
217: initialized_flag)
218: select ad_parallel_updates_s.nextval,
219: X_update_type,
220: X_owner, X_script, X_table,
221: nvl(o.dataobj#, o.obj#),
222: X_id_column, X_num_workers, sysdate,

Line 245: -- in ad_parallel_updates_pkg() package.

241:
242: -- For bug 3447980, a view ad_extents is created via adgrants.sql,
243: -- using the huge select tested by APPS Performance team.
244: -- This is to replace the Rule optimization
245: -- in ad_parallel_updates_pkg() package.
246:
247: procedure populate_extent_info
248: (X_owner in varchar2,
249: X_table in varchar2,

Line 723: from ad_parallel_updates

719:
720: begin
721: select update_id, initialized_flag, num_workers
722: into l_update_id, l_initialized, l_num_workers
723: from ad_parallel_updates
724: where owner = X_owner
725: and table_name = X_table
726: and script_name = X_script;
727:

Line 765: update ad_parallel_updates

761:
762: --
763: -- now set initialized_flag to Y
764: --
765: update ad_parallel_updates
766: set initialized_flag = 'Y',
767: num_workers = X_num_workers
768: where owner = X_owner
769: and table_name = X_table

Line 833: update ad_parallel_updates

829: end_id = null
830: where update_id = l_update_id
831: and worker_id > X_num_workers;
832:
833: update ad_parallel_updates
834: set num_workers = X_num_workers
835: where update_id = l_update_id;
836:
837: end if; -- ID range method

Line 945: ad_parallel_updates_pkg.PRESERVE_PROCESSED_UNITS,

941: initialize(X_update_type,
942: X_owner, X_table, X_script, X_ID_column,
943: X_worker_id, X_num_workers,
944: X_batch_size, X_debug_level,
945: ad_parallel_updates_pkg.PRESERVE_PROCESSED_UNITS,
946: X_SQL_Stmt, X_Begin_ID, X_End_ID);
947: END initialize_id_range;
948:
949:

Line 1496: from ad_parallel_updates p

1492: X_script in varchar2 default NULL)
1493: is
1494: cursor c_purge is
1495: select update_id
1496: from ad_parallel_updates p
1497: where initialized_flag = 'Y'
1498: and owner = nvl(upper(X_owner), owner)
1499: and table_name = nvl(upper(X_table), table_name)
1500: and script_name = nvl(X_script, script_name)

Line 1547: from ad_parallel_updates

1543: begin
1544:
1545: select update_id
1546: into l_update_id
1547: from ad_parallel_updates
1548: where owner = upper(X_owner)
1549: and table_name = upper(X_table)
1550: and script_name = X_script;
1551:

Line 1571: delete from ad_parallel_updates

1567:
1568: delete from ad_parallel_update_units
1569: where update_id = l_update_id;
1570:
1571: delete from ad_parallel_updates
1572: where update_id = l_update_id;
1573:
1574: --
1575: -- commit and release the lock

Line 1601: from ad_parallel_updates pu

1597: -- updates that have pending units are candidates for reinitialization
1598: --
1599: cursor c_cur is
1600: select update_id, table_name, owner
1601: from ad_parallel_updates pu
1602: where owner = nvl(upper(X_owner), owner)
1603: and table_name = nvl(upper(X_table), table_name)
1604: and script_name = nvl(X_script, script_name)
1605: and update_type = ROWID_RANGE

Line 1624: update ad_parallel_updates

1620:
1621: --
1622: -- set the update to un-initialized
1623: --
1624: update ad_parallel_updates
1625: set initialized_flag = 'N'
1626: where update_id = crec.update_id;
1627:
1628: --