Commit @aa51dd1755c0923ed3dfd96a8b6e0ecaeb2d0562

이호영 2024-11-28

문자전송 배치 테스트

@aa51dd1755c0923ed3dfd96a8b6e0ecaeb2d0562

26d9cad

aa51dd1

src/main/java/itn/let/mjo/msgdata/service/impl/MjonMsgDataServiceImpl.java

--- src/main/java/itn/let/mjo/msgdata/service/impl/MjonMsgDataServiceImpl.java

+++ src/main/java/itn/let/mjo/msgdata/service/impl/MjonMsgDataServiceImpl.java


 //		int instCnt = mjonMsgDataDAO.insertMsgDataInfo_jdbc_advc(mjonMsgSendVOList);
 
 		//
-		int instCnt = 0;
-	    int batchSize = (int) Math.ceil((double) mjonMsgSendVOList.size() / 3); // Batch 크기 계산
-		// Batch 처리
-		for (int i = 0; i < mjonMsgSendVOList.size(); i += batchSize) {
-			System.out.println(" i :: "+ i);
-			// Batch 크기만큼 리스트를 잘라냄
-			List<MjonMsgSendVO> batchList = mjonMsgSendVOList.subList(
-				i, Math.min(i + batchSize, mjonMsgSendVOList.size())
-			);
-		
-			// DAO 메서드 호출
-			int insertedCount = mjonMsgDataDAO.insertMsgDataInfo_advc(batchList);
-			instCnt += insertedCount; // 총 삽입된 건수 누적
-		}
+	    int totalSize = mjonMsgSendVOList.size(); // 총 데이터 개수
+	    int batchSize = (int) Math.ceil((double) totalSize / 3); // 기본 3등분 크기 계산
+
+	    // Batch 크기가 7000을 초과하면 7000으로 제한
+	    batchSize = Math.min(batchSize, 7000);
+
+	    int instCnt = 0;
+
+	    int j = 0;
+	    for (int i = 0; i < totalSize; i += batchSize) {
+	        // Batch 리스트 생성
+	        List<MjonMsgSendVO> batchList = mjonMsgSendVOList.subList(
+	            i, Math.min(i + batchSize, totalSize)
+	        );
+	        System.out.println("i : "+ i);
+	        // DAO 호출
+	        int insertedCount = mjonMsgDataDAO.insertMsgDataInfo_advc(batchList);
+	        instCnt += insertedCount;
+	        j++;
+	    }
 		
 		
 		// 종료 시간 측정

 		// 실행 시간 계산 (밀리초 -> 초로 변환)
 		double executionTimeInSeconds = (endTime - startTime) / 1000.0;
 		// 실행 시간 출력
+		System.out.println("j :: " + j);
 		System.out.println("batchSize :: " + batchSize);
 		System.out.println("Execution time :: " + executionTimeInSeconds + "초 " + "// insert Cnt :: "+instCnt);
 //		mjonMsgSendVOList.stream().forEach(t-> System.out.print(t.toString()+"\n") );

Add a comment

Open 0
Closed 0

List

...	...	@@ -4179,20 +4179,26 @@
4179	4179	// int instCnt = mjonMsgDataDAO.insertMsgDataInfo_jdbc_advc(mjonMsgSendVOList);
4180	4180
4181	4181	//
4182		- int instCnt = 0;
4183		- int batchSize = (int) Math.ceil((double) mjonMsgSendVOList.size() / 3); // Batch 크기 계산
4184		- // Batch 처리
4185		- for (int i = 0; i < mjonMsgSendVOList.size(); i += batchSize) {
4186		- System.out.println(" i :: "+ i);
4187		- // Batch 크기만큼 리스트를 잘라냄
4188		- List<MjonMsgSendVO> batchList = mjonMsgSendVOList.subList(
4189		- i, Math.min(i + batchSize, mjonMsgSendVOList.size())
4190		- );
4191		-
4192		- // DAO 메서드 호출
4193		- int insertedCount = mjonMsgDataDAO.insertMsgDataInfo_advc(batchList);
4194		- instCnt += insertedCount; // 총 삽입된 건수 누적
4195		- }
	4182	+ int totalSize = mjonMsgSendVOList.size(); // 총 데이터 개수
	4183	+ int batchSize = (int) Math.ceil((double) totalSize / 3); // 기본 3등분 크기 계산
	4184	+
	4185	+ // Batch 크기가 7000을 초과하면 7000으로 제한
	4186	+ batchSize = Math.min(batchSize, 7000);
	4187	+
	4188	+ int instCnt = 0;
	4189	+
	4190	+ int j = 0;
	4191	+ for (int i = 0; i < totalSize; i += batchSize) {
	4192	+ // Batch 리스트 생성
	4193	+ List<MjonMsgSendVO> batchList = mjonMsgSendVOList.subList(
	4194	+ i, Math.min(i + batchSize, totalSize)
	4195	+ );
	4196	+ System.out.println("i : "+ i);
	4197	+ // DAO 호출
	4198	+ int insertedCount = mjonMsgDataDAO.insertMsgDataInfo_advc(batchList);
	4199	+ instCnt += insertedCount;
	4200	+ j++;
	4201	+ }
4196	4202
4197	4203
4198	4204	// 종료 시간 측정
...	...	@@ -4200,6 +4206,7 @@
4200	4206	// 실행 시간 계산 (밀리초 -> 초로 변환)
4201	4207	double executionTimeInSeconds = (endTime - startTime) / 1000.0;
4202	4208	// 실행 시간 출력
	4209	+ System.out.println("j :: " + j);
4203	4210	System.out.println("batchSize :: " + batchSize);
4204	4211	System.out.println("Execution time :: " + executionTimeInSeconds + "초 " + "// insert Cnt :: "+instCnt);
4205	4212	// mjonMsgSendVOList.stream().forEach(t-> System.out.print(t.toString()+"\n") );

Delete comment