chore: remove unnecessary logs, update dependencies' version (#37)

api/src/main/java/de/xab/porter/api/task/Properties.java

@@ -5,6 +5,15 @@
  */
 public final class Properties {
     private String channel = "default";
+    private String reporter = "default";
+
+    public String getReporter() {
+        return reporter;
+    }
+
+    public void setReporter(String reporter) {
+        this.reporter = reporter;
+    }
 
     public String getChannel() {
         return channel;

core/src/main/java/de/xab/porter/core/Task.java

@@ -3,6 +3,7 @@
 import de.xab.porter.api.dataconnection.SinkConnection;
 import de.xab.porter.api.dataconnection.SrcConnection;
 import de.xab.porter.api.task.Context;
+import de.xab.porter.api.task.Properties;
 import de.xab.porter.common.spi.ExtensionLoader;
 import de.xab.porter.common.util.Loggers;
 import de.xab.porter.transfer.channel.Channel;
@@ -44,9 +45,10 @@ public void init() {
      * construct relations among reader, writer and its channel, define the action when channel is ready to write
      */
     public void register() {
+        Properties properties = context.getProperties();
         List<SinkConnection> sinkConnections = context.getSinkConnections();
         Reporter reporter = ExtensionLoader.getExtensionLoader(Reporter.class).
-                loadExtension(null, "default");
+                loadExtension(null, properties.getReporter());
         writers = sinkConnections.stream().
                 map(sink -> {
                     Writer<?> writer = ExtensionLoader.getExtensionLoader(Writer.class).

gradle.properties

@@ -5,12 +5,12 @@ gradleWrapper=7.1.1
 checkstylePlugin=8.44
 # test dependencies version
 jupiter=5.7.2
-mockito=3.11.2
+mockito=3.12.4
 # dependencies version
 ## demo
 h2=1.4.200
 ## common
-jackson=2.12.4
+jackson=2.12.5
 slf4j=1.7.32
 ### transfer/jdbc
 hikari=5.0.0

settings.gradle

@@ -1,7 +1,6 @@
 rootProject.name = 'porter'
 include 'api'
 include 'common'
-include 'spi'
 include 'transfer'
 include 'core'
 include 'transfer:jdbc'

transfer/jdbc/src/main/java/de/xab/porter/transfer/jdbc/reader/JDBCReader.java

@@ -56,8 +56,6 @@ public void doRead(Map<String, Column> columnMap) {
                 }
                 relation.getData().add(row);
                 if (batch % DEFAULT_BATCH_SIZE == 0) {
-                    logger.log(Level.INFO, String.format("read %d rows from %s %s",
-                            batch, srcConnection.getType(), srcConnection.getUrl()));
                     this.pushToChannel(new Result<>(seq++, relation));
                     relation = new Relation(meta);
                 }
@@ -70,7 +68,7 @@ public void doRead(Map<String, Column> columnMap) {
             Instant end = Instant.now();
             long seconds = Duration.between(start, end).toSeconds();
             logger.log(Level.INFO, String.format(
-                    "read completed. %s rows have been read, cost %s second(s)", batch, seconds));
+                    "%s rows have been read, cost %s second(s)", batch, seconds));
             try {
                 if (resultSet != null) {
                     resultSet.close();

transfer/jdbc/src/main/java/de/xab/porter/transfer/jdbc/writer/JDBCWriter.java

@@ -38,7 +38,7 @@ public void createTable(Result<?> data) {
         List<Column> meta = ((Relation) data.getResult()).getMeta();
         logger.log(Level.FINE, String.format("meta of table %s is: \n%s", tableIdentifier, Jsons.toJson(meta)));
         String ddl = getCreateDDL(tableIdentifier, quote, meta);
-        logger.log(Level.INFO, String.format("create table %s: \n\n%s\n", tableIdentifier, ddl));
+        logger.log(Level.INFO, String.format("create table %s: \n%s", tableIdentifier, ddl));
         try (Statement stmt = connection.createStatement()) {
             stmt.executeUpdate(ddl);
         } catch (SQLException e) {

transfer/src/main/java/de/xab/porter/transfer/reader/AbstractReader.java

@@ -32,13 +32,9 @@ public void read() {
         SrcConnection.Properties properties = srcConnection.getProperties();
         Map<String, Column> tableMetaData = new LinkedHashMap<>();
         if (properties.isTable() && properties.isCreate()) {
-            logger.log(Level.INFO, String.format("reading table metadata of %s %s...",
-                    srcConnection.getType(), srcConnection.getUrl()));
             tableMetaData = getTableMetaData();
         }
         initProperties(tableMetaData);
-        logger.log(Level.FINE, String.format("%s, reading table data from %s %s...",
-                properties.getSql(), srcConnection.getType(), srcConnection.getUrl()));
         doRead(tableMetaData);
     }
 

transfer/src/main/java/de/xab/porter/transfer/reporter/DefaultReporter.java

@@ -14,4 +14,4 @@ public <T> void report(T t) {
         Result<?> result = (Result<?>) t;
         logger.log(Level.INFO, String.format("wrote %sth batch", result.getSequenceNum()));
     }
-}
+}

transfer/src/main/java/de/xab/porter/transfer/writer/AbstractWriter.java

@@ -4,14 +4,10 @@
 import de.xab.porter.api.annoation.Inject;
 import de.xab.porter.api.dataconnection.DataConnection;
 import de.xab.porter.api.dataconnection.SinkConnection;
-import de.xab.porter.common.util.Loggers;
 import de.xab.porter.transfer.channel.Channel;
 import de.xab.porter.transfer.connector.Connector;
 import de.xab.porter.transfer.exception.ConnectionException;
 
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
 import static de.xab.porter.common.enums.SequenceEnum.LAST_IS_EMPTY;
 import static de.xab.porter.common.enums.SequenceEnum.isFirst;
 
@@ -21,7 +17,6 @@
 public abstract class AbstractWriter<T> implements Writer<T> {
     protected T connection;
     private Connector<?> connector;
-    private final Logger logger = Loggers.getLogger(this.getClass());
     private Channel channel;
 
     @Override
@@ -34,18 +29,12 @@ public void write(Result<?> data) {
 
         if (isFirst(data.getSequenceNum())) {
             if (properties.isDrop()) {
-                logger.log(Level.FINE, String.format("dropping table %s %s...",
-                        sinkConnection.getType(), sinkConnection.getUrl()));
                 dropTable();
             }
             if (properties.isCreate()) {
-                logger.log(Level.FINE, String.format("creating table %s %s...",
-                        sinkConnection.getType(), sinkConnection.getUrl()));
                 createTable(data);
             }
         }
-        logger.log(Level.FINE, String.format("writing data to %s %s...",
-                sinkConnection.getType(), sinkConnection.getUrl()));
         if (data.getSequenceNum() != LAST_IS_EMPTY.getSequenceNum()) {
             doWrite(data);
         }