import java.sql.*;
import java.util.*;
import javax.naming.*;
import javax.sql.DataSource;

public class SqlAccess {

    //数据库连接
    public Connection conn = null;
    //结果集
    private ResultSet rs = null;
    //数据库访问段
    public Statement stmt = null;
    //是否连接数据库
    private boolean isConnDB = false;
    private boolean isDefault = true;
    private String newDSName = null;
    public static HashMap logmap = new HashMap();
    public static int begincont = 0;
    private int count = 0;
    public String serverType="";
    public String jndiName = "";

    public static final String WLS_INITIAL_CONTEXT_FACTORY =  "weblogic.jndi.WLInitialContextFactory";
    public static final String TBJBOSS_INITIAL_CONTEXT_FACTORY = "org.jboss.naming.JNDIView";
    public static final String WEBSPHERE_INITIAL_CONTEXT_FACTORY = "com.ibm.websphere.naming.WsnInitialContextFactory";

    public SqlAccess() {
        try {
            initial();
            conn.setAutoCommit(true);
        }
        catch (Exception exp) {
        }
    }
    public SqlAccess(String jndi,String serverType) {
        this.serverType = serverType;
        this.jndiName = jndi;
        try {
            initial();
            conn.setAutoCommit(true);
        }
        catch (Exception exp) {
        }
    }

    public static SqlAccess createConn(String ds) throws Exception {
        SqlAccess sq = new SqlAccess(ds,"websphere");
        if (sq == null || sq.conn == null)
            throw new Exception("Errorx");
        return sq;
    }

    public static SqlAccess createConn() throws Exception {
        return createConn("");
    }

    public static void main(String[] args) {

    }

    public static final String ST_WEBSPHERE = "websphere";
    public static final String ST_WEBLOGIC = "weblogic";
    public static final String ST_TOMCAT = "tomcat";
    public static final String ST_JBOSS = "jboss";
    public static final String ST_RESIN = "resin";

    public void initial() throws SQLException {
        try {
            Context ctx = null;
            DataSource ds = null;
            String dsName = this.jndiName;
            try {
                count = ++begincont;
            }
            catch (Exception e) {
                begincont = 0;
                count = ++begincont;
            }

            System.out.println("[count]"+count);

            if (ST_WEBLOGIC.equals(serverType)) {
                Properties props = new Properties();
                //取数据库连接
                props.put("weblogic.codeset", "GBK");
                Hashtable parms = new Hashtable();
                parms.put(    Context.INITIAL_CONTEXT_FACTORY,    this.WLS_INITIAL_CONTEXT_FACTORY);
                ctx = new InitialContext(parms);
            }
            else if (ST_JBOSS.equals(serverType)) {
                System.out.println("Jboss connection init");
                ctx = new InitialContext();
                dsName = "java:/" + dsName;
            }
            else if (ST_RESIN.equals(serverType)) {
                System.out.println("Resin Connection init");
                ctx = new InitialContext();
                dsName = "java:comp/env/" + dsName;
            }
            else if (ST_WEBSPHERE.equals(serverType)) {
                System.out.println("Websphere Connection init");
                Hashtable prop = new Hashtable();
                prop.put(Context.INITIAL_CONTEXT_FACTORY,this.WEBSPHERE_INITIAL_CONTEXT_FACTORY);
                ctx = new InitialContext(prop);
            }
            else if (ST_TOMCAT.equals(serverType)) {
                System.out.println("Tomcat JNDI Connection init");
                ctx = new InitialContext();
                dsName = "java:comp/env/" + dsName;
            }

            System.out.println("[SqlAccess]dsName:" + dsName + "...");

            ds = (DataSource) ctx.lookup(dsName);
            conn = ds.getConnection();

            //--System.out
            System.out.println("conn:" + conn.toString());
            logmap.put(conn,count+"");
            //--System.out
            System.out.println("ConnectionPool:making a connection...[" + count + "]");
            //--System.out
            //--System.out
            //stmt = conn.createStatement();
            isConnDB = true;

        }
        catch (SQLException sqle) {
            sqle.printStackTrace();
            System.out.println("SQLException during connection(): " + sqle.getMessage());
            throw sqle;
        }
        catch (Exception e) {
            e.printStackTrace();
            System.out.println(e.getMessage());
        }
    }

    //设置AutoCommit
    public void setAutoCommit(boolean autoCommit) throws SQLException {
        try {
            if (isConnDB)
                conn.setAutoCommit(autoCommit);
        }
        catch (SQLException sqle) {
            System.out.println("SQLException during autoCommit(): " + sqle.getMessage());
            throw sqle;
        }
        catch (Exception e) {
            System.out.println(e.getMessage());

        }
    }

    //执行Commit命令
    public void commit() throws SQLException {
        try {
            if (isConnDB)
                conn.commit();
        }
        catch (SQLException sqle) {
            System.out.println("SQLException during commit(): " + sqle.getMessage());
            throw sqle;
        }
        catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }

    //执行Rollback命令
    public void rollback() {
        try {
            if (isConnDB)
                conn.rollback();
        }
        catch (SQLException sqle) {
            System.out.println("SQLException during rollback(): " + sqle.getMessage());
            //throw sqle;
        }
        catch (Exception e) {
            System.out.println(e.getMessage());

        }
    }

    //查询与数据库之间的连接是否关闭,true - 有连接:false - 没连接
    public boolean isConnectDB() {
        return isConnDB;
    }

    //关闭连接
    public void close() {

        try {

            if (conn != null)
                conn.close();
            logmap.remove(conn);
            logmap.remove("" + count);
            System.out.println("ConnectionPool::Closing connection...[" + count + "]\n");
        }
        catch (SQLException sqle) {
            System.out.println("SQLException during close(): " + sqle.getMessage());
            //throw sqle;
        }
        catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }

    //public static String SERVER="JBOSS";
    //public static String SERVER="WEBLOGIC";
    /**
     * Returns the logmap.
     * @return HashMap
     */
    public static HashMap getLogmap() {
        return logmap;
    }

    /**
     * Returns the count.
     * @return int
     */
    public int getCount() {
        return count;
    }

}

    SqlAccess sa = new SqlAccess("HIS", "websphere");
    if (sa != null) {
        System.out.println("成功连接=" + sa.conn);
    } else {
        System.out.println("失败连接=" + sa.conn);
    }
    Connection hisConn = sa.conn;