The following lines contain the word 'select', 'insert', 'update' or 'delete':
debug_mode_on_insert BOOLEAN := FALSE;
debug_mode_on_select BOOLEAN := FALSE;
PROCEDURE select_clause(
cTransaction_Type IN VARCHAR2,
cCommunication_Method IN VARCHAR2,
cInterface_Table IN VARCHAR2,
p_source_tbl IN ece_flatfile_pvt.Interface_tbl_type,
cSelect_string OUT NOCOPY VARCHAR2,
cFrom_string OUT NOCOPY VARCHAR2,
cWhere_string OUT NOCOPY VARCHAR2) IS
xProgress VARCHAR2(30);
cSelect_stmt VARCHAR2(32000) := 'SELECT ';
EC_DEBUG.PUSH('ece_extract_utils_pub.select_clause');
cSelect_stmt := cSelect_stmt || ' ' || cWord1 || nvl(p_source_tbl(i).base_column_Name,'NULL') || cWord2 || ',';
cSelect_string := RTRIM (cSelect_stmt, ',');
if (debug_mode_on_select) then
declare
stmt_1 varchar2(2000) := substrb(RTRIM(cSelect_stmt, ','), 1, 2000);
stmt_2 varchar2(2000) := substrb(RTRIM(cSelect_stmt, ','), 2001, 2000);
stmt_3 varchar2(2000) := substrb(RTRIM(cSelect_stmt, ','), 4001, 2000);
insert into ece_error (creation_date, run_id, line_id, text)
values( sysdate, 76451, ece_error_s.nextval, stmt_1);
insert into ece_error (creation_date, run_id, line_id, text)
values( sysdate, 76451, ece_error_s.nextval, stmt_2);
insert into ece_error (creation_date, run_id, line_id, text)
values( sysdate, 76451, ece_error_s.nextval, stmt_3);
EC_DEBUG.POP('ece_extract_utils_pub.select_clause');
EC_DEBUG.PL(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','ECE_EXTRACT_UTILS_PUB.Select_Clause');
END select_clause;
PROCEDURE insert_into_interface_tbl(
iRun_id IN NUMBER,
cTransaction_Type IN VARCHAR2,
cCommunication_Method IN VARCHAR2,
cInterface_Table IN VARCHAR2,
p_source_tbl IN ece_flatfile_pvt.Interface_tbl_type,
p_foreign_key IN NUMBER
)
IS
xProgress VARCHAR2(30);
cInsert_stmt VARCHAR2(32000) := 'INSERT INTO ';
c_Insert_cur INTEGER;
EC_DEBUG.PUSH('ece_extract_utils_pub.insert_into_interface_tbl');
cInsert_stmt := cInsert_stmt || ' ' || cInterface_Table || '( ';
EC_DEBUG.PL(3, 'cInsert_stmt: ',cInsert_stmt);
cInsert_stmt := cInsert_stmt || ' ' ||
p_source_tbl(i).interface_column_Name || ',';
cInsert_stmt := RTRIM(cInsert_stmt, ',') || ')';
cInsert_stmt := cInsert_stmt || cValue_stmt;
EC_DEBUG.PL(3, 'cInsert_stmt: ',cInsert_stmt);
c_Insert_cur := dbms_sql.open_cursor;
EC_DEBUG.PL(3, 'c_Insert_cur: ',c_Insert_cur);
dbms_sql.parse(c_Insert_cur, cInsert_stmt, dbms_sql.native);
dbms_sql.bind_variable(c_Insert_cur,'b'||i,iRun_id);
dbms_sql.bind_variable(c_Insert_cur,'b'||i,p_foreign_key);
dbms_sql.bind_variable(c_Insert_cur,'b'||i,d_date);
dbms_sql.bind_variable(c_Insert_cur,'b'||i,n_number);
dbms_sql.bind_variable(c_Insert_cur,'b'||i,cValue);
cInsert_stmt := cInsert_stmt || ' ' ||
p_source_tbl(i).interface_column_Name || ',';
cInsert_stmt := RTRIM(cInsert_stmt, ',') || ')';
cInsert_stmt := cInsert_stmt || cValue_stmt;
EC_DEBUG.PL(3, 'cInsert_stmt: ',cInsert_stmt);
c_Insert_cur := dbms_sql.open_cursor;
EC_DEBUG.PL(3, 'c_Insert_cur: ',c_Insert_cur);
dbms_sql.parse(c_Insert_cur, cInsert_stmt, dbms_sql.native);
dummy := dbms_sql.execute(c_Insert_cur);
if (debug_mode_on_insert)
then
declare
stmt_1 varchar2(2000) := substrb(cInsert_stmt, 1, 2000);
stmt_2 varchar2(2000) := substrb(cInsert_stmt, 2001, 2000);
stmt_3 varchar2(2000) := substrb(cInsert_stmt, 4001, 2000);
stmt_4 varchar2(2000) := substrb(cInsert_stmt, 6001, 2000);
stmt_5 varchar2(2000) := substrb(cInsert_stmt, 8001, 2000);
insert into ece_error (run_id, line_id, text) values( 478, ece_error_s.nextval, stmt_1);
insert into ece_error (run_id, line_id, text) values( 478, ece_error_s.nextval, stmt_2);
insert into ece_error (run_id, line_id, text) values( 478, ece_error_s.nextval, stmt_3);
insert into ece_error (run_id, line_id, text) values( 478, ece_error_s.nextval, stmt_4);
insert into ece_error (run_id, line_id, text) values( 478, ece_error_s.nextval, stmt_5);
dbms_sql.close_cursor(c_Insert_cur);
EC_DEBUG.POP('ece_extract_utils_pub.insert_into_interface_tbl');
EC_DEBUG.PL(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','ECE_EXTRACT_UTILS_PUB.Insert_into_Interface_tbl');
END insert_into_interface_tbl;
PROCEDURE insert_into_prod_interface(
p_Interface_Table IN VARCHAR2,
p_Insert_cur IN OUT NOCOPY INTEGER,
p_apps_tbl IN ece_flatfile_pvt.Interface_tbl_type)
IS
xProgress VARCHAR2(30);
cInsert_stmt VARCHAR2(32000) := 'INSERT INTO ';
c_Insert_cur INTEGER ;
if p_Insert_cur = 0
then
xProgress := 'EXTUB-30-1020';
p_Insert_cur := -911;
if p_Insert_cur < 0
then
xProgress := 'EXTUB-30-1040';
cInsert_stmt := cInsert_stmt || ' ' || p_Interface_Table || '(';
cInsert_stmt := cInsert_stmt || ' ' || p_apps_tbl(i).base_column_name || ',';
cInsert_stmt := RTRIM (cInsert_stmt, ',') || ') ';
cInsert_stmt := cInsert_stmt || cValue_stmt;
p_Insert_cur := dbms_sql.open_cursor;
stmt_1 varchar2(2000) := substrb(cInsert_stmt, 1, 2000);
stmt_2 varchar2(2000) := substrb(cInsert_stmt, 2001, 2000);
stmt_3 varchar2(2000) := substrb(cInsert_stmt, 4001, 2000);
stmt_4 varchar2(2000) := substrb(cInsert_stmt, 6001, 2000);
stmt_5 varchar2(2000) := substrb(cInsert_stmt, 8001, 2000);
insert into ece_error (run_id, line_id, text) values( 78, ece_error_s.nextval, stmt_1);
insert into ece_error (run_id, line_id, text) values( 78, ece_error_s.nextval, stmt_2);
insert into ece_error (run_id, line_id, text) values( 78, ece_error_s.nextval, stmt_3);
insert into ece_error (run_id, line_id, text) values( 78, ece_error_s.nextval, stmt_4);
insert into ece_error (run_id, line_id, text) values( 78, ece_error_s.nextval, stmt_5);
dbms_sql.parse(p_Insert_cur, cInsert_stmt, dbms_sql.native);
if p_Insert_cur > 0
then
begin
xProgress := 'EXTUB-30-1150';
dbms_sql.bind_variable(p_Insert_cur,
'b'||k,
d_date);
insert into ece_error (run_id, line_id, text) values
( 88, ece_error_s.nextval, 'b' ||k|| ' = '||d_date);
dbms_sql.bind_variable(p_Insert_cur,
'b'||k,
n_number);
insert into ece_error (run_id, line_id, text) values
( 88, ece_error_s.nextval, 'b'||k|| ' ='||n_number);
dbms_sql.bind_variable(p_Insert_cur,
'b'||k,
substrb(p_apps_tbl(k).value,
1,
p_apps_tbl(k).data_length));
insert into ece_error (run_id, line_id, text) values
( 88, ece_error_s.nextval, 'b'||k|| ' ='||p_apps_tbl(k).value);
dummy := dbms_sql.execute(p_Insert_cur);
EC_DEBUG.PL(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','ECE_EXTRACT_UTILS_PUB.insert_into_prod_interface');
END insert_into_prod_interface;
PROCEDURE insert_into_prod_interface_pvt(
p_api_version_number IN NUMBER,
p_init_msg_list IN VARCHAR2 := fnd_api.g_false,
p_simulate IN VARCHAR2 := fnd_api.g_false,
p_commit IN VARCHAR2 := fnd_api.g_false,
p_validation_level IN NUMBER := fnd_api.g_valid_level_full,
x_return_status OUT NOCOPY VARCHAR2,
x_msg_count OUT NOCOPY NUMBER,
x_msg_data OUT NOCOPY VARCHAR2,
p_interface_table IN VARCHAR2,
p_insert_cur IN OUT NOCOPY INTEGER,
p_apps_tbl IN ece_flatfile_pvt.Interface_tbl_type) IS
l_api_name CONSTANT VARCHAR2(30) := 'insert_into_prod_interface_pvt';
cInsert_stmt VARCHAR2(32000) := 'INSERT INTO ';
c_Insert_cur INTEGER ;
EC_DEBUG.PUSH('ece_extract_utils_pub.insert_into_prod_interface_pvt');
EC_DEBUG.PL(3, 'p_insert_cur: ',p_insert_cur);
SAVEPOINT insert_into_prod_interface_pvt;
IF p_insert_cur = 0 THEN
xProgress := 'EXTUB-30-1020';
p_insert_cur := -911;
IF p_insert_cur < 0 THEN
xProgress := 'EXTUB-30-1040';
cInsert_stmt := cInsert_stmt || ' ' || p_Interface_Table || '(';
EC_DEBUG.PL(3, 'cInsert_stmt: ',cInsert_stmt);
cInsert_stmt := cInsert_stmt || ' ' || p_apps_tbl(i).base_column_name || ',';
EC_DEBUG.PL(3, 'cInsert_stmt: ',cInsert_stmt);
cInsert_stmt := RTRIM(cInsert_stmt,',') || ') ';
EC_DEBUG.PL(3, 'cInsert_stmt: ',cInsert_stmt);
cInsert_stmt := cInsert_stmt || cValue_stmt;
EC_DEBUG.PL(3, 'cInsert_stmt: ',cInsert_stmt);
p_Insert_cur := dbms_sql.open_cursor;
EC_DEBUG.PL(3, 'p_Insert_cur: ',p_Insert_cur);
stmt_1 VARCHAR2(2000) := SUBSTR(cInsert_stmt,1, 2000);
stmt_2 VARCHAR2(2000) := SUBSTR(cInsert_stmt,2001,2000);
stmt_3 VARCHAR2(2000) := SUBSTR(cInsert_stmt,4001,2000);
stmt_4 VARCHAR2(2000) := SUBSTR(cInsert_stmt,6001,2000);
stmt_5 VARCHAR2(2000) := SUBSTR(cInsert_stmt,8001,2000);
INSERT INTO ece_error(run_id,line_id,text) VALUES(78,ece_error_s.NEXTVAL,stmt_1);
INSERT INTO ece_error(run_id,line_id,text) VALUES(78,ece_error_s.NEXTVAL,stmt_2);
INSERT INTO ece_error(run_id,line_id,text) VALUES(78,ece_error_s.NEXTVAL,stmt_3);
INSERT INTO ece_error(run_id,line_id,text) VALUES(78,ece_error_s.NEXTVAL,stmt_4);
INSERT INTO ece_error(run_id,line_id,text) VALUES(78,ece_error_s.NEXTVAL,stmt_5);
dbms_sql.parse(p_Insert_cur,cInsert_stmt,dbms_sql.native);
ROLLBACK TO insert_into_prod_interface_pvt;
cInsert_stmt);
IF p_Insert_cur > 0 THEN
BEGIN
xProgress := 'EXTUB-30-1150';
dbms_sql.bind_variable(p_Insert_cur,'b'|| k,d_date);
INSERT INTO ece_error(run_id,line_id,text) VALUES(88,ece_error_s.NEXTVAL,'b' || k || ' = ' || d_date);
dbms_sql.bind_variable(p_Insert_cur,'b' || k,n_number);
INSERT INTO ece_error(run_id,line_id,text) VALUES(88,ece_error_s.NEXTVAL,'b' || k || ' =' || n_number);
dbms_sql.bind_variable(p_Insert_cur,'b' || k,SUBSTR(p_apps_tbl(k).value,1,p_apps_tbl(k).data_length));
INSERT INTO ece_error(run_id,line_id,text) VALUES(88,ece_error_s.NEXTVAL,'b' || k || ' =' || p_apps_tbl(k).value);
dummy := dbms_sql.execute(p_Insert_cur);
EC_DEBUG.PL(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','ECE_EXTRACT_UTILS_PUB.insert_into_prod_interface_pvt');
ROLLBACK TO insert_into_prod_interface_pvt;
EC_DEBUG.POP('ece_extract_utils_pub.insert_into_prod_interface_pvt');
ROLLBACK TO insert_into_prod_interface_pvt;
ROLLBACK TO insert_into_prod_interface_pvt;
ROLLBACK TO insert_into_prod_interface_pvt;
END insert_into_prod_interface_pvt;
PROCEDURE ext_insert_value(
l_plsql_tbl IN OUT NOCOPY ece_flatfile_pvt.Interface_tbl_type,
p_position IN number,
p_value IN varchar2)
IS
BEGIN
if EC_DEBUG.G_debug_level >= 2 then
ec_debug.push('ECE_EXTRACT_UTILS_PUB.EXT_INSERT_VALUE');
ec_debug.pop('ECE_EXTRACT_UTILS_PUB.EXT_INSERT_VALUE');
ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','ECE_EXTRACT_UTILS_PUB.EXT_INSERT_VALUE');
end ext_insert_value;