package com.comm.db;

import javax.naming.*;
import javax.sql.*;

import com.comm.util.*;
import org.apache.commons.dbcp.*;
import org.apache.commons.pool.impl.*;

public class DSFactory {
    private static Context initContext = null;

    static {
        initContext();
    }

    private static void initContext() {
        try {
            initContext = new InitialContext();
        } catch (NamingException ex) {
            LoggerUtil.error(DSFactory.class, ex);
        }

    }

    public static DataSource getDatasource(String jdbc) {
        if (initContext == null) {
            initContext();
        }
        try {
            return (DataSource) initContext.lookup(jdbc);
        } catch (NamingException ex) {
            LoggerUtil.error(DSFactory.class, ex);
            return null;
        }
    }

    public static DataSource getDataSource(String dirver, String dbUrl,
                                           String dbUser, String dbPwd) {
        try {
            Class.forName(dirver);
        } catch (ClassNotFoundException e) {
        }
        org.apache.commons.pool.ObjectPool connectionPool = new
                GenericObjectPool();
        ConnectionFactory connectionFactory = new
                                              DriverManagerConnectionFactory(
                dbUrl, dbUser, dbPwd);
        PoolableConnectionFactory poolableConnectionFactory = new
                PoolableConnectionFactory(connectionFactory, connectionPool, null, null, false, true);
        PoolingDataSource dataSource = new PoolingDataSource(connectionPool);
        return dataSource;
    }

    public static DataSource getDataSource(String dirver, String dbUrl,
                                           String dbUser, String dbPwd,
                                           int maxActive) {
        try {
            Class.forName(dirver);
        } catch (ClassNotFoundException e) {
        }
        GenericObjectPool connectionPool = new GenericObjectPool();
        connectionPool.setMaxActive(maxActive);

        ConnectionFactory connectionFactory = new
                                              DriverManagerConnectionFactory(
                dbUrl, dbUser, dbPwd);
        PoolableConnectionFactory poolableConnectionFactory = new
                PoolableConnectionFactory(connectionFactory, connectionPool, null, null, false, true);
        PoolingDataSource dataSource = new PoolingDataSource(connectionPool);
        return dataSource;
    }

}