APPS.CN_IMPORT_PVT SQL Statements

The following lines contain the word 'select', 'insert', 'update' or 'delete':

Line: 16

   SELECT import_type_code INTO l_imp_type_code
     FROM cn_imp_headers
     WHERE imp_header_id = p_imp_header_id;

Line: 36

	SELECT imp_line_id FROM cn_imp_lines
	  WHERE imp_header_id = p_imp_header_id
	  ORDER BY imp_line_id;

Line: 45

      UPDATE cn_imp_lines
	SET record_num = l_count
	WHERE imp_line_id = l_imp_lines_csr.imp_line_id
	;

Line: 107

   SELECT name, status_code,server_flag
     INTO l_imp_header.name ,l_imp_header.status_code  ,
     l_imp_header.server_flag
     FROM cn_imp_headers
     WHERE imp_header_id = p_imp_header_id;

Line: 160

	 update_imp_headers
	   (p_imp_header_id => p_imp_header_id,
	    p_status_code => 'FAIL');

Line: 195

	    update_imp_headers
	      (p_imp_header_id => p_imp_header_id,
	       p_status_code => 'FAIL');

Line: 319

   SELECT name, status_code
     INTO l_name ,l_status_code
     FROM cn_imp_headers
    WHERE imp_header_id = p_imp_header_id;

Line: 324

   SELECT export_conc_program
     INTO l_conc_pgm
     FROM cn_import_types
    WHERE import_type_code = l_imp_type_code;

Line: 359

   update_imp_headers
     (p_imp_header_id => p_imp_header_id,
      p_status_code => 'SUBMIT');

Line: 375

      update_imp_headers
	(p_imp_header_id => p_imp_header_id,
	 p_status_code => 'FAIL');

Line: 478

  SELECT COUNT(*)
  FROM   cn_imp_lines
  WHERE  imp_header_id = p_imp_header_id;

Line: 487

   update_imp_headers
     (p_imp_header_id => p_imp_header_id,
      p_status_code => 'SUBMIT');

Line: 501

   SELECT name, status_code,server_flag
     INTO l_imp_header.name ,l_imp_header.status_code ,
     l_imp_header.server_flag
     FROM cn_imp_headers
     WHERE imp_header_id = p_imp_header_id;

Line: 605

	 update_imp_headers
	   (p_imp_header_id => p_imp_header_id,
	    p_status_code => 'STAGE_FAIL');

Line: 612

	 GOTO delete_conc;

Line: 623

      update_imp_headers
	(p_imp_header_id => p_imp_header_id,
	 p_status_code => 'STAGE',
	 p_staged_row => l_loaded_rows);

Line: 628

      << delete_conc >>
      -- Clean-up the concurrent programs which were created
      -- during program execution.
      FND_PROGRAM.DELETE_PROGRAM
	(program_short_name   => l_short_name,
	 application          => 'CN'
	 );

Line: 635

      cn_message_pkg.debug('Staging Data : Delete Conc Program.');

Line: 641

      FND_PROGRAM.DELETE_EXECUTABLE
	(executable_short_name      => l_short_name,
	 application                => 'CN'
	 );

Line: 645

      cn_message_pkg.debug('Staging Data : Delete Conc Executable.');

Line: 663

  SELECT name, status_code,server_flag
    INTO l_imp_header.name ,l_imp_header.status_code  ,l_imp_header.server_flag
    FROM cn_imp_headers
    WHERE imp_header_id = p_imp_header_id;

Line: 685

      update_imp_headers
	(p_imp_header_id => p_imp_header_id,
	 p_status_code => 'STAGE_FAIL');

Line: 696

      update_imp_headers
	(p_imp_header_id => p_imp_header_id,
	 p_status_code => 'STAGE_FAIL');

Line: 755

     SELECT conc_program FROM cn_import_types
       WHERE  import_type_code = l_imp_type_code;

Line: 770

  SELECT name, status_code,server_flag
    INTO l_imp_header.name ,l_imp_header.status_code,
    l_imp_header.server_flag
    FROM cn_imp_headers
    WHERE imp_header_id = p_imp_header_id;

Line: 794

     update_imp_headers
       (p_imp_header_id => p_imp_header_id,
	p_status_code => 'SCHEDULE');

Line: 851

	 update_imp_headers
	   (p_imp_header_id => p_imp_header_id,
	    p_status_code => 'IMPORT_FAIL');

Line: 876

      update_imp_headers
	(p_imp_header_id => p_imp_header_id,
	 p_status_code => 'IMPORT_FAIL');

