From a5f68511628dd8d1f26d63dea24811c9dcf39e14 Mon Sep 17 00:00:00 2001 From: anthorob Date: Sun, 7 Nov 2021 08:57:55 -0500 Subject: [PATCH] Refactored mysql connector --- .../java/netneutrality/db/MysqlConnector.java | 20 ++++++++----------- 1 file changed, 8 insertions(+), 12 deletions(-) diff --git a/src/main/java/netneutrality/db/MysqlConnector.java b/src/main/java/netneutrality/db/MysqlConnector.java index 9a33dc2..d8f0063 100644 --- a/src/main/java/netneutrality/db/MysqlConnector.java +++ b/src/main/java/netneutrality/db/MysqlConnector.java @@ -1,8 +1,7 @@ package netneutrality.db; -import com.mysql.cj.jdbc.MysqlDataSource; - import java.sql.Connection; +import java.sql.DriverManager; import java.sql.SQLException; public class MysqlConnector { @@ -26,16 +25,13 @@ public class MysqlConnector { * @return {@link MysqlConnector} */ public MysqlConnector connect() throws SQLException { - MysqlDataSource dataSource = new MysqlDataSource(); - dataSource.setUser(dbUser); - dataSource.setPassword(dbPass); - dataSource.setServerName(dbHost); - dataSource.setPort(3306); - dataSource.setDatabaseName(dbName); - dataSource.setAutoReconnect(true); - dataSource.setConnectTimeout(5000); - c = dataSource.getConnection(); - + try { + Class.forName("com.mysql.jdbc.Driver"); + c = DriverManager.getConnection("jdbc:mysql://" + dbHost + ":3306/" + dbName, dbUser, dbPass); + } catch (ClassNotFoundException e) { + e.printStackTrace(); + } + return this; }