package server;

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Properties;
import java.util.logging.Level;
import java.util.logging.Logger;


public class Database {

	private static final Logger LOG = Logger.getLogger(Database.class.getName());
	private static Properties props = new Properties();
	private static Connection conn = null;
	private static long lastUsed = System.currentTimeMillis();

	public static void init() throws Exception {
		//LOG.log(Level.INFO, "initiating database connection...");
		try {
			FileInputStream fis = new FileInputStream("database.xml");
			props.loadFromXML(fis);
		} catch (Exception e) {
			//LOG.log(Level.SEVERE, "error loading database properties", e);
			throw new Exception("error loading database properties");
		}
		connect();
	}

	private static void connect() throws Exception {
		//LOG.log(Level.INFO, "connecting to database...");
		try {
			Class.forName("com.mysql.jdbc.Driver").newInstance();
		} catch (Exception e) {
			//LOG.log(Level.SEVERE, "error loading mysql driver", e);
			throw new Exception("error loading mysql driver");
		}
		try {
			conn = DriverManager.getConnection(
					"jdbc:mysql://" + props.getProperty("host") + ":"
							+ props.getProperty("port") + "/"
							+ props.getProperty("name"),
					props.getProperty("username"),
					props.getProperty("password"));
		} catch (Exception e) {
			//LOG.log(Level.SEVERE, "error connecting to database", e);
			throw new Exception("error connecting to database "
					+ e.getMessage());
		}
	}

	public static Connection getConnection() throws Exception {
		if (conn == null) {
			throw new Exception("connection is null");
		}
		if (System.currentTimeMillis() - lastUsed > 300) {
			try {
				lastUsed = System.currentTimeMillis();
				conn.close();
				connect();
			} catch (Exception e) {
				//LOG.log(Level.SEVERE, "error refreshing database connection", e);
				throw new Exception("error refreshing database connection");
			}
		}
		return conn;
	}

	public static void close() throws Exception {
		if (conn == null) {
			throw new Exception("connection is null");
		}
		conn.close();
	}

}