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 |
Tags
- 옵저버블
- angular button
- ApexChart
- formgroup
- route
- ajax 사용 예시
- mysql if
- 검색
- TAILWIND
- 앵귤러 애니메이션
- Router
- angular animation
- angular route
- 스크롤 이벤트 감지
- flex-1
- Ionic modal
- Angular Router
- egov spring ajax 사용 예시
- 아이오닉 스크롤 이벤트
- 모달
- Oracle LISTAGG 사용 예시
- 셀렉트박스 커스텀
- 스크롤 이벤트
- scroll
- summary
- 앵귤러 모달
- modal
- prisma
- angular modal
- 호버
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