SBDevelopment/ThemePark
Archived
3
0
Fork 0
Code Activity

Bug Fix

Browse source
This commit is contained in:
BuildTools 2019-03-01 14:13:14 +01:00
parent 8856ebe077
commit ce792b2226
1 changed files with 1 additions and 66 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

67
src/main/java/me/paradoxpixel/themepark/database/Database.java
View file

@ -43,7 +43,7 @@ public class Database {
public void connect() { public void connect() {
try { try {
Class.forName("com.mysql.jdbc.Driver").newInstance(); Class.forName("com.mysql.jdbc.Driver").newInstance();
connection = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database, user, password); connection = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database + "?useSSL=false", user, password);
startPool(); startPool();
} catch(Exception e) { } catch(Exception e) {
@ -128,69 +128,4 @@ public class Database {
return false; return false;
} }
public int executeUpdate(String query, HashMap<Integer, Object> objects) {
if(query == null || query.isEmpty())
return 0;
if(!enabled)
return 0;
if(!connected())
connect();
if(!connected())
return 0;
stopPool();
try {
PreparedStatement statement = connection.prepareStatement(query);
for(Map.Entry<Integer, Object> entry : objects.entrySet())
statement.setObject(entry.getKey(), entry.getValue());
int i = statement.executeUpdate();
statement.close();
startPool();
return i;
} catch(Exception e) {
e.printStackTrace();
}
startPool();
return 0;
}
public ResultSet executeQuery(String query, HashMap<Integer, Object> objects) {
if(query == null || query.isEmpty())
return null;
if(!enabled)
return null;
if(!connected())
connect();
if(!connected())
return null;
stopPool();
try {
PreparedStatement statement = connection.prepareStatement(query);
for(Map.Entry<Integer, Object> entry : objects.entrySet())
statement.setObject(entry.getKey(), entry.getValue());
ResultSet result = statement.executeQuery();
statement.close();
startPool();
return result;
} catch(Exception e) {
e.printStackTrace();
}
startPool();
return null;
}
} }