Commit @1b1af3034f47cd00bfa53b1726c4a910dff55a9c

이호영 2024-07-30

10만건 한번에 insert - 개발서버에서 테스트

@1b1af3034f47cd00bfa53b1726c4a910dff55a9c

0d2e8d1

1b1af30

src/main/java/itn/let/mjo/addr/service/impl/AddrServiceImpl.java

--- src/main/java/itn/let/mjo/addr/service/impl/AddrServiceImpl.java

+++ src/main/java/itn/let/mjo/addr/service/impl/AddrServiceImpl.java


 //    private static final int MAX_ADDR_CNT = 500000;
     //임시 500만개
     private static final int MAX_ADDR_CNT = 5000000;
-    private static final int BATCH_SIZE = 10000;
-    private static final int THREAD_COUNT = 3;
+//    private static final int BATCH_SIZE = 10000;
+//    private static final int THREAD_COUNT = 3;
 	
 	
 	public List<AddrVO> selectAddrList(AddrVO addrVO) throws Exception {

 	    		// 등록 
 	            // Batch insert
 //	                batchInsertAddrList(addrListVO);
-	                batchInsertAddrListAsync(addrListVO);
+//	                batchInsertAddrListAsync(addrListVO);
+
+                addrDAO.insertAddrList(addrListVO);
 					
 	//    		addrDAO.insertAddrList(addrListVO);
 	        	

 	}
 
 
-    private void batchInsertAddrListAsync(List<AddrVO> addrListVO) throws InterruptedException {
+    /*private void batchInsertAddrListAsync(List<AddrVO> addrListVO) throws InterruptedException {
         int totalSize = addrListVO.size();
         int batchCount = (totalSize + BATCH_SIZE - 1) / BATCH_SIZE;
         ExecutorService executor = Executors.newFixedThreadPool(THREAD_COUNT);

 
         executor.shutdown();
         executor.awaitTermination(1, TimeUnit.HOURS);
-    }
+    }*/
 
 	public static boolean isValidPhoneNumber(String phoneNo) {
         if (phoneNo == null || phoneNo.isEmpty()) {

Add a comment

Open 0
Closed 0

List

...	...	@@ -65,8 +65,8 @@
65	65	// private static final int MAX_ADDR_CNT = 500000;
66	66	//임시 500만개
67	67	private static final int MAX_ADDR_CNT = 5000000;
68		- private static final int BATCH_SIZE = 10000;
69		- private static final int THREAD_COUNT = 3;
	68	+// private static final int BATCH_SIZE = 10000;
	69	+// private static final int THREAD_COUNT = 3;
70	70
71	71
72	72	public List<AddrVO> selectAddrList(AddrVO addrVO) throws Exception {
...	...	@@ -479,7 +479,9 @@
479	479	// 등록
480	480	// Batch insert
481	481	// batchInsertAddrList(addrListVO);
482		- batchInsertAddrListAsync(addrListVO);
	482	+// batchInsertAddrListAsync(addrListVO);
	483	+
	484	+ addrDAO.insertAddrList(addrListVO);
483	485
484	486	// addrDAO.insertAddrList(addrListVO);
485	487
...	...	@@ -517,7 +519,7 @@
517	519	}
518	520
519	521
520		- private void batchInsertAddrListAsync(List<AddrVO> addrListVO) throws InterruptedException {
	522	+ /*private void batchInsertAddrListAsync(List<AddrVO> addrListVO) throws InterruptedException {
521	523	int totalSize = addrListVO.size();
522	524	int batchCount = (totalSize + BATCH_SIZE - 1) / BATCH_SIZE;
523	525	ExecutorService executor = Executors.newFixedThreadPool(THREAD_COUNT);
...	...	@@ -542,7 +544,7 @@
542	544
543	545	executor.shutdown();
544	546	executor.awaitTermination(1, TimeUnit.HOURS);
545		- }
	547	+ }*/
546	548
547	549	public static boolean isValidPhoneNumber(String phoneNo) {
548	550	if (phoneNo == null \|\| phoneNo.isEmpty()) {

Delete comment