diff --git a/src/main/org/apache/tools/ant/taskdefs/SQLExec.java b/src/main/org/apache/tools/ant/taskdefs/SQLExec.java
index 58956189e..2db62238a 100644
--- a/src/main/org/apache/tools/ant/taskdefs/SQLExec.java
+++ b/src/main/org/apache/tools/ant/taskdefs/SQLExec.java
@@ -131,6 +131,11 @@ public class SQLExec extends Task {
      */
     private Vector transactions = new Vector();
 
+    /**
+     * SQL Statement delimiter
+     */
+    private String delimiter = ";";
+    
     /**
      * Print SQL results.
      */
@@ -247,6 +252,13 @@ public class SQLExec extends Task {
         this.autocommit = autocommit;
     }
 
+    /**
+     * Set the statement delimiter.
+     */
+    public void setDelimiter(String delimiter) {
+        this.delimiter = delimiter;
+    }
+
     /**
      * Set the print flag.
      */
@@ -441,7 +453,7 @@ public class SQLExec extends Task {
                 // so we cannot just remove it, instead we must end it
                 if (line.indexOf("--") >= 0) sql += "\n";
 
-                if (sql.endsWith(";")){
+                if (sql.endsWith(delimiter)){
                     log("SQL: " + sql, Project.MSG_VERBOSE);
                     execSQL(sql.substring(0, sql.length()-1), out);
                     sql = "";