startTransactionCount

git-svn-id: http://code.alibabatech.com/svn/druid/trunk@738 b9813039-fb51-4c41-a8b9-e21c2acb5095

src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java

@@ -172,24 +172,33 @@ public abstract class DruidAbstractDataSource implements DruidAbstractDataSource
     protected boolean                                                                        breakAfterAcquireFailure                  = false;
 
     protected final AtomicLong                                                               commitCount                               = new AtomicLong();
+    protected final AtomicLong                                                               startTransactionCount                     = new AtomicLong();
     protected final AtomicLong                                                               rollbackCount                             = new AtomicLong();
 
     public long getCommitCount() {
         return commitCount.get();
     }
-    
+
     public void incrementCommitCount() {
         commitCount.incrementAndGet();
     }
-    
+
     public long getRollbackCount() {
         return rollbackCount.get();
     }
-    
+
     public void incrementRollbackCount() {
         rollbackCount.incrementAndGet();
     }
     
+    public long getStartTransactionCount() {
+        return startTransactionCount.get();
+    }
+    
+    public void incrementStartTransactionCount() {
+        startTransactionCount.incrementAndGet();
+    }
+
     public boolean isBreakAfterAcquireFailure() {
         return breakAfterAcquireFailure;
     }

src/main/java/com/alibaba/druid/pool/DruidAbstractDataSourceMBean.java

@@ -39,6 +39,8 @@ public interface DruidAbstractDataSourceMBean {
     long getCommitCount();
     
     long getRollbackCount();
+    
+    long getStartTransactionCount();
 
     int getQueryTimeout();
 

src/main/java/com/alibaba/druid/pool/DruidDataSource.java

@@ -127,6 +127,10 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
         } finally {
             lock.unlock();
         }
+        
+        commitCount.set(0);
+        rollbackCount.set(0);
+        startTransactionCount.set(0);
     }
 
     public boolean isEnable() {

src/main/java/com/alibaba/druid/pool/PoolableConnection.java

@@ -528,6 +528,10 @@ public class PoolableConnection implements PooledConnection, Connection {
         checkOpen();
 
         try {
+            if ((!autoCommit) && conn.getAutoCommit()) {
+                holder.getDataSource().incrementStartTransactionCount();
+            }
+            
             conn.setAutoCommit(autoCommit);
         } catch (SQLException ex) {
             handleException(ex);