Mathias/sqltoolkit
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

Removed the table prefix from the mysql connection

Browse Source
This commit is contained in:
mathias 2021-08-19 19:40:52 +02:00
parent e58d96b58a
commit 5efc36d1b0
No known key found for this signature in database
GPG Key ID: 8950DF62139C852A
1 changed files with 3 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src/main/java/de/gnmyt/SQLToolkit/drivers/MySQLConnection.java
View File

@ -18,15 +18,15 @@ import java.sql.ResultSet;
public class MySQLConnection { public class MySQLConnection {
public static final Logger LOG = LoggerFactory.getLogger("MySQL-Logger"); public static final Logger LOG = LoggerFactory.getLogger("MySQL-Logger");
private final TableFactory tableFactory = new TableFactory(this);
private final String hostname; private final String hostname;
private final String username; private final String username;
private final String password; private final String password;
private final String database; private final String database;
private final TableFactory tableFactory = new TableFactory(this);
private String tablePrefix = "";
private String tablePrefixVariable = "";
private String connectString = ""; private String connectString = "";
private Connection con; private Connection con;
/** /**
@ -69,7 +69,6 @@ public class MySQLConnection {
* @return ResultSet * @return ResultSet
*/ */
public ResultSet getResultSet(String query, Object... params) { public ResultSet getResultSet(String query, Object... params) {
query = (tablePrefix.isEmpty()) ? query : query.replace((tablePrefixVariable.isEmpty()) ? "$tp" : tablePrefixVariable, tablePrefix);
try { try {
int start = 1; int start = 1;
PreparedStatement ps = con.prepareStatement(query); PreparedStatement ps = con.prepareStatement(query);
@ -119,7 +118,6 @@ public class MySQLConnection {
* @return this class * @return this class
*/ */
public MySQLConnection update(String query, Object... params) { public MySQLConnection update(String query, Object... params) {
query = (tablePrefix.isEmpty()) ? query : query.replace((tablePrefixVariable.isEmpty()) ? "$tp" : tablePrefixVariable, tablePrefix);
try { try {
int start = 1; int start = 1;
PreparedStatement ps = con.prepareStatement(query); PreparedStatement ps = con.prepareStatement(query);
@ -254,37 +252,6 @@ public class MySQLConnection {
return this; return this;
} }
/**
* Set the Connection String
*
* @param tablePrefixVariable New table prefix variable
* @return this class
*/
public MySQLConnection setTablePrefixVariable(String tablePrefixVariable) {
this.tablePrefixVariable = tablePrefixVariable;
return this;
}
/**
* Get the current table Prefix
*
* @return the prefix
*/
public String getTablePrefix() {
return tablePrefix;
}
/**
* Set the current table Prefix
*
* @param tablePrefix New table prefix
* @return this class
*/
public MySQLConnection setTablePrefix(String tablePrefix) {
this.tablePrefix = tablePrefix;
return this;
}
/** /**
* Get the current jdbc connection string for mysql * Get the current jdbc connection string for mysql
* *