diff --git a/src/main/org/apache/tools/ant/taskdefs/SQLExec.java b/src/main/org/apache/tools/ant/taskdefs/SQLExec.java
index 8c05ea99e..fef51c666 100644
--- a/src/main/org/apache/tools/ant/taskdefs/SQLExec.java
+++ b/src/main/org/apache/tools/ant/taskdefs/SQLExec.java
@@ -219,14 +219,14 @@ public class SQLExec extends Task {
             }
             
         } catch(IOException e){
-            if (!autocommit) {
+            if (!autocommit && conn != null) {
                 try {
                     conn.rollback();
                 } catch (SQLException ex) {}
             }
             throw new BuildException(e, location);
         } catch(SQLException e){
-            if (!autocommit) {
+            if (!autocommit && conn != null) {
                 try {
                     conn.rollback();
                 } catch (SQLException ex) {}