Browse Source

动态支持MySQL/Oracle

张泳健 5 years ago
parent
commit
6ab265ca00

src/main/java/com/vcarecity/cvs/BuildPartitionSQL.java → src/main/java/com/vcarecity/cvs/script/BuildPartitionSQL.java View File

1
-package com.vcarecity.cvs;
1
+package com.vcarecity.cvs.script;
2
 
2
 
3
 import lombok.extern.slf4j.Slf4j;
3
 import lombok.extern.slf4j.Slf4j;
4
 
4
 

src/main/java/com/vcarecity/cvs/csv/DataBuilder.java → src/main/java/com/vcarecity/cvs/script/DataBuilder.java View File

1
-package com.vcarecity.cvs.csv;
1
+package com.vcarecity.cvs.script;
2
 
2
 
3
 import java.io.IOException;
3
 import java.io.IOException;
4
 import java.io.UnsupportedEncodingException;
4
 import java.io.UnsupportedEncodingException;

src/main/java/com/vcarecity/cvs/csv/SQLCSVWriter.java → src/main/java/com/vcarecity/cvs/script/SQLCSVWriter.java View File

1
-package com.vcarecity.cvs.csv;
1
+package com.vcarecity.cvs.script;
2
 
2
 
3
 
3
 
4
 
4
 

src/main/java/com/vcarecity/cvs/TestInsertData.java → src/main/java/com/vcarecity/cvs/script/TestInsertData.java View File

1
-package com.vcarecity.cvs;
1
+package com.vcarecity.cvs.script;
2
 
2
 
3
 import com.google.inject.Inject;
3
 import com.google.inject.Inject;
4
 import com.zaxxer.hikari.HikariDataSource;
4
 import com.zaxxer.hikari.HikariDataSource;

+ 1 - 3
src/main/java/com/vcarecity/cvs/starter/SQLStarter.java View File

54
 
54
 
55
         long startTime = System.currentTimeMillis();
55
         long startTime = System.currentTimeMillis();
56
 
56
 
57
-        int count = 0;
58
         int currentSize;
57
         int currentSize;
59
-
60
         int page = 1;
58
         int page = 1;
61
 
59
 
62
         do {
60
         do {
63
             List<T> result = queryService.queryByPage(table, page, this.pageCount, cls);
61
             List<T> result = queryService.queryByPage(table, page, this.pageCount, cls);
64
             resultHandler.resultHandler(result, cls);
62
             resultHandler.resultHandler(result, cls);
65
             currentSize = result.size();
63
             currentSize = result.size();
66
-            count += currentSize;
64
+
67
             page++;
65
             page++;
68
 
66
 
69
         } while (currentSize == this.pageCount);
67
         } while (currentSize == this.pageCount);