package console.mysql;

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

import console.AbstractOperation;

/**
 * @author Allan(劉新福)
 * @version 1.0
 */
public class MySQLOperation extends AbstractOperation {
	private Connection con;

	public MySQLOperation(String serverIP, String serverPort,
			String databaseName, String userName, String password) {
		super(serverIP, serverPort, databaseName, userName, password);
	}

	public MySQLOperation(String serverIP, String serverPort,
			String databaseName, String userName, String password,
			int transactionIsolation) {
		super(serverIP, serverPort, databaseName, userName, password,
				transactionIsolation);
	}

	@Override
	public Connection getConnection() throws Exception {
		if (con == null) {
			try {
				Class.forName("com.mysql.jdbc.Driver");
				String jdbcURL = "jdbc:mysql://" + serverIP + ":" + serverPort
						+ "/" + databaseName;
				con = DriverManager.getConnection(jdbcURL, userName, password);
			} catch (ClassNotFoundException e) {
				System.out
						.println("Can not load mysql jdbc driver, please verify your CLASSPATH!");
				throw e;
			} catch (SQLException e) {
				System.out
						.println("Fail to get database connection, please verify your database information!");
				throw e;
			}
		}

		return con;
	}
}