src/jdbc/JdbcSqlPooledConnection.java

   1 package csql.jdbc;
   2
   3 import java.util.*;
   4 import java.sql.*;
   5 import javax.sql.*;
   6 import javax.naming.*;
   7 import java.io.*;
   8 import java.lang.*;
   9 import java.lang.Class;
  10
  11 public class JdbcSqlPooledConnection implements javax.sql.PooledConnection
  12 {
  13
  14    //To store the connection Event Listions Hash manner for faster access
  15     private Map connectionEventListeners;
  16
  17
  18    // logical connection for connenction pool
  19     private Connection logicalConn;
  20
  21
  22    // Actual or physical connection
  23     private JdbcSqlConnection physicalConn;
  24
  25
  26   //says logical connection open or close
  27    boolean isclose = true;
  28
  29    //Constructor
  30     public JdbcSqlPooledConnection(Connection connection) {
  31                 logicalConn = null;
  32                 physicalConn =(JdbcSqlConnection) connection;
  33                 connectionEventListeners = new HashMap();
  34         }
  35
  36
  37
  38
  39    //Pooled connection methods. Here connection event listener is insert into hashed map.
  40     public synchronized void addConnectionEventListener(ConnectionEventListener conEventListener)
  41     {
  42         if(connectionEventListeners != null)
  43             connectionEventListeners.put(conEventListener,conEventListener);
  44     }
  45
  46
  47
  48    //Pooled connection method. Here the connection event listioner is removed from hash map
  49    public synchronized void removeConnectionEventListener(ConnectionEventListener conEventListener)
  50    {
  51        if(connectionEventListeners != null)
  52             connectionEventListeners.remove(conEventListener);
  53    }
  54
  55
  56
  57
  58    //Pooled connection method.
  59    public synchronized Connection getConnection() throws SQLException
  60    {
  61            if (physicalConn == null) {
  62                System.out.println("Connection not Exit");
  63                isclose = true;
  64            }
  65
  66           /* if(isclose != true ||  logicalConn != null){
  67                isclose  = true;
  68                logicalConn.rollback();
  69                eventListentionMethod(true,null);
  70            }*/
  71        logicalConn = JdbcSqlConnectionWrapper.getInstance(this,physicalConn);
  72        isclose = false;
  73        return logicalConn;
  74    }
  75
  76   //Pooled connection method.
  77    public synchronized void close() throws SQLException {
  78                 if (physicalConn != null) {
  79                         physicalConn.close();
  80                         physicalConn = null;
  81                 }
  82                 if (connectionEventListeners != null) {
  83                         connectionEventListeners.clear();
  84                         connectionEventListeners = null;
  85                 }
  86    }
  87
  88
  89    public synchronized void eventListentionMethod(boolean isclose,SQLException sqlException) {
  90        if(connectionEventListeners == null){ return; }
  91        Iterator iterater = connectionEventListeners.entrySet().iterator();
  92
  93        ConnectionEvent conEvent = new ConnectionEvent(this,sqlException);
  94        while (iterater.hasNext()) {
  95            ConnectionEventListener conEventListener = (ConnectionEventListener) ((Map.Entry)iterater.next()).getValue();
  96            if (isclose) {
  97                conEventListener.connectionClosed(conEvent);
  98            } else {
  99                conEventListener.connectionErrorOccurred(conEvent);
 100            }
 101        }
 102
 103    }
 104
 105    public void addStatementEventListener(StatementEventListener listener) {
 106    //part of JDBC4
 107    }
 108
 109
 110    public void removeStatementEventListener(StatementEventListener listener) {
 111    //part of JDBC4
 112    }
 113
 114
 115 }