The following lines contain the word 'select', 'insert', 'update' or 'delete':
SELECT DELETED_FLAG, ROWID FROM CZ_IMP_PRICE WHERE REC_STATUS IS NULL AND RUN_ID = inRUN_ID;
IF (p_imp_price.DELETED_FLAG IS NULL) THEN
BEGIN
UPDATE CZ_IMP_PRICE SET DELETED_FLAG=DECODE(DELETED_FLAG,NULL,'0',DELETED_FLAG) WHERE ROWID = p_imp_price.ROWID;
SELECT DELETED_FLAG, ROWID FROM CZ_IMP_PRICE_GROUP WHERE REC_STATUS IS NULL AND RUN_ID = inRUN_ID;
IF (p_imp_pricegroup.DELETED_FLAG IS NULL) THEN
BEGIN
UPDATE CZ_IMP_PRICE_GROUP SET DELETED_FLAG=DECODE(DELETED_FLAG,NULL,'0',DELETED_FLAG) WHERE ROWID = p_imp_pricegroup.ROWID;
INSERTS IN OUT NOCOPY PLS_INTEGER,
UPDATES IN OUT NOCOPY PLS_INTEGER,
FAILED IN OUT NOCOPY PLS_INTEGER,
DUPS IN OUT NOCOPY PLS_INTEGER,
inXFR_GROUP IN VARCHAR2
) IS
BEGIN
DECLARE
/* Internal vars */
nCommitCount PLS_INTEGER:=0; /*COMMIT buffer index */
nXfrInsertCount PLS_INTEGER:=0; /*Inserts */
nXfrUpdateCount PLS_INTEGER:=0; /*Updates */
SELECT 'X' INTO dummy FROM CZ_XFR_RUN_INFOS WHERE RUN_ID=inRUN_ID;
UPDATE CZ_XFR_RUN_INFOS SET
STARTED=SYSDATE,
LAST_ACTIVITY=SYSDATE
WHERE RUN_ID=inRUN_ID;
INSERT INTO CZ_XFR_RUN_INFOS (RUN_ID,STARTED,LAST_ACTIVITY)
VALUES(inRUN_ID,SYSDATE,SYSDATE);
INSERTS:=0;
UPDATES:=0;
CZ_IMP_PR_KRS.KRS_PRICE (inRUN_ID,COMMIT_SIZE,MAX_ERR,INSERTS,UPDATES,nFailed,DUPS,inXFR_GROUP);
CZ_IMP_PR_XFR.XFR_PRICE (inRUN_ID,COMMIT_SIZE,MAX_ERR-nFailed,nXfrInsertCount,nXfrUpdateCount,FAILED,inXFR_GROUP);
/* Report Insert Errors */
IF (nXfrInsertCount<> INSERTS) THEN
x_error:=CZ_IMP_ALL.REPORT(CZ_UTILS.GET_TEXT('CZ_IMP_INSERTERRORS','RESOLVED',to_char(INSERTS),'ACTUAL',to_char(nXfrInsertCount)),1,'CZ_IMP_PR_MAIN.MAIN_PRICE ',11276);
/* Report Update Errors */
IF (nXfrUpdateCount<> UPDATES) THEN
x_error:=CZ_IMP_ALL.REPORT(CZ_UTILS.GET_TEXT('CZ_IMP_UPDATEERRORS','RESOLVED',to_char(UPDATES),'ACTUAL',to_char(nXfrUpdateCount)),1,'CZ_IMP_PR_MAIN.MAIN_PRICE',11276);
INSERTS:=nXfrInsertCount;
UPDATES:=nXfrUpdateCount;
INSERTS IN OUT NOCOPY PLS_INTEGER,
UPDATES IN OUT NOCOPY PLS_INTEGER,
FAILED IN OUT NOCOPY PLS_INTEGER,
DUPS IN OUT NOCOPY PLS_INTEGER,
inXFR_GROUP IN VARCHAR2
) IS
BEGIN
DECLARE
/* Internal vars */
nCommitCount PLS_INTEGER:=0; /*COMMIT buffer index */
nXfrInsertCount PLS_INTEGER:=0; /*Inserts */
nXfrUpdateCount PLS_INTEGER:=0; /*Updates */
SELECT 'X' INTO dummy FROM CZ_XFR_RUN_INFOS WHERE RUN_ID=inRUN_ID;
UPDATE CZ_XFR_RUN_INFOS SET
STARTED=SYSDATE,
LAST_ACTIVITY=SYSDATE
WHERE RUN_ID=inRUN_ID;
INSERT INTO CZ_XFR_RUN_INFOS (RUN_ID,STARTED,LAST_ACTIVITY)
VALUES(inRUN_ID,SYSDATE,SYSDATE);
INSERTS:=0;
UPDATES:=0;
CZ_IMP_PR_KRS.KRS_PRICE_GROUP (inRUN_ID,COMMIT_SIZE,MAX_ERR,INSERTS,UPDATES,nFailed,DUPS,inXFR_GROUP);
CZ_IMP_PR_XFR.XFR_PRICE_GROUP(inRUN_ID,COMMIT_SIZE,MAX_ERR-nFailed,nXfrInsertCount,nXfrUpdateCount,FAILED,inXFR_GROUP);
/* Report Insert Errors */
IF (nXfrInsertCount<> INSERTS) THEN
x_error:=CZ_IMP_ALL.REPORT(CZ_UTILS.GET_TEXT('CZ_IMP_INSERTERRORS','RESOLVED',to_char(INSERTS),'ACTUAL',to_char(nXfrInsertCount)),1,'CZ_IMP_PR_MAIN.MAIN_PRICE_GROUP ',11276);
/* Report Update Errors */
IF (nXfrUpdateCount<> UPDATES) THEN
x_error:=CZ_IMP_ALL.REPORT(CZ_UTILS.GET_TEXT('CZ_IMP_UPDATEERRORS','RESOLVED',to_char(UPDATES),'ACTUAL',to_char(nXfrUpdateCount)),1,'CZ_IMP_PR_MAIN.MAIN_PRICE_GROUP ',11276);
INSERTS:=nXfrInsertCount;
UPDATES:=nXfrUpdateCount;
DELETE FROM CZ_XFR_RUN_RESULTS WHERE RUN_ID=inRUN_ID AND IMP_TABLE='CZ_PRICES';
SELECT DISPOSITION,REC_STATUS,COUNT(*)
FROM CZ_IMP_price
WHERE RUN_ID = inRUN_ID
GROUP BY DISPOSITION,REC_STATUS;
INSERT INTO CZ_XFR_RUN_RESULTS(RUN_ID,IMP_TABLE,DISPOSITION,REC_STATUS,RECORDS)
VALUES(inRUN_ID,'CZ_PRICES',ins_disposition,ins_rec_status,ins_rec_count);
SELECT SUM(NVL(RECORDS,0)) FROM CZ_XFR_RUN_RESULTS
WHERE REC_STATUS<>'OK' AND RUN_ID=inRUN_ID
AND IMP_TABLE='CZ_PRICES';
UPDATE CZ_XFR_RUN_INFOS
SET TOTAL_ERRORS=NVL(TOTAL_ERRORS,0)+NVL(nErrors,0),
COMPLETED='1'
WHERE RUN_ID=inRUN_ID;
DELETE FROM CZ_XFR_RUN_RESULTS WHERE RUN_ID=inRUN_ID AND IMP_TABLE='CZ_PRICE_GROUPS';
SELECT DISPOSITION,REC_STATUS,COUNT(*)
FROM CZ_IMP_price_group
WHERE RUN_ID = inRUN_ID
GROUP BY DISPOSITION,REC_STATUS;
INSERT INTO CZ_XFR_RUN_RESULTS(RUN_ID,IMP_TABLE,DISPOSITION,REC_STATUS,RECORDS)
VALUES(inRUN_ID,'CZ_PRICE_GROUPS',ins_disposition,ins_rec_status,ins_rec_count);
SELECT SUM(NVL(RECORDS,0)) FROM CZ_XFR_RUN_RESULTS
WHERE REC_STATUS<>'OK' AND RUN_ID=inRUN_ID
AND IMP_TABLE='CZ_PRICE_GROUPS';
UPDATE CZ_XFR_RUN_INFOS
SET TOTAL_ERRORS=NVL(TOTAL_ERRORS,0)+NVL(nErrors,0),
COMPLETED='1'
WHERE RUN_ID=inRUN_ID;