package com.sqq.database;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

import com.sqq.Configuration;
import com.sqq.rs2.ExecutorServer;

public class DatabaseManager {

	private Connection connection;
	private DatabaseManager instance = new DatabaseManager();

	public void connect() {
		try {
			long start = System.currentTimeMillis();
			Class.forName("com.mysql.jdbc.Driver");
			connection = DriverManager.getConnection(
					"jdbc:mysql://" + Configuration.SQL_HOST + "/" + Configuration.SQL_DATABASE,
					Configuration.SQL_USER, Configuration.SQL_PASS);
			System.err.println("Successfully connected in " + (System.currentTimeMillis() - start) + "ms!");
		} catch (SQLException e) {
			e.printStackTrace();
		} catch(ClassNotFoundException e) {
			e.printStackTrace();
		}
	}

	public Connection getConnection() {
		return connection;
	}

	public DatabaseManager getDatabase() {
		return instance;
	}

	public void executeStatement(final ExecutionStatement request) {
		ExecutorServer.getLogicExecutor().execute(new Runnable() {
			public void run() {
				synchronized(request) {
					request.handle(connection);
				}
			}
		});
	}

}