dbconnectionmanager.java

bbs struts

package com.ntsky.datasource;

import javax.naming.*;
import java.util.Hashtable;

import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
import java.sql.Connection;
import javax.sql.DataSource;
import javax.naming.InitialContext;
import org.apache.log4j.Logger ;
import java.sql.*;
/**
 * <p>Title: Ntsky OpenSource BBS</p>
 * <p>Description: 从Jboss线程池中获取连接</p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: WWW.FM880.COM</p>
 * @author 姚君林
 * @version 1.0
 */

public class DBConnectionManager {
    private static DBConnectionManager dbc = null;
    private static Object object = new Object();

    public DBConnectionManager(){}
   // private final static Logger logger = Logger.getLogger(DBConnectionManager.class);
    public static DBConnectionManager getInstance() {
        if (dbc == null) {
            synchronized(object){
                if(dbc == null)
                    dbc = new DBConnectionManager();
            }
        }
        return dbc;
    }

    /**
     * 获取上下文
     * @throws NamingException
     * @return Context
     */
    /*private Context getInitialContext() throws NamingException {
        Hashtable environment = new Hashtable();

        environment.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
        environment.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");
        environment.put(Context.PROVIDER_URL, "jnp://127.0.0.1:1099");
        return new InitialContext(environment);
    }*/
    /**.
     * 获取连接
     */
    public Connection getConnection() {
        DataSource ds = null;
        Connection conn = null;

        try {
            Context ctx = new InitialContext();
            //tomcat ds = (DataSource) ctx.lookup("java:comp/env/ntsky");
            //ds = (DataSource) ctx.lookup("java:comp/env/ntsky");
            ds = (DataSource) ctx.lookup("java:/ntsky");
            conn = ds.getConnection();
            //logger.info("GET sql Connection scuess : conn = " + conn);
            return conn;
        }
        catch (Exception ex) {
            System.out.println(ex.getMessage());
            //logger.error("get sql Connection failure : " + ex.getMessage());
        }
        return null;
    }

    public ResultSet rs_row(){
        Connection conn = DBConnectionManager.getInstance().getConnection();
        System.out.println("conn = " + conn);

        String sql = "select * from t_user;";
        ResultSet rs = null;
        try {
            Statement stmt = conn.createStatement();
	         rs = stmt.executeQuery(sql);
             return rs;
         }
         catch (Exception ex) {
            System.out.println("ex"+ex.getMessage());
        }

        finally{
            /*try{
                rs.close();
            }
            catch(Exception e){
                logger.error("DB rs_row 关闭指针错误 "+ e.getMessage());
            }*/
           try {
                conn.close();
            }
            catch (Exception e) {
               // logger.error("DB conn 关闭数据库连接错误 " + e.getMessage());
            }

        }
        return null;
    }


    public String testProc(){
         Connection conn = DBConnectionManager.getInstance().getConnection();
         ResultSet rs = null;
         CallableStatement cs = null;
         String a = null;
         try{
             System.out.println("start");
             //cs = conn.prepareCall("{ call procPara(?) }");
             CallableStatement cStmt = conn.prepareCall("{call demoSp(?, ?)}");

             System.out.println("start1");
             cStmt.setString(1,"1");
             cStmt.setString(2,"1");
             System.out.println("start2");
             rs = cStmt.executeQuery();
             rs.next();
             a = rs.getString(1);
         }
         catch(Exception e){
             System.out.println("hahad"+e.getMessage());
         }
         finally{
             try {
                 conn.close();
             }
             catch (Exception ex) {
                 System.out.println("ex : "+ ex.getMessage());
             }
         }

         return a;

    }
      public static void main(String[] args) {
      DBConnectionManager dbcm =DBConnectionManager.getInstance();
        ResultSet rs = dbcm.rs_row();
        try{
            System.out.println("1 : " + rs.getString(1));
        }
        catch(Exception e){
            System.out.println("main "+e.getMessage());
        }
    }
}