Quellcode durchsuchen

update pagging processing

shjung vor 10 Monaten
Ursprung
Commit
8fd513179c

+ 9 - 1
src/main/java/com/ggits/etlp/server/common/Elapsed.java

@@ -31,13 +31,21 @@ public class Elapsed {
 
 	public String elapsedTimeStr() {
 		long elapsed = getElapsed();
+		long hours = TimeUnit.HOURS.convert(elapsed, TimeUnit.NANOSECONDS);
+		long minutes = TimeUnit.MINUTES.convert(elapsed, TimeUnit.NANOSECONDS);
 		long seconds = TimeUnit.SECONDS.convert(elapsed, TimeUnit.NANOSECONDS);
 		long miliSeconds = TimeUnit.MILLISECONDS.convert(elapsed, TimeUnit.NANOSECONDS) % 1000;
 		long microSeconds = TimeUnit.MICROSECONDS.convert(elapsed, TimeUnit.NANOSECONDS) % 1000;
 		long nanoSeconds = TimeUnit.NANOSECONDS.convert(elapsed, TimeUnit.NANOSECONDS) % 1000;
 
+		if (hours > 0) {
+			return String.format("Elapsed: %,d hr. %2d min. %2d sec. %3d ms. %3d us. %3d ns.", hours, minutes, seconds, miliSeconds, microSeconds, nanoSeconds);
+		}
+		if (minutes > 0) {
+			return String.format("Elapsed: %2d min. %2d sec. %3d ms. %3d us. %3d ns.", minutes, seconds, miliSeconds, microSeconds, nanoSeconds);
+		}
 		if (seconds > 0) {
-			return String.format("Elapsed: %,d sec. %3d ms. %3d us. %3d ns.", seconds, miliSeconds, microSeconds, nanoSeconds);
+			return String.format("Elapsed: %2d sec. %3d ms. %3d us. %3d ns.", seconds, miliSeconds, microSeconds, nanoSeconds);
 		}
 		if (miliSeconds > 0) {
 			return String.format("Elapsed: %3d ms. %3d us. %3d ns.", miliSeconds, microSeconds, nanoSeconds);

+ 2 - 16
src/main/java/com/ggits/etlp/server/config/ApplicationConfig.java

@@ -14,25 +14,13 @@ import javax.annotation.PostConstruct;
 public class ApplicationConfig {
 
     private String processId = "81010";
-    private String ggitsServerIp = "192.168.24.22";
-    private int dbmsWorkers = 0;
-    private int dbmsQueueSize = 0;
     private boolean loggingHist = true;
     private int pageCount = 50000;
 
     @PostConstruct
     private void init() {
-
-        if (this.dbmsWorkers == 0) {
-            this.dbmsWorkers = Runtime.getRuntime().availableProcessors();
-            if (this.dbmsWorkers == 0) this.dbmsWorkers = 1;
-        }
-        if (this.dbmsQueueSize <= 0) {
-            this.dbmsQueueSize = 50000;
-        }
-
         if (this.pageCount == 0) {
-            this.pageCount = 10000;
+            this.pageCount = 50000;
         }
         if (this.pageCount < 1000) {
             this.pageCount = 1000;
@@ -40,9 +28,7 @@ public class ApplicationConfig {
         this.pageCount = Math.min(100000, this.pageCount);
 
         log.info("[{}] -------------------------", this.getClass().getSimpleName());
-        log.info("[{}]   dbmsWorkers: {}", this.getClass().getSimpleName(), this.dbmsWorkers);
-        log.info("[{}] dbmsQueueSize: {}", this.getClass().getSimpleName(), this.dbmsQueueSize);
-        log.info("{}", super.toString());
+        log.info("[{}]     pageCount: {}", this.getClass().getSimpleName(), this.pageCount);
     }
 
 }