From af0b3e198b4deab5d0f859415d001c3d18370d55 Mon Sep 17 00:00:00 2001
From: wentch <22250530@qq.com>
Date: Mon, 28 Dec 2015 16:22:08 +0800
Subject: [PATCH]

---
 src/org/redkale/source/DataConnection.java    | 4 ++--
 src/org/redkale/source/DataDefaultSource.java | 9 +++++++--
 2 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/src/org/redkale/source/DataConnection.java b/src/org/redkale/source/DataConnection.java
index 5f43bb04e..83fab205a 100644
--- a/src/org/redkale/source/DataConnection.java
+++ b/src/org/redkale/source/DataConnection.java
@@ -24,7 +24,7 @@ public abstract class DataConnection {
 
     public abstract boolean commit();
 
-    public abstract void rollback();
+    public abstract boolean rollback();
 
-    public abstract void close();
+    public abstract boolean close();
 }
diff --git a/src/org/redkale/source/DataDefaultSource.java b/src/org/redkale/source/DataDefaultSource.java
index 92374d477..7f9751325 100644
--- a/src/org/redkale/source/DataDefaultSource.java
+++ b/src/org/redkale/source/DataDefaultSource.java
@@ -84,11 +84,14 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
 
         @Override
-        public void close() {
+        public boolean close() {
             try {
+                if(sqlconn == null || sqlconn.isClosed()) return true;
                 sqlconn.close();
+                return true;
             } catch (Exception e) {
                 //do nothing
+                return false;
             }
         }
 
@@ -103,11 +106,13 @@ public final class DataDefaultSource implements DataSource, Function<Class, Enti
         }
 
         @Override
-        public void rollback() {
+        public boolean rollback() {
             try {
                 sqlconn.rollback();
+                return true;
             } catch (Exception e) {
                 //do nothing
+                return false;
             }
         }
     }