The following lines contain the word 'select', 'insert', 'update' or 'delete':
SELECT ruleset_id
FROM cn_rulesets
WHERE name = l_name
AND start_date = l_start_date
AND end_date = l_end_date
AND module_type = l_module_type
AND org_id=p_org_id;
SELECT ruleset_name, start_date, end_date, ruleset_type
FROM CN_RULES_IMP_V
WHERE imp_header_id = p_imp_header_id
AND status_code = l_stage_status
GROUP BY ruleset_name, start_date, end_date, ruleset_type
ORDER BY start_date;
SELECT imp_header_id, name, status_code,server_flag,imp_map_id, source_column_num, import_type_code
INTO l_imp_header.imp_header_id,l_imp_header.name ,l_imp_header.status_code, l_imp_header.server_flag,
l_imp_header.imp_map_id, l_imp_header.source_column_num,l_imp_header.import_type_code
FROM cn_imp_headers
WHERE imp_header_id = p_imp_header_id;
update_imp_lines
(p_status => 'FAIL',
p_imp_line_id => G_INVALID_IMP_LINE_ID,
p_ruleset_name => detail_rec.ruleset_name,
p_start_date => detail_rec.start_date,
p_end_date => detail_rec.end_date,
p_ruleset_type => detail_rec.ruleset_type,
p_head_id => l_imp_header.imp_header_id,
p_error_code => 'CN_IMP_MISS_REQUIRED',
p_error_mssg => fnd_message.get_string('CN','CN_IMP_MISS_REQUIRED'),
x_failed_row => l_failed_row,
x_processed_row => l_processed_row);
update_imp_lines
(p_status => 'FAIL',
p_imp_line_id => G_INVALID_IMP_LINE_ID,
p_ruleset_name => detail_rec.ruleset_name,
p_start_date => detail_rec.start_date,
p_end_date => detail_rec.end_date,
p_ruleset_type => detail_rec.ruleset_type,
p_head_id => l_imp_header.imp_header_id,
p_error_code => 'CN_RULESET_NAME_TOO_LONG',
p_error_mssg => fnd_message.get_string('CN','CN_RULESET_NAME_TOO_LONG'),
x_failed_row => l_failed_row,
x_processed_row => l_processed_row);
update_imp_lines
(p_status => 'FAIL',
p_imp_line_id => G_INVALID_IMP_LINE_ID,
p_ruleset_name => detail_rec.ruleset_name,
p_start_date => detail_rec.start_date,
p_end_date => detail_rec.end_date,
p_ruleset_type => detail_rec.ruleset_type,
p_head_id => l_imp_header.imp_header_id,
p_error_code => 'CN_IMP_INVLD_RULESET_DATE',
p_error_mssg => fnd_message.get_string('CN','CN_IMP_INVLD_RULESET_DATE'),
x_failed_row => l_failed_row,
x_processed_row => l_processed_row);
-- update all the rows related to the ruleset with a general message
update_imp_lines
(p_status => 'FAIL',
p_imp_line_id => G_INVALID_IMP_LINE_ID,
p_ruleset_name => detail_rec.ruleset_name,
p_start_date => detail_rec.start_date,
p_end_date => detail_rec.end_date,
p_ruleset_type => detail_rec.ruleset_type,
p_head_id => l_imp_header.imp_header_id,
p_error_code => 'CN_IMP_INVLD_RULESET',
p_error_mssg => l_message || ' ' || fnd_message.get_string('CN','CN_IMP_INVLD_RULESET'),
x_failed_row => l_failed_row,
x_processed_row => l_processed_row);
update_imp_lines
(p_status => 'COMPLETE',
p_imp_line_id => G_INVALID_IMP_LINE_ID,
p_ruleset_name => detail_rec.ruleset_name,
p_start_date => detail_rec.start_date,
p_end_date => detail_rec.end_date,
p_ruleset_type => detail_rec.ruleset_type,
p_head_id => l_imp_header.imp_header_id,
p_error_code => '',
p_error_mssg => '',
x_failed_row => l_failed_row,
x_processed_row => l_processed_row);
CN_IMPORT_PVT.update_imp_headers
(p_imp_header_id => p_imp_header_id,
p_status_code => 'IMPORT_FAIL',
p_processed_row => l_processed_row,
p_failed_row => l_failed_row);
CN_IMPORT_PVT.update_imp_headers
(p_imp_header_id => p_imp_header_id,
p_status_code => 'COMPLETE',
p_processed_row => l_processed_row,
p_failed_row => l_failed_row);
CN_IMPORT_PVT.update_imp_headers
(p_imp_header_id => p_imp_header_id,
p_status_code => 'IMPORT_FAIL',
p_processed_row => l_processed_row,
p_failed_row => l_failed_row);
UPDATE cn_rules_imp_v
SET status_code=p_status, error_code=p_error_code, error_msg=p_error_mssg
WHERE nvl(ruleset_name,FND_API.g_miss_char) = nvl(p_ruleset_name ,FND_API.g_miss_char)
AND nvl(start_date ,FND_API.g_miss_char) = nvl(p_ruleset_start_date, FND_API.g_miss_char)
AND nvl(end_date,FND_API.g_miss_char) = nvl(p_ruleset_end_date, FND_API.g_miss_char)
AND nvl(ruleset_type,FND_API.g_miss_char) = nvl(p_ruleset_type, FND_API.g_miss_char)
AND Nvl(rule_name,FND_API.g_miss_char) =
Decode(p_rule_name,NULL, FND_API.g_miss_char,
FND_API.g_miss_char,Nvl(rule_name,FND_API.g_miss_char),
p_rule_name)
AND Nvl(parent_rule_name,FND_API.g_miss_char) =
Decode(p_parent_rule_name,NULL, FND_API.g_miss_char,
FND_API.g_miss_char,Nvl(parent_rule_name,FND_API.g_miss_char),
p_parent_rule_name)
AND Nvl(level_num,FND_API.g_miss_char) =
Decode(p_level_num,NULL, FND_API.g_miss_char,
FND_API.g_miss_char,Nvl(level_num,FND_API.g_miss_char),
p_level_num)
AND Nvl(expense_code,FND_API.g_miss_char) =
Decode(p_expense_code,NULL, FND_API.g_miss_char,
FND_API.g_miss_char,Nvl(expense_code,FND_API.g_miss_char),
p_expense_code)
AND Nvl(liability_code,FND_API.g_miss_char) =
Decode(p_liability_code,NULL, FND_API.g_miss_char,
FND_API.g_miss_char,Nvl(liability_code,FND_API.g_miss_char),
p_liability_code)
AND Nvl(revenue_class_name,FND_API.g_miss_char) =
Decode(p_revcls_name,NULL, FND_API.g_miss_char,
FND_API.g_miss_char,Nvl(revenue_class_name,FND_API.g_miss_char),
p_revcls_name)
AND imp_header_id = p_head_id
AND status_code = 'STAGE'
;
CN_IMPORT_PVT.update_imp_headers
(p_imp_header_id => p_head_id,
p_status_code => 'IMPORT_FAIL',
p_failed_row => x_failed_row,
p_processed_row => x_processed_row);
SELECT count(*)
FROM CN_RULES_IMP_V
WHERE imp_header_id = p_imp_header.imp_header_id
AND status_code = l_stage_status
AND ruleset_name = p_ruleset_name
AND start_date = p_ruleset_start_date
AND end_date = p_ruleset_end_date
AND ruleset_type = p_ruleset_type
AND rule_name IS NULL;
SELECT count(*)
FROM CN_RULES_IMP_V
WHERE imp_header_id = p_imp_header.imp_header_id
AND status_code = l_stage_status
AND ruleset_name = p_ruleset_name
AND start_date = p_ruleset_start_date
AND end_date = p_ruleset_end_date
AND ruleset_type = p_ruleset_type
AND level_num IS NULL;
SELECT distinct(rule_name) rule_name, parent_rule_name, level_num
FROM CN_RULES_IMP_V
WHERE imp_header_id = p_imp_header.imp_header_id
AND status_code = l_stage_status
AND ruleset_name = p_ruleset_name
AND start_date = p_ruleset_start_date
AND end_date = p_ruleset_end_date
AND ruleset_type = p_ruleset_type
GROUP BY rule_name, parent_rule_name, level_num
ORDER BY level_num;
SELECT COUNT(1) FROM
(SELECT revenue_class_name, expense_code, liability_code
FROM CN_RULES_IMP_V
WHERE imp_header_id = p_imp_header.imp_header_id
AND status_code = l_stage_status
AND ruleset_name = p_ruleset_name
AND start_date = p_ruleset_start_date
AND end_date = p_ruleset_end_date
AND ruleset_type = p_ruleset_type
AND rule_name = l_name
AND level_num = l_level_num
AND nvl(parent_rule_name,FND_API.g_miss_char) = nvl(l_parent_rule_name,FND_API.g_miss_char)
GROUP BY revenue_class_name, expense_code, liability_code) v1;
SELECT revenue_class_name, expense_code, liability_code
FROM CN_RULES_IMP_V
WHERE imp_header_id = p_imp_header.imp_header_id
AND status_code = l_stage_status
AND ruleset_name = p_ruleset_name
AND start_date = p_ruleset_start_date
AND end_date = p_ruleset_end_date
AND ruleset_type = p_ruleset_type
AND rule_name = l_name
AND level_num = l_level_num
AND nvl(parent_rule_name,FND_API.g_miss_char) = nvl(l_parent_rule_name,FND_API.g_miss_char);
SELECT rule_id
FROM CN_RULES
WHERE name = l_name
AND ruleset_id=p_ruleset_id
AND org_id=p_org_id;
SELECT revenue_class_id
FROM cn_revenue_classes
WHERE name = l_name
and org_id=p_org_id;
SELECT code_combination_id
FROM (SELECT
gl.code_combination_id code_combination_id ,
cn_api.get_ccid_disp_func(gl.code_combination_id,r.org_id) code_description,
gl.account_type account_type
FROM
gl_code_combinations gl ,
cn_repositories r ,
gl_sets_of_books gls
WHERE
r.set_of_books_id = gls.set_of_books_id and
gls.chart_of_accounts_id = gl.chart_of_accounts_id
AND r.org_id=p_org_id)
WHERE account_type ='L'
AND code_description = l_name;
SELECT code_combination_id
FROM (SELECT
gl.code_combination_id code_combination_id ,
cn_api.get_ccid_disp_func(gl.code_combination_id,r.org_id) code_description,
gl.account_type account_type
FROM
gl_code_combinations gl ,
cn_repositories r ,
gl_sets_of_books gls
WHERE
r.set_of_books_id = gls.set_of_books_id and
gls.chart_of_accounts_id = gl.chart_of_accounts_id
AND r.org_id=p_org_id)
WHERE account_type = 'E'
AND code_description = l_name;
SELECT imp_line_id, record_num, rule_attribute, rule_value, not_flag, rule_hierarchy, rule_low_value, rule_high_value
FROM CN_RULES_IMP_V
WHERE imp_header_id = p_imp_header.imp_header_id
AND status_code = l_stage_status
AND ruleset_name = p_ruleset_name
AND start_date = p_ruleset_start_date
AND end_date = p_ruleset_end_date
AND ruleset_type= p_ruleset_type
AND rule_name = p_rule_name
AND nvl(parent_rule_name, FND_API.g_miss_char) = nvl(p_parent_rule_name, FND_API.g_miss_char)
AND level_num = p_level_num;
SELECT head_hierarchy_id
FROM CN_HEAD_HIERARCHIES
WHERE name = l_name
and org_id=p_org_id;
SELECT CHN.value_id
FROM CN_DIM_HIERARCHIES CDH, CN_HIERARCHY_NODES CHN
WHERE cdh.header_dim_hierarchy_id = h_id
AND name = l_name AND
CDH.org_id=p_org_id AND
CDH.org_id=CHN.org_id
AND cdh.dim_hierarchy_id = chn.dim_hierarchy_id;
SELECT name
FROM cn_objects
WHERE table_id = -11803
and org_id=p_org_id
AND user_name = l_name;
update_on_error
(p_line_id => attr_rec.imp_line_id,
p_err_code => l_error_code,
p_err_mssg => x_err_mssg,
p_head_id => p_imp_header.imp_header_id);
update_on_error
(p_line_id => attr_rec.imp_line_id,
p_err_code => l_error_code,
p_err_mssg => x_err_mssg,
p_head_id => p_imp_header.imp_header_id);
update_on_error
(p_line_id => attr_rec.imp_line_id,
p_err_code => l_error_code,
p_err_mssg => x_err_mssg,
p_head_id => p_imp_header.imp_header_id);
update_on_error
(p_line_id => attr_rec.imp_line_id,
p_err_code => l_error_code,
p_err_mssg => x_err_mssg,
p_head_id => p_imp_header.imp_header_id);
CN_IMPORT_PVT.update_imp_lines
(p_imp_line_id => attr_rec.imp_line_id,
p_status_code => 'COMPLETE',
p_error_code => '');
update_on_error
(p_line_id => l_current_imp_line_id,
p_err_code => l_error_code,
p_err_mssg => x_err_mssg,
p_head_id => p_imp_header.imp_header_id);
PROCEDURE update_on_error
(p_line_id IN NUMBER,
p_err_code IN VARCHAR2,
p_err_mssg IN VARCHAR2,
p_head_id IN NUMBER ) IS
PRAGMA AUTONOMOUS_TRANSACTION;
CN_IMPORT_PVT.update_imp_lines
(p_imp_line_id => p_line_id,
p_status_code => 'FAIL',
p_error_code => p_err_code,
p_error_msg => p_err_mssg);
END update_on_error;
PROCEDURE update_imp_lines
(p_status IN VARCHAR2,
p_imp_line_id IN NUMBER,
p_ruleset_name IN VARCHAR2,
p_start_date IN VARCHAR2,
p_end_date IN VARCHAR2,
p_ruleset_type IN VARCHAR2,
p_head_id IN NUMBER,
p_error_code IN VARCHAR2,
p_error_mssg IN VARCHAR2,
x_failed_row IN OUT NOCOPY NUMBER,
x_processed_row IN OUT NOCOPY NUMBER) IS
CURSOR c_check_imp_line_id_csr IS
SELECT count(*)
FROM cn_rules_imp_v
WHERE nvl(ruleset_name,FND_API.g_miss_char) = nvl(p_ruleset_name ,FND_API.g_miss_char)
AND nvl(start_date ,FND_API.g_miss_char) = nvl(p_start_date, FND_API.g_miss_char)
AND nvl(end_date,FND_API.g_miss_char) = nvl(p_end_date, FND_API.g_miss_char)
AND nvl(ruleset_type,FND_API.g_miss_char) = nvl(p_ruleset_type, FND_API.g_miss_char)
AND imp_header_id = p_head_id
AND status_code = 'STAGE'
AND imp_line_id <> p_imp_line_id;
UPDATE cn_rules_imp_v
SET status_code=p_status, error_code=p_error_code, error_msg=p_error_mssg
WHERE nvl(ruleset_name,FND_API.g_miss_char) = nvl(p_ruleset_name ,FND_API.g_miss_char)
AND nvl(start_date ,FND_API.g_miss_char) = nvl(p_start_date, FND_API.g_miss_char)
AND nvl(end_date,FND_API.g_miss_char) = nvl(p_end_date, FND_API.g_miss_char)
AND nvl(ruleset_type,FND_API.g_miss_char) = nvl(p_ruleset_type, FND_API.g_miss_char)
AND imp_header_id = p_head_id
AND status_code = 'STAGE'
AND imp_line_id <> l_temp;
END update_imp_lines;