Paste #20043

package com.dengyu.mysql;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import org.bukkit.command.CommandSender;

public class MySQLManager {
	private String ip;
	private String databaseName;
	private String userName;
	private String userPassword;
	private Connection connection;
	private int port;
	public static MySQLManager instance = null;
	
	public static MySQLManager get() {
        return instance == null ? instance = new MySQLManager() : instance;
    }
	
	public void enableMySQL()
	{
		ip = Main.getConfigString("mysql.ip");
		databaseName = Main.getConfigString("mysql.databasename");
		userName = Main.getConfigString("mysql.username");
		userPassword = Main.getConfigString("mysql.password");
		port = Main.getConfigInt("mysql.port");
		connectMySQL();
		String cmd = SQLCommand.CREATE_TABLE1.commandToString();
		try {
			PreparedStatement ps = connection.prepareStatement(cmd);
			doCommand(ps);
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	
	private void connectMySQL()
	{
		try {
			connection = DriverManager.getConnection("jdbc:mysql://" + ip + ":" + port + "/" + databaseName + "?autoReconnect=true", userName, userPassword);
		} catch (SQLException e) {
			// TODO 自动生成的 catch 块
			e.printStackTrace();
		}
	}
	public void doCommand(PreparedStatement ps)
	{
		try {
			ps.executeUpdate();
		} catch (SQLException e) {
			System.out.println("执行指令失败，以下为错误提示");
			e.printStackTrace();
		}
	}
}