Alawn/Druid
1
0
Fork 0
mirror of https://github.com/alibaba/druid.git synced 2023-03-04 19:17:16 +00:00
Code Issues Releases Wiki Activity

log startTransactionTimeMillis

Browse Source 
git-svn-id: http://code.alibabatech.com/svn/druid/trunk@741 b9813039-fb51-4c41-a8b9-e21c2acb5095
This commit is contained in:
wenshao
2011-09-11 14:19:44 +00:00
parent 4a5b6db239
commit bc0fe7b2a4
1 changed files with 30 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/alibaba/druid/pool/PoolableConnection.java
+30 -23
View File
@@ -49,10 +49,11 @@ import com.alibaba.druid.pool.PreparedStatementPool.MethodType;
*/
public class PoolableConnection implements PooledConnection, Connection {
private final static Log LOG = LogFactory.getLog(PoolableConnection.class);
private final static Log LOG = LogFactory.getLog(PoolableConnection.class);
protected Connection conn;
protected ConnectionHolder holder;
protected long startTransactionTimeMillis = 0;
public PoolableConnection(ConnectionHolder holder){
this.conn = holder.getConnection();
@@ -69,11 +70,11 @@ public class PoolableConnection implements PooledConnection, Connection {
holder.getDataSource().handleConnectionException(this, t);
}
}
if (t instanceof SQLException) {
throw (SQLException) t;
}
throw new SQLException("Error", t);
}
@@ -100,7 +101,7 @@ public class PoolableConnection implements PooledConnection, Connection {
public Connection getConnection() {
return conn;
}
void disable() {
this.holder = null;
}
@@ -108,12 +109,12 @@ public class PoolableConnection implements PooledConnection, Connection {
@Override
public void close() throws SQLException {
ConnectionHolder holder = this.holder;
if (holder == null) {
LOG.error("dup close");
return;
}
DruidAbstractDataSource dataSource = holder.getDataSource();
if (dataSource.isRemoveAbandoned()) {
dataSource.removeActiveConnection(this);
@@ -158,15 +159,14 @@ public class PoolableConnection implements PooledConnection, Connection {
}
}
PreparedStatement stmt = null;
try {
stmt = conn.prepareStatement(sql);
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
PreparedStatement rtnVal = new PoolablePreparedStatement(this, stmt, key);
@@ -201,7 +201,7 @@ public class PoolableConnection implements PooledConnection, Connection {
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
PreparedStatement rtnVal = new PoolablePreparedStatement(this, stmt, key);
@@ -235,7 +235,7 @@ public class PoolableConnection implements PooledConnection, Connection {
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
PreparedStatement rtnVal = new PoolablePreparedStatement(this, stmt, key);
@@ -267,7 +267,7 @@ public class PoolableConnection implements PooledConnection, Connection {
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
PreparedStatement rtnVal = new PoolablePreparedStatement(this, stmt, key);
@@ -293,13 +293,13 @@ public class PoolableConnection implements PooledConnection, Connection {
}
}
PreparedStatement stmt = null;
PreparedStatement stmt = null;
try {
stmt = conn.prepareStatement(sql, columnNames);
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
PreparedStatement rtnVal = new PoolablePreparedStatement(this, stmt, key);
@@ -331,7 +331,7 @@ public class PoolableConnection implements PooledConnection, Connection {
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
PreparedStatement rtnVal = new PoolablePreparedStatement(this, stmt, key);
@@ -366,7 +366,7 @@ public class PoolableConnection implements PooledConnection, Connection {
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
CallableStatement rtnVal = new PoolableCallableStatement(this, stmt, key);
@@ -399,7 +399,7 @@ public class PoolableConnection implements PooledConnection, Connection {
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
CallableStatement rtnVal = new PoolableCallableStatement(this, stmt, key);
@@ -432,7 +432,7 @@ public class PoolableConnection implements PooledConnection, Connection {
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
CallableStatement rtnVal = new PoolableCallableStatement(this, stmt, key);
@@ -453,7 +453,7 @@ public class PoolableConnection implements PooledConnection, Connection {
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
PoolableStatement poolableStatement = new PoolableStatement(this, stmt);
@@ -473,7 +473,7 @@ public class PoolableConnection implements PooledConnection, Connection {
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
PoolableStatement poolableStatement = new PoolableStatement(this, stmt);
@@ -492,7 +492,7 @@ public class PoolableConnection implements PooledConnection, Connection {
} catch (SQLException ex) {
handleException(ex);
}
holder.getDataSource().initStatement(stmt);
PoolableStatement poolableStatement = new PoolableStatement(this, stmt);
@@ -530,8 +530,9 @@ public class PoolableConnection implements PooledConnection, Connection {
try {
if ((!autoCommit) && conn.getAutoCommit()) {
holder.getDataSource().incrementStartTransactionCount();
startTransactionTimeMillis = System.currentTimeMillis();
}
conn.setAutoCommit(autoCommit);
} catch (SQLException ex) {
handleException(ex);
@@ -554,9 +555,15 @@ public class PoolableConnection implements PooledConnection, Connection {
conn.commit();
} catch (SQLException ex) {
handleException(ex);
} finally {
startTransactionTimeMillis = 0;
}
}
public long getStartTransactionTimeMillis() {
return startTransactionTimeMillis;
}
@Override
public void rollback() throws SQLException {
checkOpen();
@@ -566,7 +573,7 @@ public class PoolableConnection implements PooledConnection, Connection {
conn.rollback();
} catch (SQLException ex) {
handleException(ex);
}
}
}
@Override