diff --git a/core/src/conf/scriptella/dtd/etl.dtd b/core/src/conf/scriptella/dtd/etl.dtd
index 1126c3ce..d732fe17 100644
--- a/core/src/conf/scriptella/dtd/etl.dtd
+++ b/core/src/conf/scriptella/dtd/etl.dtd
@@ -215,11 +215,13 @@ Queries a table and writes the result into CSV file
  @attr if expression to test. If result of evaluation is true - the element is evaluated, otherwise skipped.
         Use <a href="http://jakarta.apache.org/commons/jexl">JEXL</a> syntax for expressions.
  @attr id script identifier(name).
+ @attr commit if set to true, it will commit all connections on query exit
 -->
 <!ATTLIST query
 connection-id IDREF #IMPLIED
 if CDATA #IMPLIED
 id ID #IMPLIED
+commit (true | false) "false"
 >
 
 <!--
diff --git a/core/src/java/scriptella/configuration/ScriptingElement.java b/core/src/java/scriptella/configuration/ScriptingElement.java
index 80f2d2a9..e4172166 100644
--- a/core/src/java/scriptella/configuration/ScriptingElement.java
+++ b/core/src/java/scriptella/configuration/ScriptingElement.java
@@ -28,6 +28,7 @@
 public abstract class ScriptingElement extends XmlConfigurableBase {
     private String connectionId;
     private String ifExpr;
+    private String commit;
     private DialectBasedContentEl contentEl;
     private ScriptingElement parent;
 
@@ -55,7 +56,15 @@ public String getIf() {
     public void setIf(final String ifExpr) {
         this.ifExpr = ifExpr;
     }
-
+    
+    public String getCommit(){
+    		return commit;
+    }
+    
+    public void setCommit(final String commit){
+    		this.commit = commit;
+    }
+    
     public Resource getContent() {
         return contentEl.getContent(null);
     }
@@ -73,6 +82,7 @@ public void configure(final XmlElement element) {
         setLocation(element);
         setProperty(element, "connection-id", "connectionId");
         setProperty(element, "if");
+        setProperty(element, "commit");
         contentEl = new DialectBasedContentEl(element);
         contentEl.setLocation(getLocation());
     }
@@ -81,7 +91,7 @@ public void configure(final XmlElement element) {
     public String toString() {
         return "connectionId='" + connectionId + '\'' +
                 ", location=" + getLocation() +
-                ", ifExpr='" + ifExpr + '\'';
-
+                ", ifExpr='" + ifExpr + '\'' + 
+                ", commit='" + commit + '\'';
     }
 }
diff --git a/core/src/java/scriptella/core/DynamicContext.java b/core/src/java/scriptella/core/DynamicContext.java
index 1a63b27c..4a354a05 100644
--- a/core/src/java/scriptella/core/DynamicContext.java
+++ b/core/src/java/scriptella/core/DynamicContext.java
@@ -16,6 +16,7 @@
 package scriptella.core;
 
 import scriptella.execution.EtlContext;
+import scriptella.execution.ExecutionStatisticsBuilder;
 import scriptella.spi.Connection;
 import scriptella.spi.ParametersCallback;
 
@@ -32,12 +33,14 @@
 public class DynamicContext implements ParametersCallback {
     protected EtlContext globalContext;
     protected EtlVariable etlVariable;
+    protected ExecutionStatisticsBuilder statisticsBuilder;
 
     protected DynamicContext() {
     }
 
     public DynamicContext(EtlContext globalContext) {
         this.globalContext = globalContext;
+        this.statisticsBuilder = globalContext.getStatisticsBuilder();
     }
 
     public Object getParameter(final String name) {
@@ -56,7 +59,11 @@ public Connection getConnection() {
     protected EtlContext getGlobalContext() {
         return globalContext;
     }
-
+    
+    protected ExecutionStatisticsBuilder getStatisticsBuilder(){
+    		return statisticsBuilder;
+    }
+    
     EtlVariable getEtlVariable() {
         if (etlVariable == null) {
             etlVariable = new EtlVariable(this, globalContext);
diff --git a/core/src/java/scriptella/core/DynamicContextDecorator.java b/core/src/java/scriptella/core/DynamicContextDecorator.java
index 18714b3d..155758f2 100644
--- a/core/src/java/scriptella/core/DynamicContextDecorator.java
+++ b/core/src/java/scriptella/core/DynamicContextDecorator.java
@@ -56,14 +56,15 @@ public Connection getConnection() {
 
 
     /**
-     * Dynamically changes context beign decorated.
-     * <p>Should be used with caution mostly for performance reasosns.
+     * Dynamically changes context being decorated.
+     * <p>Should be used with caution mostly for performance reasons.
      *
      * @param context new context to decorate.
      */
     void setContext(final DynamicContext context) {
         this.context = context;
         globalContext = context.getGlobalContext();
+    		statisticsBuilder = globalContext.getStatisticsBuilder();
         cachedConnection = null;
     }
 
diff --git a/core/src/java/scriptella/core/IfInterceptor.java b/core/src/java/scriptella/core/IfInterceptor.java
index ddcee35a..a4b9cf59 100644
--- a/core/src/java/scriptella/core/IfInterceptor.java
+++ b/core/src/java/scriptella/core/IfInterceptor.java
@@ -54,7 +54,6 @@ public IfInterceptor(ExecutableElement next, ScriptingElement scr) {
 
     public void execute(final DynamicContext ctx) {
         boolean ok = false;
-
         try {
             final Object res = expression.evaluate(ctx);
 
@@ -75,6 +74,7 @@ public void execute(final DynamicContext ctx) {
         if (ok) { //if expr evaluated to true
             executeNext(ctx);
         } else {
+        		ctx.statisticsBuilder.incrementFilteredExecutionCount(location);
             if (LOG.isLoggable(Level.FINE)) {
                 LOG.fine("if=\""+expression.getExpression()+"\" is false, element body is skipped.");
             }
diff --git a/core/src/java/scriptella/core/QueryExecutor.java b/core/src/java/scriptella/core/QueryExecutor.java
index 0e162b8e..b5844812 100644
--- a/core/src/java/scriptella/core/QueryExecutor.java
+++ b/core/src/java/scriptella/core/QueryExecutor.java
@@ -61,14 +61,16 @@ private void initNestedExecutors() {
             }
         }
     }
-
-
+    
     protected void execute(Connection connection, Resource resource, DynamicContext ctx) {
         final QueryCtxDecorator ctxDecorator = new QueryCtxDecorator(ctx);
         if (debug) {
             log.fine("Executing query " + getLocation());
         }
         connection.executeQuery(resource, ctx, ctxDecorator);
+        if (getElement().getCommit().equalsIgnoreCase("TRUE")){
+    			ctx.getGlobalContext().getSession().commit();
+        }
         if (debug) {
             if (ctxDecorator.rownum == 0) {
                 log.fine("Query " + getLocation() + " returned no results.");
@@ -103,6 +105,10 @@ public QueryCtxDecorator(DynamicContext context) {
 
         public void processRow(final ParametersCallback parameters) {
             EtlCancelledException.checkEtlCancelled();
+            if (rownum == 0){
+              statisticsBuilder.elementProcessingStarted();
+            }
+            statisticsBuilder.incrementNestedExecutionCount();
             rownum++;
             params = parameters;
             cachedParams.clear();
diff --git a/core/src/java/scriptella/core/ScriptExecutor.java b/core/src/java/scriptella/core/ScriptExecutor.java
index 217e9b58..c06bbf7b 100644
--- a/core/src/java/scriptella/core/ScriptExecutor.java
+++ b/core/src/java/scriptella/core/ScriptExecutor.java
@@ -37,6 +37,7 @@
  * @version 1.0
  */
 public final class ScriptExecutor extends ContentExecutor<ScriptEl> {
+		private boolean firstExecution = true;
     public ScriptExecutor(ScriptEl scriptEl) {
         super(scriptEl);
     }
@@ -45,6 +46,10 @@ protected void execute(Connection connection, Resource resource, DynamicContext
         if (debug) {
             log.fine("Executing script " + getLocation());
         }
+	      if (firstExecution){
+	      	firstExecution = false;
+	        ctx.statisticsBuilder.elementProcessingStarted();
+	      }
         boolean repeat;
         OnErrorHandler onErrorHandler = null;
         do {
diff --git a/core/src/java/scriptella/core/StatisticInterceptor.java b/core/src/java/scriptella/core/StatisticInterceptor.java
index 9ab0713a..c8829f70 100644
--- a/core/src/java/scriptella/core/StatisticInterceptor.java
+++ b/core/src/java/scriptella/core/StatisticInterceptor.java
@@ -16,7 +16,6 @@
 package scriptella.core;
 
 import scriptella.configuration.Location;
-import scriptella.execution.ExecutionStatisticsBuilder;
 
 
 /**
@@ -35,16 +34,15 @@ public StatisticInterceptor(ExecutableElement next, Location location) {
 
     public void execute(final DynamicContext ctx) {
         boolean ok = false;
-        final ExecutionStatisticsBuilder statisticsBuilder = ctx.getGlobalContext().getStatisticsBuilder();
-        statisticsBuilder.elementStarted(location, ctx.getConnection());
+        ctx.statisticsBuilder.elementStarted(location, ctx.getConnection());
         try {
             executeNext(ctx);
             ok = true;
         } finally {
             if (ok) {
-                statisticsBuilder.elementExecuted();
+                ctx.statisticsBuilder.elementExecuted();
             } else {
-                statisticsBuilder.elementFailed();
+                ctx.statisticsBuilder.elementFailed();
             }
         }
 
diff --git a/core/src/java/scriptella/execution/ExecutionStatistics.java b/core/src/java/scriptella/execution/ExecutionStatistics.java
index 19acb254..b7bba397 100644
--- a/core/src/java/scriptella/execution/ExecutionStatistics.java
+++ b/core/src/java/scriptella/execution/ExecutionStatistics.java
@@ -104,11 +104,11 @@ public String toString() {
         for (ElementInfo ei : elements) {
             sb.append(ei.id).append(":");
 
-            if (ei.okCount > 0) {
+            if (ei.successfulExecutionCount > 0) {
                 sb.append(" Element successfully executed");
-                if (ei.okCount > 1) {
+                if (ei.successfulExecutionCount > 1) {
                     sb.append(' ');
-                    appendPlural(sb, ei.okCount, "time");
+                    appendPlural(sb, ei.successfulExecutionCount, "time");
                 }
                 if (ei.statements > 0) {
                     sb.append(" (");
@@ -117,9 +117,9 @@ public String toString() {
                 sb.append('.');
             }
 
-            if (ei.failedCount > 0) {
+            if (ei.failedExecutionCount > 0) {
                 sb.append(" Element failed ");
-                appendPlural(sb, ei.failedCount, "time");
+                appendPlural(sb, ei.failedExecutionCount, "time");
                 sb.append('.');
             }
             sb.append(" Working time ").append(ei.workingTime / 1000000).append(" milliseconds.");
@@ -248,21 +248,50 @@ void setFinished(Date finished) {
 
 
     public static class ElementInfo {
-        int okCount;
-        Connection connection;
+    		Connection connection;
+        int successfulExecutionCount;
+        int filteredExecutionCount;
+        int failedExecutionCount;
+        int nestedExecutionCount;
         long statementsOnStart;
         long statements;
-        int failedCount;
         long started;
+        Date execStart;
+        Date processingStart;
+        Date execEnd;
         long workingTime;
         String id;
-
+        
+        public Date getProcessingStart(){
+        		return processingStart;
+        }
+        
+        public Date getExecStart(){
+        	return execStart;
+        }
+        
+        public Date getExecEnd(){
+        	return execEnd;
+        }
+        
+        public int getTotalExecutionCount(){
+        	return filteredExecutionCount + successfulExecutionCount + failedExecutionCount;
+        }
+        
+        public int getFilteredExecutionCount(){
+        	return filteredExecutionCount;
+        }
+        
         public int getSuccessfulExecutionCount() {
-            return okCount;
+            return successfulExecutionCount;
         }
 
         public int getFailedExecutionCount() {
-            return failedCount;
+            return failedExecutionCount;
+        }
+        
+        public int getNestedExecutionCount(){
+        	return nestedExecutionCount;
         }
 
         /**
@@ -284,15 +313,23 @@ public long getStatementsCount() {
         public long getWorkingTime() {
             return workingTime;
         }
+        
+        /**
+         * 
+         * @return total execution time in seconds.
+         */
+        public long getExecTime() {
+        		return (execEnd.getTime()-execStart.getTime())/1000;
+        }
 
         /**
-         * Returns throughput t=statements/workingTimeSeconds. The
-         * throughput has statement/second unit.
+         * Returns throughput t=statements/execTimeSeconds. The
+         * throughput has statements/second unit.
          *
-         * @return statement/second thoughput or -1 if no statements info available or working time is zero.
+         * @return stmt/second thoughput or -1 if no statements info available or execution time is zero.
          */
         public double getThroughput() {
-            return statements <= 0 || workingTime <= 0 ? -1 : 1000000000d * statements / workingTime;
+            return statements <= 0 || getExecTime() <= 0 ? -1 : getStatementsCount() / getExecTime();
         }
 
         public String getId() {
diff --git a/core/src/java/scriptella/execution/ExecutionStatisticsBuilder.java b/core/src/java/scriptella/execution/ExecutionStatisticsBuilder.java
index c7578134..80d7263b 100644
--- a/core/src/java/scriptella/execution/ExecutionStatisticsBuilder.java
+++ b/core/src/java/scriptella/execution/ExecutionStatisticsBuilder.java
@@ -46,6 +46,9 @@ public class ExecutionStatisticsBuilder {
 
     //Execution stack for nested elements
     protected ElementsStack executionStack = new ElementsStack();
+    
+    //current element (shortcut for performance reasons)
+    protected ExecutionStatistics.ElementInfo currentEInfo;
 
     /**
      * Called when new element execution started.
@@ -53,11 +56,27 @@ public class ExecutionStatisticsBuilder {
      * @param loc element location.
      */
     public void elementStarted(final Location loc, Connection connection) {
-        ExecutionStatistics.ElementInfo ei = getInfo(loc);
-        executionStack.push(ei);
-        ei.statementsOnStart = connection.getExecutedStatementsCount();
-        ei.connection = connection;
-        ei.started = System.nanoTime();
+    		currentEInfo = getInfo(loc);
+        currentEInfo.started = System.nanoTime();
+        // check, because script elements will call elementStarted every time in the query loop
+        if (currentEInfo.execStart == null){
+        	currentEInfo.execStart = new Date();
+        }
+        executionStack.push(currentEInfo);
+        currentEInfo.statementsOnStart = connection.getExecutedStatementsCount();
+        currentEInfo.connection = connection;
+    }
+    
+    public void incrementNestedExecutionCount(){
+    	currentEInfo.nestedExecutionCount++;
+    }
+    
+    public void incrementFilteredExecutionCount(final Location loc){
+    	getInfo(loc).filteredExecutionCount++;
+    }
+    
+    public void elementProcessingStarted(){
+    	currentEInfo.processingStart = new Date();
     }
 
     /**
@@ -74,7 +93,8 @@ public void etlStarted() {
         executionStatistics = new ExecutionStatistics();
         executionStatistics.setStarted(new Date());
     }
-
+    
+    
     /**
      * Invoked on ETL completion.
      */
@@ -93,6 +113,11 @@ public void etlComplete() {
      */
     private void setElementState(boolean ok) {
         ExecutionStatistics.ElementInfo ended = executionStack.pop();
+        if (executionStack.size() > 0){
+        	currentEInfo = executionStack.get(executionStack.size() -1);
+        }
+
+        ended.execEnd = new Date();
         long ti = System.nanoTime() - ended.started;
         ended.workingTime += ti; //increase the total working time for element
         if (ended.workingTime < 0) {
@@ -103,9 +128,9 @@ private void setElementState(boolean ok) {
         long conStatements = con.getExecutedStatementsCount();
         long elStatements = conStatements - ended.statementsOnStart;
         if (ok) {
-            ended.okCount++;
+            ended.successfulExecutionCount++;
         } else {
-            ended.failedCount++;
+            ended.failedExecutionCount++;
         }
 
         if (elStatements > 0) {
diff --git a/core/src/test/scriptella/execution/ExecutionStatisticsTest.java b/core/src/test/scriptella/execution/ExecutionStatisticsTest.java
index b7dba0f4..316234aa 100644
--- a/core/src/test/scriptella/execution/ExecutionStatisticsTest.java
+++ b/core/src/test/scriptella/execution/ExecutionStatisticsTest.java
@@ -139,6 +139,38 @@ public void test3() throws EtlExecutorException {
             }
         }
     }
+    
+    /*
+     * Tests for NestedExecutionCount() and FilteredExecutionCount
+     */
+    public void test4() throws EtlExecutorException {
+      final EtlExecutor se = newEtlExecutor(
+          "ExecutionStatisticsTest4.xml");
+      final ExecutionStatistics s = se.execute();
+      final Collection<ExecutionStatistics.ElementInfo> elements = s.getElements();
+
+      for (ExecutionStatistics.ElementInfo info : elements) {
+          if ("/etl/script[1]".equals(info.getId())) {
+            assertEquals(1, info.getSuccessfulExecutionCount());
+            assertEquals(0, info.getFailedExecutionCount());
+            assertEquals(4, info.getStatementsCount());
+            assertEquals(0, info.getNestedExecutionCount());
+          } else if ("/etl/query[1]".equals(info.getId())) {
+            assertEquals(1, info.getSuccessfulExecutionCount());
+            assertEquals(0, info.getFailedExecutionCount());
+            assertEquals(2, info.getStatementsCount());
+            assertEquals(4, info.getNestedExecutionCount());
+          } else if ("/etl/query[1]/query[1]".equals(info.getId())) {
+            assertEquals(2, info.getSuccessfulExecutionCount());
+            assertEquals(0, info.getFailedExecutionCount());
+            assertEquals(2, info.getFilteredExecutionCount());
+            assertEquals(2, info.getStatementsCount());
+            assertEquals(4, info.getNestedExecutionCount());
+          } else {
+              fail("Unrecognized statistic element " + info.getId());
+          }
+      }
+  }
 
     /**
      * Tests if total time is correctly printed.
diff --git a/core/src/test/scriptella/execution/ExecutionStatisticsTest4.xml b/core/src/test/scriptella/execution/ExecutionStatisticsTest4.xml
new file mode 100644
index 00000000..a9efe247
--- /dev/null
+++ b/core/src/test/scriptella/execution/ExecutionStatisticsTest4.xml
@@ -0,0 +1,21 @@
+<!DOCTYPE etl SYSTEM "http://scriptella.javaforge.com/dtd/etl.dtd">
+<etl>
+    <connection driver="org.hsqldb.jdbcDriver" url="jdbc:hsqldb:mem:est" user="sa" password=""/>
+    <script>
+        create table t1 (
+        id int
+        );
+        create table t2 (
+        id int
+        );
+        insert into t1(id) values(1);
+        insert into t1(id) values(2);
+    </script>
+    <query>
+        select * from t1;
+        select * from t1;
+				<query if="id eq 1"> 
+        select * from t1;
+    		</query>
+    </query>
+</etl>
\ No newline at end of file
diff --git a/drivers/src/java/scriptella/driver/hana/Driver.java b/drivers/src/java/scriptella/driver/hana/Driver.java
new file mode 100644
index 00000000..703aa774
--- /dev/null
+++ b/drivers/src/java/scriptella/driver/hana/Driver.java
@@ -0,0 +1,34 @@
+/*
+ * Copyright 2006-2012 The Scriptella Project Team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package scriptella.driver.hana;
+
+import scriptella.jdbc.GenericDriver;
+
+/**
+ * Scriptella Adapter for Hana database.
+ * <p>For configuration details and examples see <a href="package-summary.html">overview page</a>.
+ *
+ * @author Bodo Hüsemann
+ * @version 1.0
+ */
+public class Driver extends GenericDriver {
+    public static final String HANA_DRIVER_NAME = "com.sap.db.jdbc.Driver";
+
+
+    public Driver() {
+        loadDrivers(HANA_DRIVER_NAME);
+    }
+}
diff --git a/drivers/src/java/scriptella/driver/hana/package.html b/drivers/src/java/scriptella/driver/hana/package.html
new file mode 100644
index 00000000..ae5129c3
--- /dev/null
+++ b/drivers/src/java/scriptella/driver/hana/package.html
@@ -0,0 +1,31 @@
+<body>
+<a href="http://hana.sap.com/">SAP Hana Database</a> Driver Adapter for Scriptella.
+<p>See <a href="../../jdbc/package-summary.html#package_description">Overview of JDBC package</a> for a description of common features and connection properties.</p>
+<h2>General information</h2>
+<table>
+    <tr>
+        <td><b>Driver class:</b></td><td><code>scriptella.driver.hana.Driver</code></td>
+    </tr>
+    <tr>
+        <td><b>URL:</b></td><td><code>jdbc:sap://<server>:<port>[/?<options>]</code></td>
+    </tr>
+    <tr>
+        <td><b>Runtime dependencies:</b></td><td><code>ngdbc5.jar</code></td>
+    </tr>
+</table>
+<h2>Driver Specific Properties</h2>
+<table border="1">
+    <tr>
+        <th>Name</th>
+        <th>Description</th>
+        <th>Required</th>
+    </tr>
+</table>
+
+<h2>Examples</h2>
+<code><pre>
+    &lt;connection driver="hana" url="jdbc:sap://myServer:30015/?autocommit=false" user="sa"&gt;
+    &lt;/connection&gt;
+</pre></code>
+
+</body>
\ No newline at end of file
diff --git a/lib/hsqldb.jar b/lib/hsqldb.jar
index e010269d..f931a458 100644
Binary files a/lib/hsqldb.jar and b/lib/hsqldb.jar differ
diff --git a/lib/janino-commons-compiler.jar b/lib/janino-commons-compiler.jar
index 39ec753d..46cd6630 100644
Binary files a/lib/janino-commons-compiler.jar and b/lib/janino-commons-compiler.jar differ
diff --git a/lib/janino.jar b/lib/janino.jar
index c92f4779..79b946df 100644
Binary files a/lib/janino.jar and b/lib/janino.jar differ
diff --git a/sql/DynamicIncludeITest1.sql b/sql/DynamicIncludeITest1.sql
new file mode 100644
index 00000000..40ac79c6
--- /dev/null
+++ b/sql/DynamicIncludeITest1.sql
@@ -0,0 +1 @@
+INSERT INTO Data VALUES (1)
\ No newline at end of file
diff --git a/sql/DynamicIncludeITest2.sql b/sql/DynamicIncludeITest2.sql
new file mode 100644
index 00000000..6cac246f
--- /dev/null
+++ b/sql/DynamicIncludeITest2.sql
@@ -0,0 +1 @@
+INSERT INTO Data VALUES (2)
\ No newline at end of file
diff --git a/sql/XIncludeTest.sql b/sql/XIncludeTest.sql
new file mode 100644
index 00000000..576a8f17
--- /dev/null
+++ b/sql/XIncludeTest.sql
@@ -0,0 +1 @@
+insert into test2(id, value) values (3,'444');
\ No newline at end of file