Merge pull request #110 from hiroyuki-sato/mysql_jdbc_version

[WIP] Output a version of MySQL Connector/J.

Author: hito4t

embulk-input-jdbc/src/main/java/org/embulk/input/jdbc/AbstractJdbcInputPlugin.java

@@ -184,6 +184,8 @@ public ConfigDiff transaction(ConfigSource config,
 
         Schema schema;
         try (JdbcInputConnection con = newConnection(task)) {
+            con.showDriverVersion();
+
             // TODO incremental_columns is not set => get primary key
             schema = setupTask(con, task);
         } catch (SQLException ex) {

embulk-input-jdbc/src/main/java/org/embulk/input/jdbc/JdbcInputConnection.java

@@ -7,6 +7,7 @@
 import java.sql.ResultSetMetaData;
 import java.sql.SQLException;
 import java.sql.Statement;
+import java.util.Locale;
 import java.util.Set;
 
 import org.embulk.config.ConfigException;
@@ -386,4 +387,9 @@ private Set<String> getColumnNames(String tableName) throws SQLException
             return columnNamesBuilder.build();
         }
     }
+
+    public void showDriverVersion() throws SQLException {
+        DatabaseMetaData meta = connection.getMetaData();
+        logger.info(String.format(Locale.ENGLISH,"Using JDBC Driver %s",meta.getDriverVersion()));
+    }
 }

embulk-input-mysql/src/main/java/org/embulk/input/mysql/MySQLInputConnection.java

@@ -67,4 +67,19 @@ public void compareTimeZone() throws SQLException
         timeZoneComparison.compareTimeZone();
     }
 
+    //
+    //
+    // The MySQL Connector/J 5.1.35 introduce new option `Current MySQL Connect`.
+    // It has incompatibility behavior current version and 5.1.35.
+    //
+    // This method announces users about this change before the update driver version.
+    //
+    @Override
+    public void showDriverVersion() throws SQLException {
+        super.showDriverVersion();
+        logger.warn("This plugin will update MySQL Connector/J version in the near future release.");
+        logger.warn("It has some incompatibility changes.");
+        logger.warn("For example, the 5.1.35 introduced `noTimezoneConversionForDateType` and `cacheDefaultTimezone` options.");
+        logger.warn("Please read a document and make sure configuration carefully before updating the plugin.");
+    }
 }