From e96bb22814eabda9fb064f0a56bb9a6233d811f3 Mon Sep 17 00:00:00 2001 From: mathias Date: Fri, 27 Aug 2021 14:05:49 +0200 Subject: [PATCH] Integrated the new ConnectSettingsManager --- .../sqltoolkit/drivers/MySQLConnection.java | 51 ++----------------- 1 file changed, 4 insertions(+), 47 deletions(-) diff --git a/src/main/java/de/gnmyt/sqltoolkit/drivers/MySQLConnection.java b/src/main/java/de/gnmyt/sqltoolkit/drivers/MySQLConnection.java index 948d238..fcdddae 100755 --- a/src/main/java/de/gnmyt/sqltoolkit/drivers/MySQLConnection.java +++ b/src/main/java/de/gnmyt/sqltoolkit/drivers/MySQLConnection.java @@ -7,7 +7,6 @@ import de.gnmyt.sqltoolkit.manager.*; import de.gnmyt.sqltoolkit.querybuilder.AbstractQuery; import de.gnmyt.sqltoolkit.querybuilder.QueryBuilder; import de.gnmyt.sqltoolkit.querybuilder.SQLQuery; -import de.gnmyt.sqltoolkit.types.LoginParam; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -20,14 +19,13 @@ public class MySQLConnection { public static final Logger LOG = LoggerFactory.getLogger("MySQL-Logger"); private final TableFactory tableFactory = new TableFactory(this); + private final ConnectSettingsManager settingsManager = new ConnectSettingsManager(this); private final String hostname; private final String username; private final String password; private final String database; - private String connectString = ""; - private Connection con; /** @@ -45,21 +43,8 @@ public class MySQLConnection { this.database = database; } - /** - * Advanced constructor for the connection - * - * @param hostname MySQL server hostname - * @param username MySQL server username - * @param password MySQL server password - * @param database MySQL server database - * @param loginParams Login parameters - */ - public MySQLConnection(String hostname, String username, String password, String database, LoginParam... loginParams) { - this.hostname = hostname; - this.username = username; - this.password = password; - this.database = database; - updateConnectionString(loginParams); + public ConnectSettingsManager updateSettings() { + return settingsManager; } /** @@ -320,7 +305,7 @@ public class MySQLConnection { try { LOG.info("Connecting to " + hostname + " with user " + username + " to database " + database); Class.forName("com.mysql.cj.jdbc.Driver"); - con = DriverManager.getConnection("jdbc:mysql://" + hostname + "/" + database + connectString, username, password); + con = DriverManager.getConnection("jdbc:mysql://" + hostname + "/" + database + settingsManager.generateConnectionString(), username, password); LOG.info("Connection established"); } catch (Exception exception) { if (exception.getMessage().contains("jdbc.Driver")) @@ -353,34 +338,6 @@ public class MySQLConnection { return this; } - /** - * Update the Connection String - * - * @param loginParams New login parameters - * @return this class - */ - public MySQLConnection updateConnectionString(LoginParam... loginParams) { - this.connectString = getConnectionString(loginParams); - return this; - } - - /** - * Get the current jdbc connection string for mysql - * - * @param loginParams login parameters - * @return the string - */ - private String getConnectionString(LoginParam[] loginParams) { - boolean used = false; - StringBuilder currentString = new StringBuilder(); - for (LoginParam param : loginParams) { - String currentChar = (used) ? "&" : "?"; - used = true; - currentString.append(currentChar).append(param.getValue()); - } - return currentString.toString(); - } - /** * Check if you are connected *