Author: fhanik
Date: Fri Apr 16 03:37:59 2010
New Revision: 934677
URL: http://svn.apache.org/viewvc?rev=934677&view=rev
Log:
Clean up a bit
Modified:
tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/StatementCache.java
tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/StatementDecoratorInterceptor.java
Modified:
tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/StatementCache.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/StatementCache.java?rev=934677&r1=934676&r2=934677&view=diff
==============================================================================
---
tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/StatementCache.java
(original)
+++
tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/StatementCache.java
Fri Apr 16 03:37:59 2010
@@ -105,7 +105,7 @@ public class StatementCache extends Stat
/*end the cache size*/
/*begin the actual statement cache*/
-
+ @Override
public void reset(ConnectionPool parent, PooledConnection con) {
super.reset(parent, con);
if (parent==null) {
@@ -120,7 +120,8 @@ public class StatementCache extends Stat
}
}
}
-
+
+ @Override
public void disconnected(ConnectionPool parent, PooledConnection con,
boolean finalizing) {
ConcurrentHashMap<String,CachedStatement> statements =
(ConcurrentHashMap<String,CachedStatement>)con.getAttributes().get(STATEMENT_CACHE_ATTR);
@@ -136,14 +137,8 @@ public class StatementCache extends Stat
}
public void closeStatement(CachedStatement st) {
- try {
- if (st==null) return;
- if (((PreparedStatement)st).isClosed()) return;
- cacheSize.decrementAndGet();
- st.forceClose();
- }catch (SQLException sqe) {
- //log debug message
- }
+ if (st==null) return;
+ st.forceClose();
}
@Override
@@ -167,22 +162,18 @@ public class StatementCache extends Stat
public Object invoke(Object proxy, Method method, Object[] args) throws
Throwable {
- if (compare(CLOSE_VAL,method)) {
- return super.invoke(proxy, method, args);
- } else {
- boolean process = process(this.types, method, false);
- if (process && args.length>0 && args[0] instanceof String) {
- CachedStatement statement = isCached((String)args[0]);
- if (statement!=null) {
- //remove it from the cache since it is used
- removeStatement(statement);
- return statement.getActualProxy();
- } else {
- return super.invoke(proxy, method, args);
- }
+ boolean process = process(this.types, method, false);
+ if (process && args.length>0 && args[0] instanceof String) {
+ CachedStatement statement = isCached((String)args[0]);
+ if (statement!=null) {
+ //remove it from the cache since it is used
+ removeStatement(statement);
+ return statement.getActualProxy();
} else {
- return super.invoke(proxy,method,args);
+ return super.invoke(proxy, method, args);
}
+ } else {
+ return super.invoke(proxy,method,args);
}
}
@@ -231,7 +222,7 @@ public class StatementCache extends Stat
}
@Override
- public void closedInvoked() {
+ public void closeInvoked() {
//should we cache it
boolean shouldClose = true;
if (cacheSize.get() < maxCacheSize) {
@@ -254,14 +245,14 @@ public class StatementCache extends Stat
closed = true;
delegate = null;
if (shouldClose) {
- super.closedInvoked();
+ super.closeInvoked();
}
}
- public void forceClose() throws SQLException {
- super.closedInvoked();
- ((Statement)getDelegate()).close();
+ public void forceClose() {
+ removeStatement(this);
+ super.closeInvoked();
}
}
Modified:
tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/StatementDecoratorInterceptor.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/StatementDecoratorInterceptor.java?rev=934677&r1=934676&r2=934677&view=diff
==============================================================================
---
tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/StatementDecoratorInterceptor.java
(original)
+++
tomcat/trunk/modules/jdbc-pool/java/org/apache/tomcat/jdbc/pool/interceptor/StatementDecoratorInterceptor.java
Fri Apr 16 03:37:59 2010
@@ -188,7 +188,7 @@ public class StatementDecoratorIntercept
public void setConstructor(Constructor constructor) {
this.constructor = constructor;
}
- public void closedInvoked() {
+ public void closeInvoked() {
if (getDelegate()!=null) {
try {
getDelegate().close();
@@ -224,7 +224,7 @@ public class StatementDecoratorIntercept
try {
// perform close cleanup
if (close) {
- closedInvoked();
+ closeInvoked();
} else {
// execute the query
result = method.invoke(delegate, args);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
