jdbc batch processing
이 자습서에서는 샘플 Java 예제를 통해 JDBC 일괄 처리 및 Java 저장 프로 시저에 대한 완전한 이해를 제공합니다.
에서 JDBC 예외 처리 튜토리얼 JDBC 튜토리얼 시리즈 , 우리는 프로그래밍 예제를 통해 SQL 예외를 처리하는 방법을 배웠습니다.
이 튜토리얼에서는 JDBC 드라이버를 사용하여 Java에서 일괄 처리를 수행하는 방법에 대해 설명합니다. 또한 저장 프로 시저를 생성하고 Java 프로그램에서 호출하는 방법에 대해서도 알아 봅니다.
일괄 처리와 그 장점을 이해하는 것부터 시작하겠습니다.
학습 내용 :
JDBC 일괄 처리
하나의 트랜잭션에서 여러 SQL 문을 실행하는 프로세스입니다. 이 프로세스는 통신 시간을 줄이고 성능을 향상시킵니다. 많은 양의 데이터를 훨씬 쉽게 처리 할 수 있습니다.
일괄 처리의 장점
일괄 처리는 성능 및 데이터 일관성 향상을 목표로합니다.
공연
JAVA 프로그램에서 여러 항목 (예 : 5 개)이 테이블에 추가되는 시나리오를 고려하십시오. 간단한 접근 방식은 데이터베이스에 대한 연결을 열고 INSERT 쿼리를 작성하고 Statement 또는 PreparedStatement를 사용하여 각 쿼리를 실행하는 것입니다.
이 접근 방식은 데이터베이스로의 네트워크 이동을 증가시켜 결과적으로 성능 저하로 이어집니다. 일괄 처리를 사용하면 한 번의 호출로이 작업을 수행 할 수 있습니다.
데이터 일관성
어떤 경우에는 여러 테이블에 데이터를 삽입 / 업데이트해야합니다. 이로 인해 삽입 또는 업데이트되는 쿼리 순서가 중요한 상호 관련된 트랜잭션이 발생합니다. 실행 중에 발생하는 모든 오류는 이전 쿼리가 삽입 한 데이터를 롤백합니다.
예:
#1) 테이블‘EMPLOYEE_DETAILS’에는 3 개의 열이 있습니다. 신분증 , 이름 , 및 직원의 역할.
statement.execute('INSERT INTO EMPLOYEE_DETAILS(ID, NAME, ROLE) ' + 'VALUES ('1','EMPLOYEE_NAME1','ROLE1')');
#두) 테이블‘EMPLOYEE_ADDRESS’에는 2 개의 열이 있습니다. EMP ID 과 주소
statement.execute('INSERT INTO EMPLOYEE_ADDRESS( EMP_ID, ADDRESS) ' + 'VALUES ('1','ADDRESS1')');
위의 예에서 첫 번째 문이 성공적으로 실행되었지만 두 번째 문이 실패하면 문제가 발생할 수 있습니다. 이 상황에서는 첫 번째 명령문에서 삽입 한 데이터의 롤백이 없습니다. 이로 인해 데이터 불일치가 발생합니다.
마지막에 트랜잭션을 커밋하거나 예외가 발생하는 경우 롤백을 수행하여 데이터 일관성을 얻을 수 있습니다. 그러나이를 달성하기 위해서는 모든 문에 대해 DB를 반복적으로 조회해야합니다.
반면에 일괄 처리에서는 일괄 처리 내의 모든 쿼리가 성공적으로 실행될 때만 데이터가 커밋됩니다. 그렇지 않으면 그렇지 않습니다.
일괄 처리 수행 방법
Statement 및 PreparedStatement 클래스 모두에서 사용할 수있는 addbatch () 및 executeBatch () 메서드를 사용하여 일괄 처리를 수행 할 수 있습니다.
이 튜토리얼에서 모든 프로그램은 Java로 작성됩니다. 우리는 Java 8 버전과 Oracle DB를 사용했습니다.
=> Oracle 소프트웨어를 다운로드하려면 여기를 클릭하십시오.
=> Java 버전 8을 다운로드하려면 여기를 클릭하십시오.
다음 예에서는 배치 처리를 정교하게 수행하는 방법을 살펴 보겠습니다. 단계별 Java 설치 프로세스가 있습니다.
데이터를 삽입하기 전 EMPLOYEE 테이블의 데이터 :
swf 파일이란 무엇입니까?
자바 프로그램
package com.STH.JDBC; import java.sql.BatchUpdateException; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class ExecuteBatch_Example { public static void main(String() args) throws ClassNotFoundException, SQLException { //Inserting the data in EMPLOYEE Table using the following query String insert_query1 = 'insert into employee values(?,?,?)'; Class.forName('oracle.jdbc.driver.OracleDriver'); Try(Connection conn = DriverManager.getConnection('jdbc:oracle:thin:system/pass123@localhost:1521:XE')) { PreparedStatement pstatemnt1 = conn.prepareStatement(insert_query1); //Setting values for the 1st person in EMPLOYEE Table pstatemnt1.setInt(1,10001); pstatemnt1.setString(2, 'Bush'); pstatemnt1.setString(3, 'William '); //Adding the 1st insert query into batch pstatemnt1.addBatch(); //Setting values for the 2nd person in EMPLOYEE Table pstatemnt1.setInt(1,10002); pstatemnt1.setString(2, “Bush'); pstatemnt1.setString(3, 'George'); //Adding the 2nd insert query into batch pstatemnt1.addBatch(); //Setting values for the 3rd person in EMPLOYEE Table pstatemnt1.setInt(1,10003); pstatemnt1.setString(2, 'Bond'); pstatemnt1.setString(3, 'James'); //Adding the 3rd insert query into batch pstatemnt1.addBatch(); //Executing the executeBatch method int No_of_Afffected_Rows()= pstatemnt1.executeBatch(); //After inserting the data, displaying no. of rows affected System.out.println('No of rows affected = ' +No_of_Afffected_Rows.length);} catch (SQLException e) { e.printStackTrace();} } }
산출:
데이터 삽입 후 EMPLOYEE 테이블의 데이터 :
설명:
위 프로그램에서는 일괄 작업을 사용하여 한 번의 호출에 3 명의 직원 데이터를 삽입했습니다.
- 열 값을 전달할 하나의 삽입 쿼리를 만듭니다.
- 연결을 열고 연결 개체를 사용하여 prepareStatement 개체를 만들고 prepareStatement 메서드를 호출합니다.
- 그런 다음 1에 대한 값을 설정하십시오.성직원이 setXXX 메서드를 사용하고 addBatch () 메서드를 호출하여 배치에 새 행을 추가합니다.
- 이렇게 2의 값을 더하세요nd그리고 3rd직원. addBatch () 메서드에 쿼리를 추가 한 후 readyStatement 객체를 사용하여 executeBatch () 메서드를 호출해야합니다.
- executeBatch () 메서드는 한 번의 호출에 3 명의 직원 데이터를 삽입합니다.
- EMPLOYEE 테이블에서 데이터가 제대로 삽입되었는지 확인하십시오.
Java 저장 프로 시저
저장 프로시 저는 단일 단위를 형성하고 특정 작업을 수행하는 SQL 문 그룹입니다. 데이터베이스 서버에서 실행할 일련의 작업 또는 질문을 수행하는 데 사용됩니다. 다른 매개 변수와 결과로 컴파일하고 실행할 수 있습니다.
각 프로 시저에는 참조 할 고유 한 이름이 있습니다. 이 서브 프로그램 단위는 DB에 Database 객체로 저장됩니다.
서브 프로그램은 프로 시저 일 뿐이며 원하는대로 수동으로 생성하여 DB 객체로 저장해야합니다.
저장 프로시 저는 DB에 저장할 수있는 프로그램의 독립형 블록입니다. 저장 프로 시저의 이름을 사용하여이를 호출하고 실행할 수 있습니다. 주로 PL / SQL에서 프로세스를 실행하는 데 사용됩니다. 프로 시저에는 중첩 된 블록이 있거나 다른 블록 안에 중첩 될 수 있습니다.
저장 프로시 저는 세 부분으로 구성됩니다.
- 선언 부분 (선택 사항) : 이 부분에서는 변수, 상수, 커서 등을 선언 할 수 있습니다. 이것은 선택적인 부분입니다. 요구 사항에 따라 사용할 수 있습니다.
- 실행 부분 : 이 부분은 프로 시저의 주요 비즈니스 로직을 포함합니다. 일반적으로 SQL 문 블록이 있습니다.
- 예외적 인 처리 부분 (선택 사항) : 이 부분에서는 Execution 부분 코드로 인해 발생할 수있는 예외를 처리 할 수 있습니다. 또한 선택 사항입니다.
요구 사항에 따라 절차를 만들 수 있습니다. 매개 변수에서 값을 전달하거나 검색 할 수 있습니다.
저장 프로 시저에서 사용할 수있는 세 가지 유형의 매개 변수가 있습니다. 그들은:
- 에: 입력 값을 저장 프로 시저에 전달하는 데 사용됩니다. 스토어드 프로시 저는 프로그램의 입력 매개 변수를 읽기 전용 변수로 사용합니다. 값은 서브 프로그램 내에서 변경할 수 없습니다. Oracle은 IN을 매개 변수의 기본 모드로 사용합니다. 기본 매개 변수입니다.
- 밖: 실행 후 저장 프로 시저에서 값을 반환하거나 가져 오는 데 사용됩니다. 서브 프로그램 내의 읽기-쓰기 변수입니다. 값은 서브 프로그램 내에서 변경할 수 있습니다.
- 입 / 출력 : 입력 값을 저장 프로 시저에 전달하고 프로 시저에서 값을 반환하거나 가져 오는데도 사용됩니다. 읽기 및 쓰기가 가능합니다. 우리는 그것을 읽고 수정할 수 있습니다.
반환
return 키워드를 사용하여 Java 프로그램과 같은 기본 프로그램에 제어를 다시 제공합니다. 프로 시저가 RETURN 키워드를 찾으면 실행을 종료하고 그 이후의 코드 나 문을 건너 뜁니다.
Java에서 저장 프로 시저를 호출하는 방법
저장 프로 시저를 호출하기 위해 Java에 CallableStatement 인터페이스가 있습니다. CallableStatement 인터페이스 객체는 Connection 인터페이스의 prepareCall () 메소드를 사용하여 생성 할 수 있으며, 그 후 executeQuery () 메소드를 호출하여 Java 프로그램에서 Stored Procedure를 실행해야합니다.
이를 구현하기 위해 Java 프로그램을 작성하기 전에 프로그램에서 사용할 저장 프로 시저를 만들어야합니다.
다음은 Java 프로그램에서 스토어드 프로 시저를 호출하는 구문입니다.
통사론 | 매개 변수 없음 |
---|---|
{PROCEDURE_NAME () 호출} | 입력 매개 변수 및 출력 매개 변수 없음 |
{PROCEDURE_NAME (?,?,?)에 전화} | 3 개의 입력 매개 변수 및 출력 매개 변수 없음 |
{? = PROCEDURE_NAME ()} 호출 | 입력 매개 변수 없음 및 하나의 출력 매개 변수 (RETURN 값) |
{? = PROCEDURE_NAME 호출 (?,?)} | 2 개의 입력 매개 변수 및 1 개의 출력 매개 변수 (RETURN 값) |
저장 프로 시저를 만드는 단계
#1) DB 서버에서 프로 시저를 생성합니다. 여기에서는 Oracle DB를 사용하고 있습니다.
# 2) 전체 프로 시저 생성 구문 :
저장 프로 시저를 Java 코드로도 작성할 수 있습니다.
#삼) 절차에서 사용하려면 IN 및 OUT 매개 변수를 전달하십시오.
# 4) AS / IS 키워드를 언급해야합니다. 새 프로 시저에 다른 프로 시저를 추가하는 경우 IS 키워드를 사용하거나 프로 시저가 독립형이면 AS 키워드를 사용하십시오.
# 5) 우리가 생성 할 수있는 요구 사항에 따라 필수가 아닌 변수를 선언합니다.
# 6) 그런 다음 BEGIN 키워드를 사용하여 프로 시저를 시작하고 프로 시저에서 수행 할 SQL 문 또는 쿼리를 작성하십시오.
C ++에서 int 로의 char
# 7) 다음으로 Exception 부분에서 예외를 처리 할 수 있습니다. 언급 할 필요도 없습니다.
# 8) END 키워드와 프로 시저 이름을 언급하여 프로 시저를 종료하십시오.
Oracle에서 프로 시저를 만들고 고유 한 이름으로 저장하고 Java 프로그램에서 해당 프로 시저를 호출 할 수 있습니다. 프로 시저를 생성하고 Java에서도 해당 프로 시저를 호출 할 수 있습니다.
Oracle에서 프로 시저를 작성하고 저장 한 후 Java 프로그램에서 프로 시저를 호출하십시오.
#1) 데이터베이스 서버를 엽니 다. 여기에서는 Oracle DB 서버를 사용하고 있습니다.
#두) Procedure 폴더를 마우스 오른쪽 버튼으로 클릭하고 New Procedure 옵션을 클릭합니다.
#삼) 프로 시저 이름과 매개 변수 세부 사항을 묻습니다.
노트 : 프로 시저를 작성하는 동안에도 매개 변수 세부 사항을 제공 할 수 있습니다.
# 4) 이 자습서에서 이미 논의한 단계를 사용하여 절차를 작성하고 고유 한 이름으로 절차를 저장합니다.
스크린 샷의 절차는 DB에 출력을 표시합니다. Java 프로그램에서도 표시하도록 변경할 수 있습니다. 이를 위해 OUT 매개 변수를 사용해야합니다.
# 5) 실행 버튼을 클릭하여 절차를 실행합니다.
# 6) 입력 값 열에 값을 입력하십시오. 주어진 값에 대한 데이터를 표시합니다.
지금까지 DB 콘솔 자체에서 프로 시저를 생성하고 실행하는 방법을 살펴 보았습니다.
DB에 프로 시저를 생성합니다. 그것을 호출하고 Java 콘솔에 데이터를 표시하십시오. .
위의 단계를 사용하여 다음 절차를 만들고 'DISPLAY_EMPLOYEE_DETAILS'라는 이름으로 저장합니다.
Java 저장 프로 시저 예제 프로그램
package com.STH.JDBC; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; public class StoredProcedureExample { public static void main(String() args) throws ClassNotFoundException { Class.forName('oracle.jdbc.driver.OracleDriver'); //Connecting to Oracle DB Try (Connection conn = DriverManager.getConnection('jdbc:oracle:thin:system/pass123@localhost:1521:XE')) { // Creating prepared Statement CallableStatementCallStmt = conn.prepareCall('{call DISPLAY_EMPLOYEE_DETAILS(?,?,?,?)}'); //Passing Input Parameter CallStmt.setInt(1,1001); //Retrieving the Output Parameters values CallStmt.registerOutParameter(2, java.sql.Types.VARCHAR); CallStmt.registerOutParameter(3, java.sql.Types.VARCHAR); CallStmt.registerOutParameter(4, java.sql.Types.VARCHAR); //Calling the execute to execute the procedure and retrieve the data CallStmt.execute(); System.out.println('First Name: '+ CallStmt.getString(2)+'
Last Name: '+ CallStmt.getString(3) + '
Email: ' + CallStmt.getString(4)); }catch (SQLException e) { e.printStackTrace(); } } }
산출:
설명:
위 프로그램에서 우리가 한 것은 하나의 프로 시저를 생성하여 Oracle DB에 저장 한 것입니다. 그런 다음 CallableStatement를 사용하여 해당 프로 시저를 호출하고 Java 콘솔에 데이터를 표시했습니다.
- 프로 시저를 생성하고 Oracle DB에 저장합니다.
- Java 프로그램에서 DB 연결을 열고 connection 및 CallableStatement 개체를 사용하여 prepareCall 메서드를 호출합니다.
- setXXX 메소드를 사용하여 입력 매개 변수 값을 전달하십시오.
- registerOutParameter 메소드를 사용하여 출력 매개 변수 값을 검색하십시오. 이 방법에서는 매개 변수 인덱스 값과 매개 변수의 데이터 유형을 전달해야합니다. 매개 변수 색인에 값을 저장합니다.
- getXXX 메소드를 사용하여 데이터를 검색하고 Java 콘솔에 표시 할 수 있습니다.
프로 시저를 작성하고 Java 프로그램 자체에서 실행하십시오.
자바 프로그램
package com.STH.JDBC; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Statement; public class StoredProcedureExample1 { public static void main(String() args) throws ClassNotFoundException { String Stored_Procedure = 'CREATE OR REPLACE PROCEDURE UPD_EMPLOYEE_DETAILS
' +'(
' + ' PARAM1 IN NUMBER,
' + ' PARAM2 IN NUMBER
'+ ') IS
'+ ' BEGIN
'+ 'UPDATE EMPLOYEE_DETAILS SET EMPNUM= PARAM2 WHERE EMPNUM = PARAM1;
'+ 'COMMIT;
'+ 'END UPD_EMPLOYEE_DETAILS;
'; Class.forName('oracle.jdbc.driver.OracleDriver'); //Connecting to Oracle DB try(Connection conn = DriverManager.getConnection('jdbc:oracle:thin:system/pass123@localhost:1521:XE')) {// Creating prepared Statement Statement stmt = conn.createStatement(); CallableStatementCallStmt = conn.prepareCall('{call UPD_EMPLOYEE_DETAILS(?,?)}'); stmt.execute(Stored_Procedure); //Setting the values to pass the procedure CallStmt.setInt(1,1010); CallStmt.setInt(2, 10010); //Calling executeUpdate method to update the values using Procedure CallStmt.executeUpdate(); System.out.println(' Successfully Updated ' ); } catch (SQLException e) { e.printStackTrace(); } } }
산출:
프로그램 실행 전 Employee_details 테이블의 데이터 :
프로그램 실행 후 Employee_details 테이블의 데이터 :
설명:
위의 프로그램에서는 프로 시저 코드를 문자열로 저장합니다.
String Stored_Procedure = 'CREATE OR REPLACE PROCEDURE UPD_EMPLOYEE_DETAILS
' +'(
' +' PARAM1 IN NUMBER,
' +' PARAM2 IN NUMBER
'+ ') IS
'+' BEGIN
'+'UPDATE EMPLOYEE_DETAILS SET EMPNUM= PARAM2 WHERE EMPNUM = PARAM1;
'+'COMMIT;
'+'END UPD_EMPLOYEE_DETAILS;
';
- Oracle DB 연결을 열고 연결 개체를 사용하여 문 개체를 만듭니다.
- Java 코드로 프로 시저를 생성하고 있으므로 statement 객체를 사용하여 createStatement 메서드를 호출합니다.
- 구문을 사용하여 프로 시저 호출 {UPD_EMPLOYEE_DETAILS (?,?)에 전화 CallableStatement의 prepareCall 메소드입니다.
- Java 코드로 프로 시저를 생성하고 있으므로 'Create procedure Code'를 실행해야합니다.
- 해당 프로 시저를 실행하려면 Statement 객체“ stmt.execute (Stored_Procedure) ”. 그러면 DB에 임시로 프로 시저가 생성됩니다.
- 프로 시저의 범위는 프로그램 실행의 끝입니다. 그 후에는 사용할 수 없습니다. setXXX 메서드를 사용하여 Employee_Details 테이블에서 업데이트 할 값을 설정합니다.
- callableStatement 객체를 사용하여 executeUpdate 메서드를 호출합니다. 이 메서드는 Empoyee_Details 이야기의 값을 업데이트합니다.
- Employee_details 테이블에서 데이터가 제대로 업데이트되었는지 확인하십시오.
기억해야 할 사항 :
- 일괄 처리는 성능을 향상시키고 데이터 일관성을 유지합니다.
- 하나의 트랜잭션에서 여러 SQL 문을 실행하는 것을 일괄 처리라고합니다.
- 저장 프로시 저는 비즈니스 논리를 수행하는 데 사용되는 SQL 문 블록입니다.
- IN 키워드를 사용하여 입력 매개 변수를 프로 시저에 전달하고 출력 매개 변수에 대해 OUT 키워드를 전달할 수 있습니다.
- DB 서버 자체에서 프로 시저를 생성 할 수 있으며 일시적으로 Java 코드도 사용할 수 있습니다.
자주 묻는 질문
Q # 1) JDBC에서 일괄 처리를 수행하려면 어떤 인터페이스를 사용해야합니까?
대답: Java 패키지에는 일괄 처리를 수행하는 방법을 제공하는 Statement 및 PreparedStatement 인터페이스가 있습니다.
Q # 2) JDBC에서 배치 업데이트는 어떻게 작동합니까?
대답: JDBC 일괄 업데이트는 업데이트를 하나씩 보내는 대신 한 번에 그룹화되어 데이터베이스로 전송되는 업데이트 모음입니다. 따라서 데이터베이스의 네트워크 트래픽을 줄입니다.
Q # 3) 일괄 처리로 성능이 어떻게 향상됩니까?
대답: 일괄 처리는 데이터를 하나씩 전송하지 않고 한 번에 (단 1 회 왕복) 데이터베이스로 전송하며 데이터베이스는 일부 명령문을 병렬로 실행할 수 있습니다. 이와 같이 응용 프로그램의 성능을 높이고 시간을 절약합니다.
Q # 4) JDBC의 저장 프로 시저에서 허용되는 매개 변수는 무엇입니까?
대답: 세 가지 유형의 매개 변수 (IN, OUT 및 INOUT 매개 변수)가 있습니다. IN 매개 변수는 입력 값을 가져 오는 것입니다. OUT 매개 변수는 출력 값을 검색하기위한 것입니다. INOUT 매개 변수는 입력 및 출력 모두에 사용됩니다.
Q # 5) JDBC에서 저장 프로 시저를 실행하는 데 사용할 수있는 방법은 무엇입니까?
대답: CallableStatement 인터페이스를 사용하여 프로 시저를 호출 할 수 있습니다. CallableStatement 인터페이스는 저장 프로 시저를 실행하는 세 가지 메서드를 제공합니다.
세 가지 방법은 다음과 같습니다.
- executeUpdate () : 프로 시저가 반환 값을 반환하지 않는 경우이 메서드를 사용합니다.
- executeQuery () : 프로 시저가 하나의 결과 집합 만 반환하는 경우이 방법을 사용합니다.
- execute () : 프로 시저가 많은 결과 집합을 반환하거나 알 수없는 수의 결과 집합을 반환하는 경우이 방법을 사용합니다.
결론
이 자습서에서는 일괄 처리 및 저장 프로 시저를 다루었습니다. 현대 사회에서 고성능, 데이터 일관성 및 재사용 성은 널리 사용되는 모든 애플리케이션의 유행어입니다. 일괄 처리와 저장 프로시 저는 모두 이러한 기능을 구현하는 데 매우 중요한 역할을합니다. 이러한 지식은 모든 소프트웨어 엔지니어에게 필연적입니다.