diff --git a/migration-tool/src/main/java/org/full/migration/jdbc/SqlServerConnection.java b/migration-tool/src/main/java/org/full/migration/jdbc/SqlServerConnection.java index 5263b82e2441caab85401264ffcfaf8d94d35ad9..758ae08701a50a0768d4eacef91de9739750628a 100644 --- a/migration-tool/src/main/java/org/full/migration/jdbc/SqlServerConnection.java +++ b/migration-tool/src/main/java/org/full/migration/jdbc/SqlServerConnection.java @@ -38,11 +38,12 @@ public Connection getConnection(DatabaseConfig dbConfig) throws SQLException { String url = String.format(Locale.ROOT, SQLSERVER_URL, dbConfig.getHost(), dbConfig.getPort(), dbConfig.getDatabase()); try { + Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); return DriverManager.getConnection(url, dbConfig.getUser(), dbConfig.getPassword()); - } catch (SQLException e) { + } catch (SQLException | ClassNotFoundException e) { LOGGER.error("fail to create sql server connection, host:{}, port:{}, please check.", dbConfig.getHost(), dbConfig.getPort()); - throw e; + throw new SQLException(e.getMessage()); } } diff --git a/migration-tool/src/main/java/org/full/migration/source/SourceDatabase.java b/migration-tool/src/main/java/org/full/migration/source/SourceDatabase.java index d5252fed534b8fae488ac4d6a7a3debb2dda6b08..a43fcba2c47c5f4d869490ff7744a5bdf4970111 100644 --- a/migration-tool/src/main/java/org/full/migration/source/SourceDatabase.java +++ b/migration-tool/src/main/java/org/full/migration/source/SourceDatabase.java @@ -250,6 +250,7 @@ public void queryTables(Set schemaSet) { if (isDumpJson) { ProgressTracker.getInstance().recordTableProgress(); } + LOGGER.info("success to query all tables..."); } catch (SQLException e) { LOGGER.error("fail to query table list, error message:{}.", e.getMessage()); }