Notice
Recent Posts
Recent Comments
Link
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | 6 | |
7 | 8 | 9 | 10 | 11 | 12 | 13 |
14 | 15 | 16 | 17 | 18 | 19 | 20 |
21 | 22 | 23 | 24 | 25 | 26 | 27 |
28 | 29 | 30 | 31 |
Tags
- Oracle LISTAGG 사용 예시
- 검색
- prisma
- 스크롤 이벤트 감지
- Router
- scroll
- Ionic modal
- 옵저버블
- TAILWIND
- 아이오닉 스크롤 이벤트
- egov spring ajax 사용 예시
- 호버
- Angular Router
- 셀렉트박스 커스텀
- angular animation
- 앵귤러 모달
- modal
- route
- 앵귤러 애니메이션
- angular button
- angular modal
- flex-1
- summary
- ApexChart
- formgroup
- angular route
- mysql if
- ajax 사용 예시
- 스크롤 이벤트
- 모달
Archives
- Today
- Total
깜놀하는 해므찌로
Java JDBC Batch 활용 예시 / JDBC 쿼리문 일괄 입력 / java 배치 활용 쿼리문 일괄 등록 JDBC 본문
IT
Java JDBC Batch 활용 예시 / JDBC 쿼리문 일괄 입력 / java 배치 활용 쿼리문 일괄 등록 JDBC
agnusdei1207 2022. 12. 3. 14:09반응형
SMALL
public HashMap<String,Object> testBatch(List<NameVO> excelList) throws Exception {
HashMap<String,Object> returnMap = new HashMap<>();
Connection con = null;
PreparedStatement pstmt = null ;
String msg = "";
try{
/* JDBC 드라이버 연결 */
Class.forName(driver);
/* DB연결 */
con = DriverManager.getConnection(url, id, pw);
/* 자동 커밋 방지 */
con.setAutoCommit(false);
String sql = "MERGE INTO T_NAME A ";
sql += "USING DUAL B ON (A.SEQ = ?) ";
sql += "WHEN NOT MATCHED THEN ";
sql += "INSERT (A.NAME, B.REG_DATE, A.USE_YN) ";
sql += "VALUES (T_NAME.NEXTVAL), ?, ? ,?) ";
sql += "WHEN MATCHED THEN ";
sql += "UPDATE SET ";
sql += " A.NAME = ?";
sql += ", A.REG_DATE = SYSDATE ";
sql += ", A.USE_YN = ? ";
pstmt = con.prepareStatement(sql) ;
for(int i= 0; i < excelList.size(); i++){
pstmt.setString(1, excelList.get(i).getName());
pstmt.setString(2, excelList.get(i).getRegDate());
pstmt.setString(3, excelList.get(i).getUseYn());
/* 배치에 추가 */
pstmt.addBatch();
/* 파라미터 클리어 */
pstmt.clearParameters() ;
/* 메모리 초과 현상 방지를 위해 1만 단위 커밋 */
if( (i % 10000) == 0 && i > 0){
/* Batch 입력 */
pstmt.executeBatch();
/* Batch 클리어 */
pstmt.clearBatch();
/* 커밋 */
con.commit();
}
}
/* 나머지 커밋 */
pstmt.executeBatch() ;
con.commit() ;
msg = excelList.size()+" 건 입력 완료!";
}catch(Exception e){
e.printStackTrace();
msg = "에러가 발생하였습니다";
}finally{
/* 연결 종료 */
if (pstmt != null) try {pstmt.close();pstmt = null;} catch(SQLException ex){}
if (con != null) try {con.close();con = null;} catch(SQLException ex){}
}
returnMap.put("msg", msg);
return returnMap;
}
반응형
LIST