[Home] [Help]
The following lines contain the word 'select', 'insert', 'update' or 'delete':
l_update_name_hdr varchar2(30) := 'HDR::'||to_char(sysdate,'MM/DD/YYYY:HH:MI:SS'); -- modified by rassharm for unique name
l_update_name_line varchar2(30) := 'LINE::'||to_char(sysdate,'MM/DD/YYYY:HH:MI:SS'); -- modified by rassharm for unique name
l_update_name_pa varchar2(30) := 'ATTR::'||to_char(sysdate,'MM/DD/YYYY:HH:MI:SS'); -- modified by rassharm for unique name
l_update_name_qual varchar2(30) := 'QUAL::'||to_char(sysdate,'MM/DD/YYYY:HH:MI:SS'); -- modified by rassharm for unique name
ad_parallel_updates_pkg.initialize_rowid_range(
ad_parallel_updates_pkg.ROWID_RANGE,
l_table_owner_hdr,
l_table_name_hdr,
l_update_name_hdr,
X_worker_id,
X_num_workers,
X_batch_size, 0);
ad_parallel_updates_pkg.get_rowid_range(
l_start_rowid_hdr,
l_end_rowid_hdr,
l_any_rows_to_process_hdr,
X_batch_size,
TRUE);
Update qp_list_headers_b qplh1
Set qplh1.orig_system_header_ref = 'INT'||to_char(qplh1.list_header_id)
where qplh1.orig_system_header_ref is null
and qplh1.rowid between l_start_rowid_hdr and l_end_rowid_hdr;
ad_parallel_updates_pkg.processed_rowid_range(
l_rows_processed_hdr,
l_end_rowid_hdr);
ad_parallel_updates_pkg.get_rowid_range(
l_start_rowid_hdr,
l_end_rowid_hdr,
l_any_rows_to_process_hdr,
X_batch_size,
FALSE);
ad_parallel_updates_pkg.initialize_rowid_range(
ad_parallel_updates_pkg.ROWID_RANGE,
l_table_owner_line,
l_table_name_line,
l_update_name_line,
X_worker_id,
X_num_workers,
X_batch_size, 0);
ad_parallel_updates_pkg.get_rowid_range(
l_start_rowid_line,
l_end_rowid_line,
l_any_rows_to_process_line,
X_batch_size,
TRUE);
update qp_list_lines l
set l.orig_sys_line_ref=to_char(l.list_line_id),
l.orig_sys_header_ref=
(
select nvl(h.orig_system_header_ref,'INT'||to_char(h.list_header_id))
from qp_list_headers_b h
where h.list_header_id = l.list_header_id
)
where l.orig_sys_line_ref is null
and l.rowid between l_start_rowid_line and l_end_rowid_line;
UPDATE qp_list_lines l
SET l.orig_sys_header_ref=
(
select nvl(h.orig_system_header_ref,'INT'||to_char(h.list_header_id))
from qp_list_headers_b h
where h.list_header_id = l.list_header_id
)
where l.orig_sys_header_ref is null
and l.rowid between l_start_rowid_line and l_end_rowid_line;
ad_parallel_updates_pkg.processed_rowid_range(
l_rows_processed_line,
l_end_rowid_line);
ad_parallel_updates_pkg.get_rowid_range(
l_start_rowid_line,
l_end_rowid_line,
l_any_rows_to_process_line,
X_batch_size,
FALSE);
ad_parallel_updates_pkg.initialize_rowid_range(
ad_parallel_updates_pkg.ROWID_RANGE,
l_table_owner_pa,
l_table_name_pa,
l_update_name_pa,
X_worker_id,
X_num_workers,
X_batch_size, 0);
ad_parallel_updates_pkg.get_rowid_range(
l_start_rowid_pa,
l_end_rowid_pa,
l_any_rows_to_process_pa,
X_batch_size,
TRUE);
update qp_pricing_attributes p
set p.ORIG_SYS_PRICING_ATTR_REF=to_char(p.PRICING_ATTRIBUTE_ID),
p.orig_sys_header_ref=
(
select nvl(h.orig_system_header_ref,'INT'||to_char(h.list_header_id))
from qp_list_headers_b h
where h.list_header_id = p.list_header_id
),
p.orig_sys_line_ref=
(
select nvl(l.orig_sys_line_ref,l.list_line_id)
from qp_list_lines l
where l.list_line_id = p.list_line_id
)
where p.ORIG_SYS_PRICING_ATTR_REF is null
and p.rowid between l_start_rowid_pa and l_end_rowid_pa;
update qp_pricing_attributes p
set p.orig_sys_header_ref=
(
select nvl(h.orig_system_header_ref,'INT'||to_char(h.list_header_id))
from qp_list_headers_b h
where h.list_header_id = p.list_header_id
)
where p.orig_sys_header_ref is null
and p.rowid between l_start_rowid_pa and l_end_rowid_pa;
update qp_pricing_attributes p
set p.orig_sys_line_ref=
(
select nvl(l.orig_sys_line_ref,l.list_line_id)
from qp_list_lines l
where l.list_line_id = p.list_line_id
)
where p.orig_sys_line_ref is null
and p.rowid between l_start_rowid_pa and l_end_rowid_pa;
ad_parallel_updates_pkg.processed_rowid_range(
l_rows_processed_pa,
l_end_rowid_pa);
ad_parallel_updates_pkg.get_rowid_range(
l_start_rowid_pa,
l_end_rowid_pa,
l_any_rows_to_process_pa,
X_batch_size,
FALSE);
ad_parallel_updates_pkg.initialize_rowid_range(
ad_parallel_updates_pkg.ROWID_RANGE,
l_table_owner_qual,
l_table_name_qual,
l_update_name_qual,
X_worker_id,
X_num_workers,
X_batch_size, 0);
ad_parallel_updates_pkg.get_rowid_range(
l_start_rowid_qual,
l_end_rowid_qual,
l_any_rows_to_process_qual,
X_batch_size,
TRUE);
update qp_qualifiers q
set q.orig_sys_qualifier_ref=to_char(q.qualifier_id),
q.orig_sys_header_ref=
(
select nvl(h.orig_system_header_ref,'INT'||to_char(h.list_header_id))
from qp_list_headers_b h
where h.list_header_id = q.list_header_id
)
where q.orig_sys_qualifier_ref is null
and q.list_header_id is not null
and q.rowid between l_start_rowid_qual and l_end_rowid_qual;
update qp_qualifiers q
set q.orig_sys_header_ref=
(
select nvl(h.orig_system_header_ref,'INT'||to_char(h.list_header_id))
from qp_list_headers_b h
where h.list_header_id = q.list_header_id
)
where q.orig_sys_header_ref is null
and q.list_header_id is not null
and q.rowid between l_start_rowid_qual and l_end_rowid_qual;
ad_parallel_updates_pkg.processed_rowid_range(
l_rows_processed_qual,
l_end_rowid_qual);
ad_parallel_updates_pkg.get_rowid_range(
l_start_rowid_qual,
l_end_rowid_qual,
l_any_rows_to_process_qual,
X_batch_size,
FALSE);