Refactored mysql connector

This commit is contained in:
anthorob committed 2021-11-07 08:57:55 -05:00
1 parent fd32bbee91
commit a5f6851162
1 file changed
+8 -12
@@ -1,8 +1,7 @@
package netneutrality.db; package netneutrality.db;
import com.mysql.cj.jdbc.MysqlDataSource;
import java.sql.Connection; import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException; import java.sql.SQLException;
public class MysqlConnector { public class MysqlConnector {
@@ -26,16 +25,13 @@ public class MysqlConnector {
* @return {@link MysqlConnector} * @return {@link MysqlConnector}
*/ */
public MysqlConnector connect() throws SQLException { public MysqlConnector connect() throws SQLException {
MysqlDataSource dataSource = new MysqlDataSource(); try {
dataSource.setUser(dbUser); Class.forName("com.mysql.jdbc.Driver");
dataSource.setPassword(dbPass); c = DriverManager.getConnection("jdbc:mysql://" + dbHost + ":3306/" + dbName, dbUser, dbPass);
dataSource.setServerName(dbHost); } catch (ClassNotFoundException e) {
dataSource.setPort(3306); e.printStackTrace();
dataSource.setDatabaseName(dbName); }
dataSource.setAutoReconnect(true);
dataSource.setConnectTimeout(5000);
c = dataSource.getConnection();
return this; return this;
} }