The following lines contain the word 'select', 'insert', 'update' or 'delete':
PROCEDURE insert_archive
(
table_id NUMBER,
seq_num NUMBER,
table_name VARCHAR2,
row_count NUMBER,
any_rows_to_process varchar2)
IS
pragma autonomous_transaction;
INSERT
INTO cn_arc_audit_desc_all
(TABLE_ID,ARCHIVE_PURGE_ID,TABLES_NAME,TABLE_AP_ROWS,ARCHIVE_PURGE_DATE,ANY_ROWS_TO_PROCESS_FLAG,ATTRIBUTE1,
ATTRIBUTE2,ATTRIBUTE3,ATTRIBUTE4,ATTRIBUTE5,CREATED_BY,CREATION_DATE,LAST_UPDATED_BY,LAST_UPDATE_DATE,LAST_UPDATE_LOGIN)
VALUES
(
table_id ,
seq_num ,
table_name ,
row_count ,
sysdate ,
any_rows_to_process,
NULL ,
NULL ,
NULL ,
NULL ,
NULL ,
fnd_global.user_id ,
sysdate ,
fnd_global.user_id ,
sysdate ,
fnd_global.user_id
);
PROCEDURE delete_table
(
p_start_period_id IN NUMBER,
p_end_period_id IN NUMBER,
x_start_date IN DATE,
x_end_date IN DATE,
p_worker_id IN NUMBER,
p_no_of_workers IN NUMBER,
p_batch_size IN NUMBER,
p_table_owner IN VARCHAR2,
p_table_name IN VARCHAR2,
p_script_name IN VARCHAR2,
p_addnl_para IN VARCHAR2,
x_row_to_process_flag OUT nocopy VARCHAR2,
x_return_status OUT nocopy VARCHAR2
)
IS
l_start_rowid rowid;
'CN_PURGE_TABLES_PVT.delete_table:Start '
)
;
'CN_PURGE_TABLES_PVT.delete_table:p_table_name ' || p_table_name
)
;
'CN_PURGE_TABLES_PVT.delete_table:p_table_owner ' || p_table_owner
)
;
'CN_PURGE_TABLES_PVT.delete_table:p_script_name ' || p_script_name
)
;
'CN_PURGE_TABLES_PVT.delete_table:p_worker_id ' || p_worker_id
)
;
'CN_PURGE_TABLES_PVT.delete_table:p_no_of_workers ' || p_no_of_workers
)
;
'CN_PURGE_TABLES_PVT.delete_table:p_batch_size ' || p_batch_size
)
;
SELECT TO_CHAR(sysdate,'dd-mm-rr:hh:mi:ss') INTO l_time FROM dual;
debugmsg('CN_PURGE_TABLES_PVT.delete_table: delete start l_time ' || l_time );
ad_parallel_updates_pkg.initialize_rowid_range( ad_parallel_updates_pkg.ROWID_RANGE, p_table_owner, p_table_name, p_script_name, p_worker_id, p_no_of_workers, p_batch_size, 0);
debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.initialize_rowid_range ' );
ad_parallel_updates_pkg.get_rowid_range( l_start_rowid, l_END_rowid, l_any_rows_to_process, p_batch_size, TRUE);
debugmsg('CN_PURGE_TABLES_PVT.delete_table:after ad_parallel_updates_pkg.get_rowid_range l_any_rows_to_process ' );
debugmsg('CN_PURGE_TABLES_PVT.delete_table: before loop l_any_rows_to_process is true ' );
debugmsg('CN_PURGE_TABLES_PVT.delete_table: before loop l_any_rows_to_process is false ' );
DELETE
/*+ ROWID (cnh) */
FROM CN_PAYMENT_API_ALL cnh
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_posting_details_all cnh
WHERE pay_period_id BETWEEN p_start_period_id AND p_end_period_id
AND paid_flag = 'Y'
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_payment_transactions_all cnh
WHERE pay_period_id BETWEEN p_start_period_id AND p_end_period_id
AND paid_flag = 'Y'
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_commission_lines_all cnh
WHERE processed_period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_commission_headers_all cnh
WHERE processed_period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_trx_sales_lines_all cnh
WHERE processed_date BETWEEN x_start_date AND x_end_date
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (t1) */
FROM cn_trx_lines_all tl
WHERE tl.TRX_ID IN
(SELECT DISTINCT t.TRX_ID
FROM cn_trx_all t
WHERE TRUNC(t.processed_date) BETWEEN x_start_date AND x_end_date
);
DELETE
/*+ ROWID (cnh) */
FROM cn_trx_all cnh
WHERE processed_date BETWEEN x_start_date AND x_end_date
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_not_trx_all cnh
WHERE processed_date BETWEEN x_start_date AND x_end_date
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (i) */
FROM cn_invoice_changes_all i
WHERE i.comm_lines_api_id IN
(SELECT DISTINCT c.comm_lines_api_id
FROM cn_comm_lines_api_all c
WHERE c.processed_period_id BETWEEN p_start_period_id AND p_end_period_id
)
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
l_sql := 'DELETE
/*+ ROWID (ih) */
FROM cn_imp_headers ih
WHERE ih.imp_header_id IN ' || p_addnl_para ||
' AND rowid BETWEEN ' || l_start_rowid || ' AND ' || l_end_rowid;
l_sql := 'DELETE
/*+ ROWID (cnh) */
FROM cn_imp_lines cnh
WHERE import_type_code = ''TRXAPI''
AND imp_header_id IN ' || p_addnl_para ||
' AND rowid BETWEEN ' || l_start_rowid || ' AND ' || l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_comm_lines_api_all cnh
WHERE processed_period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (qa) */
FROM cn_srp_quota_assigns_all qa
WHERE qa.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
)
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (ra) */
FROM cn_srp_rate_assigns_all ra
WHERE ra.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
)
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (ru) */
FROM cn_srp_rule_uplifts_all ru
WHERE ru.srp_quota_rule_id IN
(SELECT DISTINCT qr.srp_quota_rule_id
FROM cn_srp_quota_rules_all qr
WHERE qr.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
)
)
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (ra) */
FROM cn_srp_quota_rules_all ra
WHERE ra.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
)
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_srp_plan_assigns_all cnh
WHERE ((start_date BETWEEN x_start_date AND x_end_date)
AND (end_date BETWEEN x_start_date AND x_end_date))
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (qe) */
FROM cn_srp_period_quotas_ext_all qe
WHERE qe.srp_period_quota_id IN
(SELECT DISTINCT qa.srp_period_quota_id
FROM cn_srp_period_quotas_all qa
WHERE qa.period_id BETWEEN p_start_period_id AND p_end_period_id
)
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_srp_per_quota_rc_all cnh
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_srp_period_quotas_all cnh
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (af) */
FROM cn_pay_approval_flow_all af
WHERE af.payrun_id IN
(SELECT DISTINCT pa.payrun_id
FROM cn_payruns_all pa
WHERE pa.PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id
)
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_worksheet_qg_dtls_all cnh
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (pw) */
FROM cn_payment_worksheets_all pw
WHERE pw.payrun_id IN
(SELECT DISTINCT pa.payrun_id
FROM cn_payruns_all pa
WHERE pa.PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id
)
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (je) */
FROM cn_ledger_journal_entries_all je
WHERE je.srp_period_id IN
(SELECT DISTINCT sp.srp_period_id
FROM cn_srp_periods_all sp
WHERE sp.period_id BETWEEN p_start_period_id AND p_end_period_id
)
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_posting_details_sum_all cnh
WHERE pay_period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (wb) */
FROM cn_worksheet_bonuses_all wb
WHERE wb.payrun_id IN
(SELECT DISTINCT pa.payrun_id
FROM cn_payruns_all pa
WHERE pa.PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id
)
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (pw) */
FROM cn_payment_worksheets_all pw
WHERE pw.payrun_id IN
(SELECT DISTINCT pa.payrun_id
FROM cn_payruns_all pa
WHERE pa.PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id
)
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_payruns_all cnh
WHERE pay_period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_srp_periods_all cnh
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_process_audits_all cnh
WHERE rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_process_audit_lines_all cnh
WHERE rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_process_batches_all cnh
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
DELETE
/*+ ROWID (cnh) */
FROM cn_srp_intel_periods_all cnh
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id
AND rowid BETWEEN l_start_rowid AND l_end_rowid;
debugmsg('Before ad_parallel_updates_pkg.processed_rowid_range value_error - ' || sqlerrm);
debugmsg('Before ad_parallel_updates_pkg.processed_rowid_range error - ' || sqlerrm);
ad_parallel_updates_pkg.processed_rowid_range( l_rows_processed, l_END_rowid);
ad_parallel_updates_pkg.get_rowid_range( l_start_rowid, l_end_rowid, l_any_rows_to_process, p_batch_size, FALSE);
SELECT TO_CHAR(sysdate,'dd-mm-rr:hh:mi:ss') INTO l_time FROM dual;
debugmsg('CN_PURGE_TABLES_PVT.delete_table: delete end l_time ' || l_time );
debugmsg('CN_PURGE_TABLES_PVT.delete_table:end final ' );
END delete_table;
SELECT DISTINCT h.imp_header_id
FROM cn_imp_headers h
WHERE exists (select distinct l.imp_header_id from cn_imp_lines l where h.imp_header_id = l.imp_header_id
and to_date(l.col3, 'dd-mm-rr') between x_start_date AND x_end_date
and h.imp_header_id not in (select distinct l2.imp_header_id from cn_imp_lines l2 where
to_date(l2.col3, 'dd-mm-rr') not between x_start_date AND x_end_date
));
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => l_imp_header_id_list,
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => l_imp_header_id_list,
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
SELECT DISTINCT h.imp_header_id
FROM cn_imp_headers h
WHERE exists (select distinct l.imp_header_id from cn_imp_lines l where h.imp_header_id = l.imp_header_id
and to_date(l.col3, 'dd-mm-rr') between x_start_date AND x_end_date
and h.imp_header_id not in (select distinct l2.imp_header_id from cn_imp_lines l2 where
to_date(l2.col3, 'dd-mm-rr') not between x_start_date AND x_end_date
));
SELECT COUNT(*)
INTO l_row_count
FROM cn_payment_api_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_payment_api_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_posting_details_all
WHERE pay_period_id BETWEEN p_start_period_id AND p_end_period_id
AND paid_flag = 'Y';
insert_archive(cn_posting_details_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_payment_transactions_all
WHERE pay_period_id BETWEEN p_start_period_id AND p_end_period_id
AND paid_flag = 'Y';
insert_archive(cn_payment_transactions_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_commission_lines_all
WHERE processed_period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_commission_lines_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_commission_headers_all
WHERE processed_period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_commission_headers_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_trx_sales_lines_all
WHERE TRUNC(processed_date) BETWEEN x_start_date AND x_end_date;
insert_archive(cn_trx_sales_lines_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_trx_lines_all tl
WHERE tl.TRX_ID IN
(SELECT DISTINCT t.TRX_ID
FROM cn_trx_all t
WHERE TRUNC(t.processed_date) BETWEEN x_start_date AND x_end_date
);
insert_archive(cn_trx_lines_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_trx_all
WHERE TRUNC(processed_date) BETWEEN x_start_date AND x_end_date;
insert_archive(cn_trx_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_not_trx_all
WHERE processed_date BETWEEN x_start_date AND x_end_date;
insert_archive(cn_not_trx_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_invoice_changes_all i
WHERE i.comm_lines_api_id IN
(SELECT DISTINCT c.comm_lines_api_id
FROM cn_comm_lines_api_all c
WHERE c.processed_period_id BETWEEN p_start_period_id AND p_end_period_id
);
insert_archive(cn_invoice_changes_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := 'SELECT COUNT(*) FROM cn_imp_lines WHERE import_type_code = ''TRXAPI'' AND imp_header_id in ' || l_imp_header_id_list;
insert_archive(cn_imp_lines_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := 'SELECT COUNT(*) FROM cn_imp_headers ih WHERE ih.imp_header_id IN ' || l_imp_header_id_list;
insert_archive(cn_imp_headers_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_comm_lines_api_all
WHERE processed_period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_comm_lines_api_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_period_quotas_ext_all qe
WHERE qe.srp_period_quota_id IN
(SELECT DISTINCT qa.srp_period_quota_id
FROM cn_srp_period_quotas_all qa
WHERE qa.period_id BETWEEN p_start_period_id AND p_end_period_id
);
insert_archive(cn_srp_period_quotas_ext_all_i,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_per_quota_rc_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_srp_per_quota_rc_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_period_quotas_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_srp_period_quotas_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_pay_approval_flow_all af
WHERE af.payrun_id IN
(SELECT DISTINCT pa.payrun_id
FROM cn_payruns_all pa
WHERE pa.PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id
);
insert_archive(cn_pay_approval_flow_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_worksheet_qg_dtls_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_worksheet_qg_dtls_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_payment_worksheets_all pw
WHERE pw.payrun_id IN
(SELECT DISTINCT pa.payrun_id
FROM cn_payruns_all pa
WHERE pa.PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id
);
insert_archive(cn_payment_worksheets_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_ledger_journal_entries_all je
WHERE je.srp_period_id IN
(SELECT DISTINCT sp.srp_period_id
FROM cn_srp_periods_all sp
WHERE sp.period_id BETWEEN p_start_period_id AND p_end_period_id
);
insert_archive(cn_ledger_journal_entries_alli,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_posting_details_sum_all
WHERE pay_period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_posting_details_sum_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_worksheet_bonuses_all wb
WHERE wb.payrun_id IN
(SELECT DISTINCT pa.payrun_id
FROM cn_payruns_all pa
WHERE pa.PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id
);
insert_archive(cn_worksheet_bonuses_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_payruns_all
WHERE PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_payruns_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_periods_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_srp_periods_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_payee_assigns_all pa
WHERE pa.srp_quota_assign_id IN
(SELECT DISTINCT qa.srp_quota_assign_id
FROM cn_srp_period_quotas_all qa
WHERE qa.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
)
);
insert_archive(cn_srp_payee_assigns_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_quota_assigns_all qa
WHERE qa.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
);
insert_archive(cn_srp_quota_assigns_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_rate_assigns_all ra
WHERE ra.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND pl.end_date BETWEEN x_start_date AND x_end_date)
);
insert_archive(cn_srp_rate_assigns_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_rule_uplifts_all ru
WHERE ru.srp_quota_rule_id IN
(SELECT DISTINCT qr.srp_quota_rule_id
FROM cn_srp_quota_rules_all qr
WHERE qr.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
)
);
insert_archive(cn_srp_rule_uplifts_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_quota_rules_all ra
WHERE ra.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
);
insert_archive(cn_srp_quota_rules_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_plan_assigns_all
WHERE ((start_date BETWEEN x_start_date AND x_end_date)
AND (end_date BETWEEN x_start_date AND x_end_date));
insert_archive(cn_srp_plan_assigns_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
delete_table ( p_start_period_id => p_start_period_id,
p_end_period_id => p_end_period_id,
x_start_date => x_start_date,
x_end_date => x_end_date,
p_worker_id => p_worker_id,
p_no_of_workers => p_no_of_workers,
p_batch_size => p_batch_size,
p_table_owner => l_table_owner,
p_table_name => upper(l_table_name),
p_script_name => g_script_name || '_' || p_cn_archive_all_s,
p_addnl_para => '',
x_row_to_process_flag => l_any_rows_to_process,
x_return_status => x_return_status );
SELECT COUNT(*) INTO l_row_count FROM cn_process_audit_lines_all;
insert_archive(cn_process_audit_lines_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*) INTO l_row_count FROM cn_process_audits_all;
insert_archive(cn_process_audits_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_process_batches_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_process_batches_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_intel_periods_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_srp_intel_periods_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT DISTINCT h.imp_header_id
FROM cn_imp_headers h
WHERE exists (select distinct l.imp_header_id from cn_imp_lines l where h.imp_header_id = l.imp_header_id
and to_date(l.col3, 'dd-mm-rr') between x_start_date AND x_end_date
and h.imp_header_id not in (select distinct l2.imp_header_id from cn_imp_lines l2 where
to_date(l2.col3, 'dd-mm-rr') not between x_start_date AND x_end_date
));
l_sql := l_sql || ' as select * from CN_PAYMENT_API_ALL where period_id between ' || p_start_period_id || ' and ' || p_end_period_id;
SELECT COUNT(*)
INTO l_row_count
FROM cn_payment_api_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_payment_api_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_posting_details_all where pay_period_id between ' || p_start_period_id || ' and ' || p_end_period_id || ' and paid_flag = ''Y''';
SELECT COUNT(*)
INTO l_row_count
FROM cn_posting_details_all
WHERE pay_period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_posting_details_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_payment_transactions_all where pay_period_id between ' || p_start_period_id || ' and ' || p_end_period_id || ' and paid_flag = ''Y''';
SELECT COUNT(*)
INTO l_row_count
FROM cn_payment_transactions_all
WHERE pay_period_id BETWEEN p_start_period_id AND p_end_period_id
AND paid_flag = 'Y';
insert_archive(cn_payment_transactions_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_commission_lines_all where processed_period_id between ' || p_start_period_id || ' and ' || p_end_period_id;
SELECT COUNT(*)
INTO l_row_count
FROM cn_commission_lines_all
WHERE processed_period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_commission_lines_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_commission_headers_all where processed_period_id between ' || p_start_period_id || ' and ' || p_end_period_id;
SELECT COUNT(*)
INTO l_row_count
FROM cn_commission_headers_all
WHERE processed_period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_commission_headers_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_trx_sales_lines_all where TRUNC(processed_date) between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||'''';
SELECT COUNT(*)
INTO l_row_count
FROM cn_trx_sales_lines_all
WHERE TRUNC(processed_date) BETWEEN x_start_date AND x_end_date;
insert_archive(cn_trx_sales_lines_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_trx_lines_all tl where tl.TRX_ID in (Select distinct t.TRX_ID from cn_trx_all t where TRUNC(t.processed_date) between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||'''' || ' ) ';
SELECT COUNT(*)
INTO l_row_count
FROM cn_trx_lines_all tl
WHERE tl.TRX_ID IN
(SELECT DISTINCT t.TRX_ID
FROM cn_trx_all t
WHERE TRUNC(t.processed_date) BETWEEN x_start_date AND x_end_date
);
insert_archive(cn_trx_lines_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_trx_all where TRUNC(processed_date) between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||'''';
SELECT COUNT(*)
INTO l_row_count
FROM cn_trx_all
WHERE TRUNC(processed_date) BETWEEN x_start_date AND x_end_date;
insert_archive(cn_trx_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_not_trx_all where processed_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||'''';
SELECT COUNT(*)
INTO l_row_count
FROM cn_not_trx_all
WHERE processed_date BETWEEN x_start_date AND x_end_date;
insert_archive(cn_not_trx_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_invoice_changes_all i where i.comm_lines_api_id in ' ||
' (select distinct c.comm_lines_api_id from cn_comm_lines_api_all c where c.processed_period_id between ' ||
p_start_period_id || ' and ' || p_end_period_id || ' ) ';
SELECT COUNT(*)
INTO l_row_count
FROM cn_invoice_changes_all i
WHERE i.comm_lines_api_id IN
(SELECT DISTINCT c.comm_lines_api_id
FROM cn_comm_lines_api_all c
WHERE c.processed_period_id BETWEEN p_start_period_id AND p_end_period_id );
insert_archive(cn_invoice_changes_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_imp_lines il where il.import_type_code = ''TRXAPI'' and il.imp_header_id in '
|| l_imp_header_id_list;
l_sql := 'SELECT COUNT(*) FROM cn_imp_lines WHERE import_type_code = ''TRXAPI'' AND imp_header_id in ' || l_imp_header_id_list;
insert_archive(cn_imp_lines_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_imp_headers ih where ih.imp_header_id in '
|| l_imp_header_id_list;
l_sql := 'SELECT COUNT(*) FROM cn_imp_headers ih WHERE ih.imp_header_id IN ' || l_imp_header_id_list;
insert_archive(cn_imp_headers_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_comm_lines_api_all where processed_period_id between ' || p_start_period_id || ' and ' || p_end_period_id;
SELECT COUNT(*)
INTO l_row_count
FROM cn_comm_lines_api_all
WHERE processed_period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_comm_lines_api_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_srp_period_quotas_ext_all qe where ' ||
' qe.srp_period_quota_id in (Select distinct qa.srp_period_quota_id from cn_srp_period_quotas_all qa where qa.period_id between ' ||
p_start_period_id || ' and ' || p_end_period_id || ' ) ';
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_period_quotas_ext_all qe
WHERE qe.srp_period_quota_id IN
(SELECT DISTINCT qa.srp_period_quota_id
FROM cn_srp_period_quotas_all qa
WHERE qa.period_id BETWEEN p_start_period_id AND p_end_period_id
);
insert_archive(cn_srp_period_quotas_ext_all_i,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_srp_per_quota_rc_all where period_id between ' || p_start_period_id || ' and ' || p_end_period_id ;
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_per_quota_rc_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_srp_per_quota_rc_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_srp_period_quotas_all where period_id between ' || p_start_period_id || ' and ' || p_end_period_id;
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_period_quotas_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_srp_period_quotas_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_pay_approval_flow_all af where af.payrun_id in (Select distinct pa.payrun_id from cn_payruns_all pa where pa.PAY_PERIOD_ID between ' || p_start_period_id || ' and ' || p_end_period_id || ' ) ';
SELECT COUNT(*)
INTO l_row_count
FROM cn_pay_approval_flow_all af
WHERE af.payrun_id IN
(SELECT DISTINCT pa.payrun_id
FROM cn_payruns_all pa
WHERE pa.PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id
);
insert_archive(cn_pay_approval_flow_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_worksheet_qg_dtls_all where period_id between ' || p_start_period_id || ' and ' || p_end_period_id;
SELECT COUNT(*)
INTO l_row_count
FROM cn_worksheet_qg_dtls_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_worksheet_qg_dtls_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_payment_worksheets_all pw where pw.payrun_id in (Select distinct pa.payrun_id from cn_payruns_all pa where pa.PAY_PERIOD_ID between ' || p_start_period_id || ' and ' || p_end_period_id || ' ) ';
SELECT COUNT(*)
INTO l_row_count
FROM cn_payment_worksheets_all pw
WHERE pw.payrun_id IN
(SELECT DISTINCT pa.payrun_id
FROM cn_payruns_all pa
WHERE pa.PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id
);
insert_archive(cn_payment_worksheets_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_ledger_journal_entries_all je where je.srp_period_id in (Select distinct sp.srp_period_id from cn_srp_periods_all sp where sp.period_id between ' || p_start_period_id || ' and ' || p_end_period_id || ' ) ';
SELECT COUNT(*)
INTO l_row_count
FROM cn_ledger_journal_entries_all je
WHERE je.srp_period_id IN
(SELECT DISTINCT sp.srp_period_id
FROM cn_srp_periods_all sp
WHERE sp.period_id BETWEEN p_start_period_id AND p_end_period_id
);
insert_archive(cn_ledger_journal_entries_alli,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_posting_details_sum_all where pay_period_id between ' || p_start_period_id || ' and ' || p_end_period_id;
SELECT COUNT(*)
INTO l_row_count
FROM cn_posting_details_sum_all
WHERE pay_period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_posting_details_sum_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_worksheet_bonuses_all wb where wb.payrun_id in (Select distinct pa.payrun_id from cn_payruns_all pa where pa.PAY_PERIOD_ID between ' || p_start_period_id || ' and ' || p_end_period_id || ' ) ';
SELECT COUNT(*)
INTO l_row_count
FROM cn_worksheet_bonuses_all wb
WHERE wb.payrun_id IN
(SELECT DISTINCT pa.payrun_id
FROM cn_payruns_all pa
WHERE pa.PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id
);
insert_archive(cn_worksheet_bonuses_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_payruns_all where PAY_PERIOD_ID between ' || p_start_period_id || ' and ' || p_end_period_id;
SELECT COUNT(*)
INTO l_row_count
FROM cn_payruns_all
WHERE PAY_PERIOD_ID BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_payruns_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_srp_periods_all where period_id between ' || p_start_period_id || ' and ' || p_end_period_id;
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_periods_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_srp_periods_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_srp_payee_assigns_all pa where pa.srp_quota_assign_id in (Select distinct qa.srp_quota_assign_id from cn_srp_period_quotas_all qa where qa.srp_plan_assign_id in (Select distinct pl.srp_plan_assign_id
from cn_srp_plan_assigns_all pl where ((pl.start_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||''''
|| ' ) and (pl.end_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||'''' || '))))';
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_payee_assigns_all pa
WHERE pa.srp_quota_assign_id IN
(SELECT DISTINCT qa.srp_quota_assign_id
FROM cn_srp_period_quotas_all qa
WHERE qa.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
)
);
insert_archive(cn_srp_payee_assigns_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_srp_quota_assigns_all qa where qa.srp_plan_assign_id in (Select distinct pl.srp_plan_assign_id from cn_srp_plan_assigns_all pl
where ((pl.start_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||''''
|| ' ) and (pl.end_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||'''' || ')))';
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_quota_assigns_all qa
WHERE qa.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
);
insert_archive(cn_srp_quota_assigns_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_srp_rate_assigns_all ra where ra.srp_plan_assign_id in (Select distinct pl.srp_plan_assign_id from cn_srp_plan_assigns_all pl
where ((pl.start_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||''''
|| ' ) and pl.end_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||'''' || '))';
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_rate_assigns_all ra
WHERE ra.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND pl.end_date BETWEEN x_start_date AND x_end_date)
);
insert_archive(cn_srp_rate_assigns_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_srp_rule_uplifts_all ru ' ||
' where ru.srp_quota_rule_id in (Select distinct qr.srp_quota_rule_id from cn_srp_quota_rules_all qr ' ||
' where qr.srp_plan_assign_id in (Select distinct pl.srp_plan_assign_id from cn_srp_plan_assigns_all pl ' ||
' where ((pl.start_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||''''
|| ' ) and (pl.end_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||'''' || '))))';
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_rule_uplifts_all ru
WHERE ru.srp_quota_rule_id IN
(SELECT DISTINCT qr.srp_quota_rule_id
FROM cn_srp_quota_rules_all qr
WHERE qr.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
)
);
insert_archive(cn_srp_rule_uplifts_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_srp_quota_rules_all ra where ra.srp_plan_assign_id in (Select distinct pl.srp_plan_assign_id from cn_srp_plan_assigns_all pl
where ((pl.start_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||''''
|| ' ) and (pl.end_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||'''' || ')))';
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_quota_rules_all ra
WHERE ra.srp_plan_assign_id IN
(SELECT DISTINCT pl.srp_plan_assign_id
FROM cn_srp_plan_assigns_all pl
WHERE ((pl.start_date BETWEEN x_start_date AND x_end_date)
AND (pl.end_date BETWEEN x_start_date AND x_end_date))
);
insert_archive(cn_srp_quota_rules_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_srp_plan_assigns_all where ((start_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||'''' || ') and (end_date between ''' || x_start_date ||'''' || ' and ''' || x_end_date ||'''' || ' ))';
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_plan_assigns_all
WHERE ((start_date BETWEEN x_start_date AND x_end_date)
AND (end_date BETWEEN x_start_date AND x_end_date));
insert_archive(cn_srp_plan_assigns_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_process_batches_all where period_id between ' || p_start_period_id || ' and ' || p_end_period_id;
SELECT COUNT(*)
INTO l_row_count
FROM cn_process_batches_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_process_batches_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
l_sql := l_sql || ' as select * from cn_srp_intel_periods_all where period_id between ' || p_start_period_id || ' and ' || p_end_period_id;
SELECT COUNT(*)
INTO l_row_count
FROM cn_srp_intel_periods_all
WHERE period_id BETWEEN p_start_period_id AND p_end_period_id;
insert_archive(cn_srp_intel_periods_all_id,p_cn_archive_all_s,upper(l_table_name),l_row_count,l_any_rows_to_process);
SELECT CN_ARC_AUDIT_ALL_S.nextval INTO l_cn_archive_all_s FROM dual;
INSERT
INTO cn_arc_audit_all
(ARCHIVE_PURGE_ID,TOT_AP_TABLES_COUNT,TOT_AP_ROWS,ARCHIVE_PURGE_DATE,START_PERIOD_ID,END_PERIOD_ID,ORG_ID,RUN_MODE,
ATTRIBUTE1,ATTRIBUTE2,ATTRIBUTE3,ATTRIBUTE4,ATTRIBUTE5,CREATED_BY,CREATION_DATE,LAST_UPDATED_BY,LAST_UPDATE_DATE,LAST_UPDATE_LOGIN)
VALUES
(
l_cn_archive_all_s,
x_msg_count ,
l_tot_rows_count ,
sysdate ,
p_start_period_id ,
p_end_period_id ,
p_org_id ,
l_run_mode ,
NULL ,
NULL ,
NULL ,
NULL ,
NULL ,
fnd_global.user_id,
sysdate ,
fnd_global.user_id,
sysdate ,
fnd_global.user_id
);
SELECT CN_ARC_AUDIT_ALL_S.nextval INTO l_cn_archive_all_s FROM dual;
SELECT CN_ARC_AUDIT_ALL_S.nextval INTO l_cn_archive_all_s FROM dual;
INSERT
INTO cn_arc_audit_all
(ARCHIVE_PURGE_ID,TOT_AP_TABLES_COUNT,TOT_AP_ROWS,ARCHIVE_PURGE_DATE,START_PERIOD_ID,END_PERIOD_ID,ORG_ID,RUN_MODE,
ATTRIBUTE1,ATTRIBUTE2,ATTRIBUTE3,ATTRIBUTE4,ATTRIBUTE5,CREATED_BY,CREATION_DATE,LAST_UPDATED_BY,LAST_UPDATE_DATE,LAST_UPDATE_LOGIN)
VALUES
(
l_cn_archive_all_s,
x_msg_count ,
l_tot_rows_count ,
sysdate ,
p_start_period_id ,
p_end_period_id ,
p_org_id ,
l_run_mode ,
NULL ,
NULL ,
NULL ,
NULL ,
NULL ,
fnd_global.user_id,
sysdate ,
fnd_global.user_id,
sysdate ,
fnd_global.user_id
);