package com.xindeco.common.dbconn ;

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

public class DbConn
{

   public ResultSet rs = null ;
   public Statement stmt = null ;
   private CustomizedResultSet crs = null ;
   public Connection conn = null ;
   static private Hashtable pools = new Hashtable(); //存放DB连接
   static private ArrayList vector = new ArrayList(); //存放标志
   static private int x = 0; //存放标志

   private long lt ;
   private long lt1 ;

   public DbConn ()
   {
        this.getConnByWeblogicPool () ;
   }

   //根据txdatasource的JNDI取得conn
   private void getConnByWeblogicPool ()
   {
       String url = "" ;
       String user = "" ;
       String password = "" ;
        DataSource ds = null ;
        Context ctx = null ;

        try
        {
   //如果正在使用的连接超过29个，将全部关闭
      if(x > 29){
            for(int i = 0; i<vector.size();){
     Object o = pools.get(vector.get(i));
     Connection c = (Connection)o;
     if(c!=null && !c.isClosed()){
        x--;
        //System.out.println ("关闭无效连接后还剩下x="+x);
        pools.remove(vector.get(i));
        vector.remove(i);
        c.close () ;
      }
     }
       }

       ctx = this.getInitialContext () ;
       ds = (javax.sql.DataSource) ctx.lookup ("graduate") ;
       synchronized(this){
     conn = ds.getConnection () ;
     if (conn != null)
     {
        ++x;
        //System.out.println ("建立连接个数xxxx=" + (++x)) ;
       lt = System.currentTimeMillis();
       vector.add(String.valueOf(lt));
        pools.put(String.valueOf(lt),conn);
        stmt = conn.createStatement
       (
       ResultSet.TYPE_SCROLL_SENSITIVE,
       ResultSet.CONCUR_READ_ONLY
        ) ;
      }
         }
      }
      catch (Exception e)
      {
                 throw e;
      }

  }

  static final private Context getInitialContext ()
    throws Exception
  {

    Properties properties = null ;

    try
    {
      properties = new Properties () ;
      properties.put (Context.INITIAL_CONTEXT_FACTORY,
        "weblogic.jndi.WLInitialContextFactory") ;
      return new InitialContext (properties) ;
    }
    catch (Exception ex)
    {
      //ex.printStackTrace () ;
      throw ex ;
    }
  }

  synchronized public void close ()
  {
    try
    {
      if (stmt != null && !conn.isClosed ())
      {
        stmt.close () ;
        stmt = null ;
      }
      if (stmt1 != null && !conn.isClosed ())
      {
        stmt1.close () ;
        stmt1 = null ;
      }
      if (rs != null && !conn.isClosed ()) 
                    {
        rs.close () ;
        rs = null ;
      }
      if (conn != null && !conn.isClosed ())
      {
        pools.remove (String.valueOf (lt)) ;
        vector.remove (String.valueOf (lt)) ;
        conn.close () ;
        conn = null ;
        --x;
       //System.out.println ("关闭后还剩连接个数111xxxx=" + (--x)) ;
      }
    }
    catch (Exception ex)
    {
      //ex.printStackTrace () ;
    }
  }

}