Commit @118a60fe8bac7e142e7f97ffe7df4280d5d9a1b7

이호영 2024-11-28

배치 사이즈 수정해서 테스트

@118a60fe8bac7e142e7f97ffe7df4280d5d9a1b7

645a410

118a60f

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 = 0;
-		int batchSize = 5000;
+	    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);

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

Add a comment

Open 0
Closed 0

List

...	...	@@ -4180,7 +4180,7 @@
4180	4180
4181	4181	//
4182	4182	int instCnt = 0;
4183		- int batchSize = 5000;
	4183	+ int batchSize = (int) Math.ceil((double) mjonMsgSendVOList.size() / 3); // Batch 크기 계산
4184	4184	// Batch 처리
4185	4185	for (int i = 0; i < mjonMsgSendVOList.size(); i += batchSize) {
4186	4186	System.out.println(" i :: "+ i);
...	...	@@ -4200,6 +4200,7 @@
4200	4200	// 실행 시간 계산 (밀리초 -> 초로 변환)
4201	4201	double executionTimeInSeconds = (endTime - startTime) / 1000.0;
4202	4202	// 실행 시간 출력
	4203	+ System.out.println("batchSize :: " + batchSize);
4203	4204	System.out.println("Execution time :: " + executionTimeInSeconds + "초 " + "// insert Cnt :: "+instCnt);
4204	4205	// mjonMsgSendVOList.stream().forEach(t-> System.out.print(t.toString()+"\n") );
4205	4206	// mjonMsgSendVOList.stream().forEach(t-> System.out.print(t.toString()+"\n") );

Delete comment