package lib.commons.dal;

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

import org.apache.commons.logging.Log;

import lib.commons.Utils;

public class JDBCFactory extends DbAccessFactory {
	private String driver;

	private String url;

	private String user;

	private String password;

	private Object lockObject = new Object();

	private boolean isInit;

	public JDBCFactory(String driver, String url, String user, String password) {
		super(null);
		this.driver = driver;
		this.url = url;
		this.user = user;
		this.password = password;
	}

	public JDBCFactory(Properties properties) {
		super(properties);
		if (null != properties) {
			driver = properties.getProperty("driverClassName");
			url = properties.getProperty("url");
			user = properties.getProperty("username");
			password = properties.getProperty("password");
		}
	}

	public String getDriver() {
		return driver;
	}

	public String getUrl() {
		return url;
	}

	public String getUser() {
		return user;
	}

	public String getPassword() {
		return password;
	}

	protected DbAccess createDbAccess() {
		if (!isInit) {
			synchronized (lockObject) {
				if (!isInit) {
					try {
						Class.forName(driver);
					} catch (ClassNotFoundException err) {
						Log log = Utils.getLog(JDBCFactory.class);
						log.error(err.getMessage(), err);
					}
					isInit = true;
				}
			}
		}
		DbAccess db = null;
		Connection conn = null;
		try {
			conn = DriverManager.getConnection(url, user, password);
		} catch (SQLException err) {
			Log log = Utils.getLog(JDBCFactory.class);
			log.error(err.getMessage(), err);
		}
		db = new DbAccess(conn);
		return db;
	}
}