From: Roland Haeder Date: Wed, 29 Jul 2015 13:00:13 +0000 (+0200) Subject: Implemented doShutdown() for MySQL backend X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=669ceb6256a7f4f06d95be7686bb965382037b84;p=jaddressbook-lib.git Implemented doShutdown() for MySQL backend Signed-off-by:Roland Häder --- diff --git a/Addressbook/src/org/mxchange/addressbook/database/backend/mysql/MySqlDatabaseBackend.java b/Addressbook/src/org/mxchange/addressbook/database/backend/mysql/MySqlDatabaseBackend.java index 6a7b0094..900d5a89 100644 --- a/Addressbook/src/org/mxchange/addressbook/database/backend/mysql/MySqlDatabaseBackend.java +++ b/Addressbook/src/org/mxchange/addressbook/database/backend/mysql/MySqlDatabaseBackend.java @@ -57,19 +57,26 @@ public class MySqlDatabaseBackend extends BaseDatabaseBackend implements Databas @Override public void connectToDatabase () throws SQLException { // Trace message - this.getLogger().trace("CALLED!"); + this.getLogger().trace("CALLED!"); //NOI18N // Generate connection string - String connect = String.format("jdbc:mysql://%s/%s", this.getProperty("org.mxchange.addressbook.database.mysql.host"), this.getProperty("org.mxchange.addressbook.database.mysql.dbname")); + String connect = String.format("jdbc:mysql://%s/%s", //NOI18N + this.getProperty("org.mxchange.addressbook.database.mysql.host"), //NOI18N + this.getProperty("org.mxchange.addressbook.database.mysql.dbname") //NOI18N + ); // Debug message - this.getLogger().debug(MessageFormat.format("Attempting to connect to {0} ...", connect)); + this.getLogger().debug(MessageFormat.format("Attempting to connect to {0} ...", connect)); //NOI18N // Now get a connection instance back - this.connection = DriverManager.getConnection(connect, this.getProperty("org.mxchange.addressbook.database.mysql.login"), this.getProperty("org.mxchange.addressbook.database.mysql.password")); + this.connection = DriverManager.getConnection( + connect, + this.getProperty("org.mxchange.addressbook.database.mysql.login"), //NOI18N + this.getProperty("org.mxchange.addressbook.database.mysql.password") //NOI18N + ); // Trace message - this.getLogger().trace("EXIT!"); + this.getLogger().trace("EXIT!"); //NOI18N } @Override @@ -79,7 +86,15 @@ public class MySqlDatabaseBackend extends BaseDatabaseBackend implements Databas @Override public void doShutdown () { - throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates. + // This should not happen: + assert(this.connection == null) : "connection is null"; + + try { + // Close down database connection + this.connection.close(); + } catch (final SQLException ex) { + this.abortProgramWithException(ex); + } } @Override