Start some initial work on the sql portion, no where near close. #18

This commit is contained in:
graywolf336 2014-02-19 21:54:56 -06:00
parent e54dbc8a8c
commit 356fab682e
2 changed files with 45 additions and 6 deletions

View File

@ -2,6 +2,9 @@ package com.graywolf336.jail;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Set; import java.util.Set;
import org.bukkit.Location; import org.bukkit.Location;
@ -25,6 +28,7 @@ import com.graywolf336.jail.enums.LangString;
public class JailIO { public class JailIO {
private JailMain pl; private JailMain pl;
private FileConfiguration flat, lang; private FileConfiguration flat, lang;
private Connection con;
private int storage; //0 = flatfile, 1 = sqlite, 2 = mysql private int storage; //0 = flatfile, 1 = sqlite, 2 = mysql
public JailIO(JailMain plugin) { public JailIO(JailMain plugin) {
@ -103,21 +107,54 @@ public class JailIO {
return Util.getColorfulMessage(message); return Util.getColorfulMessage(message);
} }
/** /** Prepares the storage engine to be used, returns true if everything went good. */
* Prepares the storage engine to be used. public boolean prepareStorage() {
*/
public void prepareStorage() {
switch(storage) { switch(storage) {
case 1: case 1:
//prepare sqlite, I need to research this //prepare sqlite, I need to research this
break; return false;
case 2: case 2:
//prepare mysql, research this as well try {
Class.forName("com.mysql.jdbc.Driver");
Connection connection = DriverManager.getConnection("jdbc:mysql://" + pl.getConfig().getString("storage.mysql.host") + ":"
+ pl.getConfig().getString("storage.mysql.port") + "/"
+ pl.getConfig().getString("storage.mysql.database"), pl.getConfig().getString("storage.mysql.username"), pl.getConfig().getString("storage.mysql.password"));
connection.setAutoCommit(false);
this.con = connection;
}catch(ClassNotFoundException e) {
e.printStackTrace();
pl.getLogger().severe("---------- Jail Error!! ----------");
pl.getLogger().severe("MySQL driver not found, disabling the plugin.");
return false;
} catch (SQLException e) {
e.printStackTrace();
pl.getLogger().severe("---------- Jail Error!! ----------");
pl.getLogger().severe("Unable to connect to the MySQL database, please update your config accordingly.");
return false;
}
break; break;
default: default:
flat = YamlConfiguration.loadConfiguration(new File(pl.getDataFolder(), "data.yml")); flat = YamlConfiguration.loadConfiguration(new File(pl.getDataFolder(), "data.yml"));
break; break;
} }
return true;
}
/**
* Gets the connection for the sqlite and mysql, null if flatfile.
*
* @return The connection for the sql database.
*/
public Connection getConnection() {
switch(storage) {
case 1:
case 2:
if(con == null) this.prepareStorage();
return con;
default:
return null;
}
} }
/** /**

View File

@ -11,6 +11,8 @@ storage:
port: 3306 port: 3306
username: 'root' username: 'root'
password: 'password' password: 'password'
prefix: 'j3_'
database: 'jailDatabase'
jails: jails:
endermenProtection: true endermenProtection: true
explosionProtection: true explosionProtection: true