Upstream/bentobox
1
0
Fork 0
mirror of https://github.com/BentoBoxWorld/BentoBox.git synced 2025-01-17 21:51:41 +01:00
Code Issues Projects Releases Wiki Activity

Made MySQL work. Tested. Still needs to implement collections.

Browse Source
This commit is contained in:
tastybento 2017-05-26 08:15:53 -07:00
parent 19865969d2
commit c6d41ba1ee
4 changed files with 21 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/us/tastybento/bskyblock/BSkyBlock.java
View File

@ -46,7 +46,7 @@ public class BSkyBlock extends JavaPlugin{
Settings.dbHost = "localhost";
Settings.dbPort = 3306;
Settings.dbName = "ASkyBlock";
Settings.dbUsername = "user";
Settings.dbUsername = "username";
Settings.dbPassword = "password";
playersManager = new PlayersManager(this);

2
src/main/java/us/tastybento/bskyblock/database/AbstractDatabaseHandler.java
View File

@ -91,7 +91,7 @@ public abstract class AbstractDatabaseHandler<T> {
if (usePlaceHolders)
sb.append("?");
else
sb.append(f.getName());
sb.append("`" + f.getName() + "`");
}
return sb.toString();

23
src/main/java/us/tastybento/bskyblock/database/mysql/MySQLDatabaseHandler.java
View File

@ -17,6 +17,7 @@ import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.UUID;
@ -64,13 +65,22 @@ public class MySQLDatabaseHandler<T> extends AbstractDatabaseHandler<T> {
mySQLmapping.put(Location.class.getTypeName(), "VARCHAR(254)");
mySQLmapping.put(World.class.getTypeName(), "VARCHAR(254)");
// Sets - this stores just the name of the set which is another table
// TODO: Collections - these need to create another table and link to it
mySQLmapping.put(Set.class.getTypeName(), "VARCHAR(254)");
mySQLmapping.put(Map.class.getTypeName(), "VARCHAR(254)");
mySQLmapping.put(HashMap.class.getTypeName(), "VARCHAR(254)");
mySQLmapping.put(ArrayList.class.getTypeName(), "VARCHAR(254)");
}
public MySQLDatabaseHandler(BSkyBlock plugin, Class<T> type, DatabaseConnecter databaseConnecter) {
super(plugin, type, databaseConnecter);
try {
connection = databaseConnecter.createConnection();
} catch (SQLException e1) {
plugin.getLogger().severe(e1.getMessage());
return;
}
// Check if the table exists in the database and if not, create it
try {
createSchema();
@ -90,22 +100,23 @@ public class MySQLDatabaseHandler<T> extends AbstractDatabaseHandler<T> {
*/
private void createSchema() throws IntrospectionException, SQLException {
PreparedStatement pstmt = null;
connection = databaseConnecter.createConnection();
try {
String sql = "CREATE TABLE IF NOT EXISTS " + type.getSimpleName() + "(";
for (Field field : type.getDeclaredFields()) {
PropertyDescriptor propertyDescriptor = new PropertyDescriptor(field.getName(), type);
plugin.getLogger().info("DEBUG: Field = " + field.getName());
plugin.getLogger().info("DEBUG: Field = " + field.getName() + "(" + propertyDescriptor.getPropertyType().getTypeName() + ")");
String mapping = mySQLmapping.get(propertyDescriptor.getPropertyType().getTypeName());
if (mapping != null) {
sql += field.getName() + " " + mapping + ",";
sql += "`" + field.getName() + "` " + mapping + ",";
// TODO: Create set and map tables.
} else {
sql += field.getName() + " VARCHAR(254),";
plugin.getLogger().severe("Unknown type! Hoping it'll fit in a string!");
}
}
sql = sql.substring((sql.length()-1), sql.length()) + ")";
plugin.getLogger().info("DEBUG: SQL string = " + sql);
//plugin.getLogger().info("DEBUG: SQL before trim string = " + sql);
sql = sql.substring(0,(sql.length()-1)) + ")";
//plugin.getLogger().info("DEBUG: SQL string = " + sql);
pstmt = connection.prepareStatement(sql.toString());
pstmt.executeUpdate();
} catch (Exception e) {

3
src/main/java/us/tastybento/bskyblock/database/mysql/MySqlDatabaseConnecter.java
View File

@ -27,7 +27,8 @@ public class MySqlDatabaseConnecter implements DatabaseConnecter {
// TODO Auto-generated catch block
e.printStackTrace();
}
connectionUrl = "jdbc:mysql://" + dbSettings.getHost() + "/" + dbSettings.getDatabaseName();
// jdbc:mysql://localhost:3306/Peoples?autoReconnect=true&useSSL=false
connectionUrl = "jdbc:mysql://" + dbSettings.getHost() + "/" + dbSettings.getDatabaseName() + "?autoReconnect=true&useSSL=false";
}
@Override