Line: 887

      update_imp_headers
	(p_imp_header_id => p_imp_header_id,
	 p_status_code => 'IMPORT_FAIL');

Line: 958

	 SELECT f.source_column,f.target_column_name,f.target_table_name,
	   m.object_version_number map_obj_ver
	   FROM cn_imp_map_fields f, cn_imp_maps m
	   WHERE m.imp_map_id = c_imp_map_id
	   AND   f.imp_map_id = m.imp_map_id
	   ORDER BY f.source_column
	   ;

Line: 967

	 SELECT COUNT(*)
	   FROM   cn_imp_lines
	   WHERE  imp_header_id = p_imp_header_id;

Line: 1001

   SELECT name, status_code,server_flag,imp_map_id, source_column_num
     INTO 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
     FROM cn_imp_headers
     WHERE imp_header_id = p_imp_header_id;

Line: 1013

      update_imp_headers
	(p_imp_header_id => p_imp_header_id,
	 p_status_code => 'SUBMIT');

Line: 1039

	 -- check if mapping is updated by other user
	 IF c_tar_col.map_obj_ver <> p_map_obj_ver THEN
	    IF FND_MSG_PUB.Check_Msg_Level (FND_MSG_PUB.G_MSG_LVL_ERROR)
	      THEN
	       FND_MESSAGE.SET_NAME ('CN' , 'CN_IMP_MAPPED_CHANGED');

Line: 1067

      cn_import_client_pvt.insert_data
	(p_api_version => 1.0,
	 p_imp_header_id => p_imp_header_id,
	 p_import_type_code =>  l_imp_type_code,
	 p_table_name  => l_target_table,
	 p_col_names   => l_columns,
	 p_data        => l_data,
	 p_row_count   => l_row_count,
	 x_return_status => x_return_status,
	 x_msg_count   => x_msg_count,
	 x_msg_data    => x_msg_data);

Line: 1088

      update_imp_headers
	(p_imp_header_id => p_imp_header_id,
	 p_status_code => 'STAGE',
	 p_staged_row => l_loaded_rows);

Line: 1122

      update_imp_headers
	(p_imp_header_id => p_imp_header_id,
	 p_status_code => 'STAGE_FAIL');

Line: 1135

      update_imp_headers
	(p_imp_header_id => p_imp_header_id,
	 p_status_code => 'STAGE_FAIL');

Line: 1148

      update_imp_headers
	(p_imp_header_id => p_imp_header_id,
	 p_status_code => 'STAGE_FAIL');

Line: 1175

PROCEDURE update_imp_lines
  (p_imp_line_id IN NUMBER,
   p_status_code IN VARCHAR2,
   p_error_code  IN VARCHAR2,
   p_error_msg IN VARCHAR2 := NULL) IS
      PRAGMA AUTONOMOUS_TRANSACTION;

Line: 1183

   UPDATE cn_imp_lines
     SET status_code = p_status_code, error_code = p_error_code,
     error_msg = p_error_msg
     WHERE imp_line_id = p_imp_line_id
     ;

Line: 1193

END update_imp_lines;

Line: 1201

PROCEDURE update_imp_headers
  (p_imp_header_id IN NUMBER,
   p_status_code IN VARCHAR2,
   p_staged_row  IN NUMBER := NULL,
   p_processed_row  IN NUMBER := NULL,
   p_failed_row  IN NUMBER := NULL) IS
      PRAGMA AUTONOMOUS_TRANSACTION;

Line: 1210

   UPDATE cn_imp_headers
     SET status_code = Decode(p_status_code,NULL,status_code,p_status_code),
     staged_row =Decode(p_staged_row,NULL,staged_row,p_staged_row),
     processed_row =Decode(p_processed_row,NULL,processed_row,p_processed_row),
     failed_row = Decode(p_failed_row,NULL,failed_row,p_failed_row)
     WHERE imp_header_id = p_imp_header_id
     ;

Line: 1222

END update_imp_headers;

Line: 1237

	SELECT f.source_column,f.source_user_column,
	  f.target_column_name,f.target_table_name
	  FROM cn_imp_headers h, cn_imp_map_fields f
	  WHERE h.imp_header_id = p_imp_header_id
	  AND f.imp_map_id = h.imp_map_id
	  ORDER BY f.source_column
	  ;

Line: 1250

   x_sql_stmt := 'SELECT ';

Line: 1262

      IF x_sql_stmt <> 'SELECT ' THEN
	x_sql_stmt := x_sql_stmt || ' || '' , '' || ';