Fix(TDI-34953):reset the changes

This reverts commit ce443a4c17.

main/plugins/org.talend.designer.components.localprovider/components/tAS400Output/tAS400Output_main.javajet

@@ -301,6 +301,7 @@ skeleton="../templates/db_output_bulk.skeleton"
     		%>
     		pstmt_<%=cid %>.addBatch();
     		nb_line_<%=cid%>++;
+    		  <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
     		  <%dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));%>
     		  	batchSizeCounter_<%=cid%>++;
     		<%
@@ -309,6 +310,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 nb_line_<%=cid%>++;
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.sql.SQLException e) {
                 whetherReject_<%=cid%> = true;
@@ -431,6 +433,7 @@ skeleton="../templates/db_output_bulk.skeleton"
     		%>
     		pstmt_<%=cid %>.addBatch();
     		nb_line_<%=cid%>++;
+    		<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
 			<%dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));%>
 			batchSizeCounter_<%=cid%>++;
     		<%
@@ -439,6 +442,7 @@ skeleton="../templates/db_output_bulk.skeleton"
              try {
                 nb_line_<%=cid%>++;
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.sql.SQLException e) {
                 whetherReject_<%=cid%> = true;
@@ -586,6 +590,7 @@ skeleton="../templates/db_output_bulk.skeleton"
     			%>
         			updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
         			nb_line_<%=cid%>++;
+        			<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.sql.SQLException e) {
                     whetherReject_<%=cid%> = true;
@@ -661,6 +666,7 @@ skeleton="../templates/db_output_bulk.skeleton"
     			%>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.sql.SQLException e) {
                     whetherReject_<%=cid%> = true;
@@ -835,9 +841,11 @@ skeleton="../templates/db_output_bulk.skeleton"
         		%>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
     			}else{
     				nb_line_<%=cid%>++;
+    				<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
     			}
                 } catch(java.sql.SQLException e) {
@@ -914,6 +922,7 @@ skeleton="../templates/db_output_bulk.skeleton"
     		%>
     		pstmt_<%=cid %>.addBatch();
     		nb_line_<%=cid%>++;
+    		<%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
 			<%dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));%>
    			batchSizeCounter_<%=cid%>++;
    		   <%
@@ -922,6 +931,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
 				<%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.sql.SQLException e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tAccessOutput/tAccessOutput_main.javajet

@@ -141,6 +141,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
             	insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
             	nb_line_<%=cid%>++;
+            	<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
             	<%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -230,6 +231,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
             	updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
             	nb_line_<%=cid%>++;
+            	<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
             	<%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -347,6 +349,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
     				updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
     				nb_line_<%=cid%>++;
+    				<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -408,6 +411,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try{
         			insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
         			nb_line_<%=cid%>++;
+        			<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -504,6 +508,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                  updateFlag_<%=cid%>=pstmtUpdate_<%=cid %>.executeUpdate();
                  if(updateFlag_<%=cid%> != 0) {
             		nb_line_<%=cid%>++;
+            		<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
                  }
                  updatedCount_<%=cid%> = updatedCount_<%=cid%>+updateFlag_<%=cid%>;
@@ -569,6 +574,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                  try {
         			insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
         			nb_line_<%=cid%>++;
+        			<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 	<%dbLog.data().inserting(dbLog.var("nb_line"));%>
                  } catch(java.lang.Exception e) {
                      whetherReject_<%=cid%> = true;
@@ -647,6 +653,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tAmazonMysqlOutput/tAmazonMysqlOutput_main.javajet

@@ -763,6 +763,7 @@ if(columnList != null && columnList.size() > 0) {
 		    		pstmt_<%=cid %>.addBatch();
 		    		nb_line_<%=cid%>++;
 
+						<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
 		    			<%dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));%>
 		    		  	<%
 		    		  	if (!("").equals(numPerInsert ) && !("0").equals(numPerInsert )) {
@@ -777,6 +778,7 @@ if(columnList != null && columnList.size() > 0) {
 	                try {
 	                    nb_line_<%=cid%>++;
 	                    insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+	                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
 	                    <%dbLog.data().inserting(dbLog.var("nb_line"));%>
 	                } catch(java.lang.Exception e) {
 	                    whetherReject_<%=cid%> = true;
@@ -854,6 +856,7 @@ if(columnList != null && columnList.size() > 0) {
                 try {
                     nb_line_<%=cid%>++;
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -979,6 +982,7 @@ if(columnList != null && columnList.size() > 0) {
     		%>
         		pstmt_<%=cid %>.addBatch();
         		nb_line_<%=cid%>++;
+        		<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     		  	<%dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));%>
     		  		batchSizeCounter_<%=cid%>++;
     		<%
@@ -987,6 +991,7 @@ if(columnList != null && columnList.size() > 0) {
             try {
                 nb_line_<%=cid%>++;
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -1139,6 +1144,7 @@ if(columnList != null && columnList.size() > 0) {
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -1214,6 +1220,7 @@ if(columnList != null && columnList.size() > 0) {
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -1391,9 +1398,11 @@ if(columnList != null && columnList.size() > 0) {
         		%>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
              		nb_line_<%=cid%>++;
+             		<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
     			}else{
     				nb_line_<%=cid%>++;
+    				<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
     			}
                 } catch(java.lang.Exception e) {
@@ -1472,6 +1481,7 @@ if(columnList != null && columnList.size() > 0) {
     		%>
         		pstmt_<%=cid %>.addBatch();
     			nb_line_<%=cid%>++;
+    			<%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
         		<%dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));%>
     		  		batchSizeCounter_<%=cid%>++;
     		<%
@@ -1480,6 +1490,7 @@ if(columnList != null && columnList.size() > 0) {
             try {
         	    deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
             	nb_line_<%=cid%>++;
+            	<%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
             	<%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -1626,6 +1637,7 @@ if(columnList != null && columnList.size() > 0) {
             int count_on_duplicate_key_<%=cid%> = 0;
             try {
                 count_on_duplicate_key_<%=cid%> = pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insertIgnore_"+cid+"");%>
                 <%dbLog.data().insertingOnDuplicateKeyUpdating(null);%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -1691,6 +1703,7 @@ if(columnList != null && columnList.size() > 0) {
                 try {
                     nb_line_<%=cid%>++;
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                    <%dbLog.data().sqlExecuteTry("insertIgnore_"+cid+"");%>
                     <%dbLog.data().insertingOnDuplicateKeyUpdating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tAmazonOracleOutput/tAmazonOracleOutput_main.javajet

@@ -454,6 +454,7 @@ IMetadataColumn talendDynCol = null;
             try {
                 nb_line_<%=cid%>++;
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -595,6 +596,7 @@ IMetadataColumn talendDynCol = null;
              try {
                 nb_line_<%=cid%>++;
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -760,6 +762,7 @@ IMetadataColumn talendDynCol = null;
                 try {
         			updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
         			nb_line_<%=cid%>++;
+        			<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -840,6 +843,7 @@ IMetadataColumn talendDynCol = null;
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -1025,9 +1029,11 @@ IMetadataColumn talendDynCol = null;
         		%>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
     			}else{
     				nb_line_<%=cid%>++;
+    				<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
     			}
                 } catch(java.lang.Exception e) {
@@ -1118,6 +1124,7 @@ IMetadataColumn talendDynCol = null;
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tDB2Output/tDB2Output_main.javajet

@@ -348,6 +348,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 nb_line_<%=cid%>++;
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -504,6 +505,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 nb_line_<%=cid%>++;
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -679,6 +681,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -777,6 +780,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -984,9 +988,11 @@ skeleton="../templates/db_output_bulk.skeleton"
         		%>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
 					nb_line_<%=cid%>++;
+					<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
     			}else{
     				nb_line_<%=cid%>++;
+    				<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
     			}
                 } catch(java.lang.Exception e) {
@@ -1088,6 +1094,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
             	deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
             	nb_line_<%=cid%>++;
+            	<%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tEXAOutput/tEXAOutput_main.javajet

@@ -311,6 +311,8 @@ skeleton="@{org.talend.designer.components.localprovider}/components/templates/d
             %>
             pstmt_<%=cid %>.addBatch();
             nb_line_<%=cid%>++;
+            
+              <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
               <%
               dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
               %>
@@ -321,6 +323,7 @@ skeleton="@{org.talend.designer.components.localprovider}/components/templates/d
             try {
                 nb_line_<%=cid%>++;
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -446,6 +449,8 @@ skeleton="@{org.talend.designer.components.localprovider}/components/templates/d
             %>
             pstmt_<%=cid %>.addBatch();
             nb_line_<%=cid%>++;
+            
+              <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
               <%
               dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
               %>
@@ -456,6 +461,7 @@ skeleton="@{org.talend.designer.components.localprovider}/components/templates/d
             try {
                 nb_line_<%=cid%>++;
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -606,6 +612,7 @@ skeleton="@{org.talend.designer.components.localprovider}/components/templates/d
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -683,6 +690,7 @@ skeleton="@{org.talend.designer.components.localprovider}/components/templates/d
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -855,9 +863,11 @@ skeleton="@{org.talend.designer.components.localprovider}/components/templates/d
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                     }else{
                         nb_line_<%=cid%>++;
+                        <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                         <%dbLog.data().updating(dbLog.var("nb_line"));%>
                     }
                 } catch(java.lang.Exception e) {
@@ -937,6 +947,8 @@ skeleton="@{org.talend.designer.components.localprovider}/components/templates/d
             %>
             pstmt_<%=cid %>.addBatch();
             nb_line_<%=cid%>++;
+              
+              <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
               <%
               dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
               %>
@@ -947,6 +959,7 @@ skeleton="@{org.talend.designer.components.localprovider}/components/templates/d
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tFirebirdOutput/tFirebirdOutput_main.javajet

@@ -153,6 +153,8 @@ skeleton="../templates/db_output_bulk.skeleton"
                        pstmt_<%=cid %>.addBatch();
                        batchSizeCounter_<%=cid%>++;
                        nb_line_<%=cid%>++;
+                       
+                       <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                        <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                     <%
                }else{
@@ -160,6 +162,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        try {
                            insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                            nb_line_<%=cid%>++;
+                           <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                            <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                        } catch(java.lang.Exception e) {
                            whetherReject_<%=cid%> = true;
@@ -256,6 +259,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                            pstmt_<%=cid %>.addBatch();
                            batchSizeCounter_<%=cid%>++;
                            nb_line_<%=cid%>++;
+                           <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                            <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                         <%
                }else{
@@ -263,6 +267,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                            try {
                                updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                                nb_line_<%=cid%>++;
+                               <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                                <%dbLog.data().updating(dbLog.var("nb_line"));%>
                            } catch(java.lang.Exception e) {
                                whetherReject_<%=cid%> = true;
@@ -384,6 +389,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -445,6 +451,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -573,9 +580,11 @@ skeleton="../templates/db_output_bulk.skeleton"
         		%>
                 	insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                 	nb_line_<%=cid%>++;
+                	<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
     			}else{
     				nb_line_<%=cid%>++;
+    				<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
              	}
                 } catch(java.lang.Exception e) {
@@ -658,6 +667,8 @@ skeleton="../templates/db_output_bulk.skeleton"
                        pstmt_<%=cid %>.addBatch();
                        batchSizeCounter_<%=cid%>++;
                        nb_line_<%=cid%>++;
+                       
+                       <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                        <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                     <%
                }else{
@@ -665,6 +676,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        try {
                            deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                            nb_line_<%=cid%>++;
+                           <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                            <%dbLog.data().deleting(dbLog.var("nb_line"));%>
                        } catch(java.lang.Exception e) {
                            whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tHSQLDbOutput/tHSQLDbOutput_main.javajet

@@ -127,6 +127,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -200,6 +201,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -291,6 +293,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -352,6 +355,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -462,9 +466,11 @@ skeleton="../templates/db_output_bulk.skeleton"
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();  
          			nb_line_<%=cid%>++;
+         			<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
     			}else{
     				nb_line_<%=cid%>++;
+    				<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
     			}
                 } catch(java.lang.Exception e) {
@@ -527,6 +533,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tInformixOutput/tInformixOutput_main.javajet

@@ -331,6 +331,7 @@ skeleton="../templates/db_output_bulk.skeleton"
     		pstmt_<%=cid %>.addBatch();
     		nb_line_<%=cid%>++;
     		batchSizeCounter_<%=cid%>++;
+    		<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
 <%
 			dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
 %>
@@ -340,6 +341,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 nb_line_<%=cid%>++;
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -467,6 +469,7 @@ skeleton="../templates/db_output_bulk.skeleton"
     		pstmt_<%=cid %>.addBatch();
     		nb_line_<%=cid%>++;
     		batchSizeCounter_<%=cid%>++;
+    		<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
 <%
 			dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
 %>
@@ -476,6 +479,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 nb_line_<%=cid%>++;
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         	    <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -625,6 +629,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -700,6 +705,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -871,9 +877,11 @@ skeleton="../templates/db_output_bulk.skeleton"
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
              		nb_line_<%=cid%>++;
+             		<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
     			}else{
     				nb_line_<%=cid%>++;
+    				<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
     			}
                 } catch(java.lang.Exception e) {
@@ -958,6 +966,7 @@ skeleton="../templates/db_output_bulk.skeleton"
 		    		pstmt_<%=cid %>.addBatch();
 		    		batchSizeCounter_<%=cid%>++;
 					nb_line_<%=cid%>++;
+					<%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
     			<%
 				dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
 				%>
@@ -967,6 +976,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tIngresOutput/tIngresOutput_main.javajet

@@ -151,6 +151,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                       pstmt_<%=cid %>.addBatch();
                       batchSizeCounter_<%=cid%>++;
                       nb_line_<%=cid%>++;
+                      <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                       <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                    <%
                }else{
@@ -158,6 +159,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                       try {
                           insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                           nb_line_<%=cid%>++;
+                          <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                           <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                       } catch(java.lang.Exception e) {
                           whetherReject_<%=cid%> = true;
@@ -253,6 +255,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                       pstmt_<%=cid %>.addBatch();
                       batchSizeCounter_<%=cid%>++;
                       nb_line_<%=cid%>++;
+                      <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                       <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                     <%
                 }else{
@@ -260,6 +263,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                       try {
                           updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                           nb_line_<%=cid%>++;
+                          <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                           <%dbLog.data().updating(dbLog.var("nb_line"));%>
                       } catch(java.lang.Exception e) {
                           whetherReject_<%=cid%> = true;
@@ -379,6 +383,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -440,6 +445,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -567,9 +573,11 @@ skeleton="../templates/db_output_bulk.skeleton"
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 }else{
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
              }
                 } catch(java.lang.Exception e) {
@@ -652,6 +660,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        pstmt_<%=cid %>.addBatch();
                        batchSizeCounter_<%=cid%>++;
                        nb_line_<%=cid%>++;
+                       <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                        <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                     <%
                }else{
@@ -659,6 +668,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        try {
                            deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                            nb_line_<%=cid%>++;
+                           <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                            <%dbLog.data().deleting(dbLog.var("nb_line"));%>
                        } catch(java.lang.Exception e) {
                            whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tInterbaseOutput/tInterbaseOutput_main.javajet

@@ -154,6 +154,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        try {
                            insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                            nb_line_<%=cid%>++;
+                           <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                            <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                        } catch(java.lang.Exception e) {
                            whetherReject_<%=cid%> = true;
@@ -254,6 +255,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        try {
                            updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                            nb_line_<%=cid%>++;
+                           <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                         <%dbLog.data().updating(dbLog.var("nb_line"));%>
                        } catch(java.lang.Exception e) {
                            whetherReject_<%=cid%> = true;
@@ -372,6 +374,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -433,6 +436,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -558,9 +562,11 @@ skeleton="../templates/db_output_bulk.skeleton"
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 }else{
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 }
                 } catch(java.lang.Exception e) {
@@ -647,6 +653,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        try {
                            deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                            nb_line_<%=cid%>++;
+                           <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                            <%dbLog.data().deleting(dbLog.var("nb_line"));%>
                        } catch(java.lang.Exception e) {
                            whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tJavaDBOutput/tJavaDBOutput_main.javajet

@@ -127,6 +127,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -200,6 +201,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -291,6 +293,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -352,6 +355,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -434,6 +438,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 updateFlag_<%=cid%>=pstmtUpdate_<%=cid %>.executeUpdate();
                 if(updateFlag_<%=cid%> != 0){
                 	nb_line_<%=cid%>++;
+                	<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
 					<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 }
                 updatedCount_<%=cid%> = updatedCount_<%=cid%>+updateFlag_<%=cid%>;
@@ -499,6 +504,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 	<%dbLog.data().inserting(dbLog.var("nb_line"));%>   
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -561,6 +567,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
             	nb_line_<%=cid%>++;
+            	<%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tMSSqlOutput/tMSSqlOutput_main.javajet

@@ -586,6 +586,7 @@ if(incomingConnName != null && columnList != null){
     		%>
         		pstmt_<%=cid %>.addBatch();
         		nb_line_<%=cid%>++;
+        		<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
     		 <%
     		 dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
     		 %>
@@ -603,6 +604,7 @@ if(incomingConnName != null && columnList != null){
 %>
                 nb_line_<%=cid%>++;
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -831,6 +833,7 @@ if(incomingConnName != null && columnList != null){
     		%>
     		pstmt_<%=cid %>.addBatch();
     		nb_line_<%=cid%>++;
+    		<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     		<%
     		dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
     		%>
@@ -848,6 +851,7 @@ if(incomingConnName != null && columnList != null){
 %>
                 nb_line_<%=cid%>++;
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         	    <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -1018,6 +1022,7 @@ if(incomingConnName != null && columnList != null){
 %>
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -1109,6 +1114,7 @@ if(incomingConnName != null && columnList != null){
 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -1301,9 +1307,11 @@ if(incomingConnName != null && columnList != null){
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
 					nb_line_<%=cid%>++;
+					<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
     			}else{
     				nb_line_<%=cid%>++;
+    				<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
     			}
                 } catch(java.lang.Exception e) {
@@ -1391,6 +1399,7 @@ if(incomingConnName != null && columnList != null){
     		%>
     		pstmt_<%=cid %>.addBatch();
     		nb_line_<%=cid%>++;
+    		<%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
 			<%
 			dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
     		%>
@@ -1408,6 +1417,7 @@ if(incomingConnName != null && columnList != null){
 %>
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -1526,6 +1536,7 @@ if(incomingConnName != null && columnList != null){
 %>
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
 				whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tMaxDBOutput/tMaxDBOutput_main.javajet

@@ -132,6 +132,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -218,6 +219,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -333,6 +335,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
         			updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
         			nb_line_<%=cid%>++;
+        			<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -391,6 +394,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
 					<%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -543,6 +547,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -577,6 +582,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 }
             }else{
                  nb_line_<%=cid%>++;
+                 <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
 				 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             }
             <%    	
@@ -620,6 +626,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
 				<%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tMysqlOutput/tMysqlOutput_main.javajet

@@ -780,6 +780,7 @@ if(columnList != null && columnList.size() > 0) {
                     pstmt_<%=cid %>.addBatch();
                     nb_line_<%=cid%>++;
 
+						<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                         <%dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));%>
                         <%
                         if (!("").equals(numPerInsert ) && !("0").equals(numPerInsert )) {
@@ -794,6 +795,7 @@ if(columnList != null && columnList.size() > 0) {
                     try {
                         nb_line_<%=cid%>++;
                         insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                        <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                         <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                     } catch(java.lang.Exception e) {
                         whetherReject_<%=cid%> = true;
@@ -871,6 +873,7 @@ if(columnList != null && columnList.size() > 0) {
                 try {
                     nb_line_<%=cid%>++;
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -998,7 +1001,8 @@ if(columnList != null && columnList.size() > 0) {
             %>
             pstmt_<%=cid %>.addBatch();
             nb_line_<%=cid%>++;
-
+				
+				<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));%>
                 <%
                 if (useBatchSize && !("").equals(batchSize) && !("0").equals(batchSize)) {
@@ -1013,6 +1017,7 @@ if(columnList != null && columnList.size() > 0) {
             try {
                 nb_line_<%=cid%>++;
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -1171,6 +1176,7 @@ if(columnList != null && columnList.size() > 0) {
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -1242,6 +1248,7 @@ if(columnList != null && columnList.size() > 0) {
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -1415,9 +1422,11 @@ if(columnList != null && columnList.size() > 0) {
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 }else{
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
              }
                 } catch(java.lang.Exception e) {
@@ -1502,6 +1511,8 @@ if(columnList != null && columnList.size() > 0) {
             %>
             pstmt_<%=cid %>.addBatch();
             nb_line_<%=cid%>++;
+            	
+            	<%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));%>
                 <%
                 if (useBatchSize && !("").equals(batchSize) && !("0").equals(batchSize)) {
@@ -1516,6 +1527,7 @@ if(columnList != null && columnList.size() > 0) {
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -1677,6 +1689,7 @@ if(columnList != null && columnList.size() > 0) {
             int count_on_duplicate_key_<%=cid%> = 0;
             try {
                 count_on_duplicate_key_<%=cid%> = pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insertIgnore_"+cid+"");%>
                 <%dbLog.data().insertingOnDuplicateKeyUpdating(null);%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -1747,6 +1760,7 @@ if(columnList != null && columnList.size() > 0) {
                 try {
                     nb_line_<%=cid%>++;
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().insertingIgnore(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tNetezzaOutput/tNetezzaOutput_main.javajet

@@ -293,12 +293,12 @@ skeleton="../templates/db_output_bulk.skeleton"
                 }
             }
             %>
-            int checkCount_<%=cid%> = -1;
-            try (java.sql.ResultSet rs_<%=cid%> = pstmt_<%=cid %>.executeQuery()) {
-                while(rs_<%=cid%>.next()) {
-                    checkCount_<%=cid%> = rs_<%=cid%>.getInt(1);
-                }
-            }
+            int checkCount_<%=cid%> = -1;
+            try (java.sql.ResultSet rs_<%=cid%> = pstmt_<%=cid %>.executeQuery()) {
+                while(rs_<%=cid%>.next()) {
+                    checkCount_<%=cid%> = rs_<%=cid%>.getInt(1);
+                }
+            }
             if(checkCount_<%=cid%> > 0)
             {
                 <%

main/plugins/org.talend.designer.components.localprovider/components/tOracleOutput/tOracleOutput_main.javajet

@@ -471,6 +471,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             %>
                 pstmt_<%=cid %>.addBatch();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%
                 dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
                 %>
@@ -481,6 +482,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     nb_line_<%=cid%>++;
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e_<%=cid%>) {
                     whetherReject_<%=cid%> = true;
@@ -611,6 +613,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             %>
                 pstmt_<%=cid %>.addBatch();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%
                 dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
                 %>
@@ -621,6 +624,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     nb_line_<%=cid%>++;
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e_<%=cid%>) {
                     whetherReject_<%=cid%> = true;
@@ -778,6 +782,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e_<%=cid%>) {
                     whetherReject_<%=cid%> = true;
@@ -857,6 +862,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e_<%=cid%>) {
                     whetherReject_<%=cid%> = true;
@@ -1041,9 +1047,11 @@ skeleton="../templates/db_output_bulk.skeleton"
                     %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 }else{
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 }
             } catch(java.lang.Exception e_<%=cid%>) {
@@ -1122,6 +1130,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             %>
                 pstmt_<%=cid %>.addBatch();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%
                 dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
                 %>
@@ -1132,6 +1141,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                     <%dbLog.data().deleting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e_<%=cid%>) {
                     whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tPostgresPlusOutput/tPostgresPlusOutput_main.javajet

@@ -153,6 +153,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        pstmt_<%=cid %>.addBatch();
                        batchSizeCounter_<%=cid%>++;
                        nb_line_<%=cid%>++;
+                       <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                        <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                     <%
                }else{
@@ -160,6 +161,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        try {
                            insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                            nb_line_<%=cid%>++;
+                           <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                            <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                        } catch(java.lang.Exception e) {
                            whetherReject_<%=cid%> = true;
@@ -257,6 +259,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        pstmt_<%=cid %>.addBatch();
                        batchSizeCounter_<%=cid%>++;
                        nb_line_<%=cid%>++;
+                       <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                        <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                     <%
               }else{
@@ -264,6 +267,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        try {
                            updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                            nb_line_<%=cid%>++;
+                           <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                            <%dbLog.data().updating(dbLog.var("nb_line"));%>
                        } catch(java.lang.Exception e) {
                            whetherReject_<%=cid%> = true;
@@ -383,6 +387,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -444,6 +449,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
 					<%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -570,9 +576,11 @@ skeleton="../templates/db_output_bulk.skeleton"
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
              }else{
              	   nb_line_<%=cid%>++;
+             	   <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
              	   <%dbLog.data().updating(dbLog.var("nb_line"));%>
              }
                 } catch(java.lang.Exception e) {
@@ -653,6 +661,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        pstmt_<%=cid %>.addBatch();
                        batchSizeCounter_<%=cid%>++;
                        nb_line_<%=cid%>++;
+                       <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                        <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                     <%
               }else{
@@ -660,6 +669,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        try {
                            deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                            nb_line_<%=cid%>++;
+                           <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                            <%dbLog.data().deleting(dbLog.var("nb_line"));%>
                        } catch(java.lang.Exception e) {
                            whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tPostgresqlOutput/tPostgresqlOutput_main.javajet

@@ -428,6 +428,7 @@ skeleton="../templates/db_output_bulk.skeleton"
     		%>
     		pstmt_<%=cid %>.addBatch();
     		nb_line_<%=cid%>++;
+    		  <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
     		  <%
     		  dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
     		  %>
@@ -441,6 +442,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 	sp_<%=cid %> = conn_<%=cid%>.setSavepoint();
 				<%}%>
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
 				<%if(showSavePoint){%>
 	                conn_<%=cid%>.releaseSavepoint(sp_<%=cid %>);
@@ -574,6 +576,7 @@ skeleton="../templates/db_output_bulk.skeleton"
     		%>
     		pstmt_<%=cid %>.addBatch();
     		nb_line_<%=cid%>++;
+    		  <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     		  <%
     		  dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
     		  %>
@@ -587,6 +590,7 @@ skeleton="../templates/db_output_bulk.skeleton"
 	                sp_<%=cid %> = conn_<%=cid%>.setSavepoint();
 	            <%}%>
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
 				<%if(showSavePoint){%>
                 	conn_<%=cid%>.releaseSavepoint(sp_<%=cid %>);
@@ -745,6 +749,7 @@ skeleton="../templates/db_output_bulk.skeleton"
 	                <%}%>
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
 					<%if(showSavePoint){%>
     	                conn_<%=cid%>.releaseSavepoint(sp_<%=cid %>);
@@ -831,6 +836,7 @@ skeleton="../templates/db_output_bulk.skeleton"
 	                <%}%>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
 					<%if(showSavePoint){%>
     	                conn_<%=cid%>.releaseSavepoint(sp_<%=cid %>);
@@ -1026,12 +1032,14 @@ skeleton="../templates/db_output_bulk.skeleton"
 	                <%}%>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
 					<%if(showSavePoint){%>
     	                conn_<%=cid%>.releaseSavepoint(sp_<%=cid %>);
     	            <%}%>
     	            }else{
     					nb_line_<%=cid%>++;
+    					<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
      					<%dbLog.data().updating(dbLog.var("nb_line"));%>
     				}
                 } catch(java.lang.Exception e) {
@@ -1118,6 +1126,7 @@ skeleton="../templates/db_output_bulk.skeleton"
     		%>
     		pstmt_<%=cid %>.addBatch();
 			nb_line_<%=cid%>++;
+			  <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
     		  <%
     		  dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
     		  %>
@@ -1131,6 +1140,7 @@ skeleton="../templates/db_output_bulk.skeleton"
 				<%}%>
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
 				<%if(showSavePoint){%>
 	                conn_<%=cid%>.releaseSavepoint(sp_<%=cid %>);

main/plugins/org.talend.designer.components.localprovider/components/tS3Put/tS3Put_begin.javajet

@@ -36,11 +36,6 @@ imports="
 	String key_<%=cid%> = <%=key%>;
 	
 	int partSizeInBytes_<%=cid%> = <%=partSizeMb%> * 1024 * 1024;
-	if(partSizeInBytes_<%=cid%> < 5 << 20 ) {
-		log.info("Set part size as 5MB, as it is the recommended minimun value.");
-		partSizeInBytes_<%=cid%> = 5 << 20;
-	}
-	
 	
 	Object fileOrStream_<%=cid%> = <%=file%>;
 	

main/plugins/org.talend.designer.components.localprovider/components/tSQLDWHOutput/tSQLDWHOutput_main.javajet

@@ -563,6 +563,7 @@ if((cid.equals("talendLogs_DB") || cid.equals("talendStats_DB") || cid.equals("t
     		%>
         		pstmt_<%=cid %>.addBatch();
         		nb_line_<%=cid%>++;
+        		<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
     		 <%
     		 dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
     		 %>
@@ -580,6 +581,7 @@ if((cid.equals("talendLogs_DB") || cid.equals("talendStats_DB") || cid.equals("t
 %>
                 nb_line_<%=cid%>++;
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -808,6 +810,7 @@ if((cid.equals("talendLogs_DB") || cid.equals("talendStats_DB") || cid.equals("t
     		%>
     		pstmt_<%=cid %>.addBatch();
     		nb_line_<%=cid%>++;
+    		<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     		<%
     		dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
     		%>
@@ -825,6 +828,7 @@ if((cid.equals("talendLogs_DB") || cid.equals("talendStats_DB") || cid.equals("t
 %>
                 nb_line_<%=cid%>++;
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         	    <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -995,6 +999,7 @@ if((cid.equals("talendLogs_DB") || cid.equals("talendStats_DB") || cid.equals("t
 %>
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -1086,6 +1091,7 @@ if((cid.equals("talendLogs_DB") || cid.equals("talendStats_DB") || cid.equals("t
 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -1278,9 +1284,11 @@ if((cid.equals("talendLogs_DB") || cid.equals("talendStats_DB") || cid.equals("t
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
 					nb_line_<%=cid%>++;
+					<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
     			}else{
     				nb_line_<%=cid%>++;
+    				<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
     			}
                 } catch(java.lang.Exception e) {
@@ -1368,6 +1376,7 @@ if((cid.equals("talendLogs_DB") || cid.equals("talendStats_DB") || cid.equals("t
     		%>
     		pstmt_<%=cid %>.addBatch();
     		nb_line_<%=cid%>++;
+    		<%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
 			<%
 			dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
     		%>
@@ -1385,6 +1394,7 @@ if((cid.equals("talendLogs_DB") || cid.equals("talendStats_DB") || cid.equals("t
 %>
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -1503,6 +1513,7 @@ if((cid.equals("talendLogs_DB") || cid.equals("talendStats_DB") || cid.equals("t
 %>
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
 				whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tSQLiteOutput/tSQLiteOutput_main.javajet

@@ -153,6 +153,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        pstmt_<%=cid %>.addBatch();
                        batchSizeCounter_<%=cid%>++;
                        nb_line_<%=cid%>++;
+                       <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                        <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                     <%
                }else{
@@ -160,6 +161,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        try {
                            insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                            nb_line_<%=cid%>++;
+                           <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                            <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                        } catch(java.lang.Exception e) {
                            whetherReject_<%=cid%> = true;
@@ -255,6 +257,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                        pstmt_<%=cid %>.addBatch();
                        batchSizeCounter_<%=cid%>++;
                        nb_line_<%=cid%>++;
+                       <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                        <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                     <%
                }else{
@@ -262,6 +265,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                         try {
                             updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                             nb_line_<%=cid%>++;
+                            <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                             <%dbLog.data().updating(dbLog.var("nb_line"));%>
                         } catch(java.lang.Exception e) {
                             whetherReject_<%=cid%> = true;
@@ -380,6 +384,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -441,6 +446,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -599,6 +605,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -636,6 +643,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 }
             }else{
             	nb_line_<%=cid%>++;
+            	<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
 				<%dbLog.data().updating(dbLog.var("nb_line"));%>
             }
             <%
@@ -682,6 +690,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                      pstmt_<%=cid %>.addBatch();
                      batchSizeCounter_<%=cid%>++;
                      nb_line_<%=cid%>++;
+                     <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                      <% dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction)); %>
                   <%
               }else{
@@ -689,6 +698,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                       try {
                           deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                           nb_line_<%=cid%>++;
+                          <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                           <%dbLog.data().deleting(dbLog.var("nb_line"));%>
                       } catch(java.lang.Exception e) {
                           whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tSasOutput/tSasOutput_main.javajet

@@ -112,6 +112,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
             	<%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -185,6 +186,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         	    <%dbLog.data().updating(dbLog.var("nb_line"));%>                
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -276,6 +278,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -337,6 +340,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -419,6 +423,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 updateFlag_<%=cid%> = pstmtUpdate_<%=cid %>.executeUpdate();
                 if(updateFlag_<%=cid%> != 0) {
             		nb_line_<%=cid%>++;
+            		<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 }
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + updateFlag_<%=cid%>;
@@ -484,6 +489,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 	<%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -546,6 +552,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tSybaseOutput/tSybaseOutput_main.javajet

@@ -306,6 +306,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             %>
                 pstmt_<%=cid %>.addBatch();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
               <%
               dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
               %>
@@ -316,6 +317,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 nb_line_<%=cid%>++;
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -439,6 +441,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             %>
             pstmt_<%=cid %>.addBatch();
             nb_line_<%=cid%>++;
+           	  <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
               <%
               dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
               %>
@@ -449,6 +452,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 nb_line_<%=cid%>++;
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -600,6 +604,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -675,6 +680,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -846,9 +852,11 @@ skeleton="../templates/db_output_bulk.skeleton"
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 }else{
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 }
                 } catch(java.lang.Exception e) {
@@ -929,9 +937,10 @@ skeleton="../templates/db_output_bulk.skeleton"
             %>
                     pstmt_<%=cid %>.addBatch();
                     nb_line_<%=cid%>++;
-                <%
-                dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
-                %>
+                    <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
+	                <%
+	                dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
+	                %>
                     batchSizeCounter_<%=cid%>++;
                 <%
             }else {
@@ -939,6 +948,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tTeradataOutput/tTeradataOutput_main.javajet

@@ -316,6 +316,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 pstmt_<%=cid %>.addBatch();
                 batchSizeCounter_<%=cid%>++;
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
             <%
               dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
             }else {
@@ -324,6 +325,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 nb_line_<%=cid%>++;
                 insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                 <%dbLog.data().inserting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e_<%=cid%>) {
                 whetherReject_<%=cid%> = true;
@@ -446,6 +448,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 pstmt_<%=cid %>.addBatch();
                 batchSizeCounter_<%=cid%>++;
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%
                 dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
             }else {
@@ -454,6 +457,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 nb_line_<%=cid%>++;
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e_<%=cid%>) {
                 whetherReject_<%=cid%> = true;
@@ -604,6 +608,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e_<%=cid%>) {
                     whetherReject_<%=cid%> = true;
@@ -679,6 +684,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e_<%=cid%>) {
                     whetherReject_<%=cid%> = true;
@@ -851,9 +857,11 @@ skeleton="../templates/db_output_bulk.skeleton"
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
              }else{
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
              }
                 } catch(java.lang.Exception e_<%=cid%>) {
@@ -932,6 +940,7 @@ skeleton="../templates/db_output_bulk.skeleton"
               pstmt_<%=cid %>.addBatch();
               batchSizeCounter_<%=cid%>++;
               nb_line_<%=cid%>++;
+              <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
             <%
               dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
             }else {
@@ -940,6 +949,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
               deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
               nb_line_<%=cid%>++;
+              <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
               <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e_<%=cid%>) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tVectorWiseOutput/tVectorWiseOutput_main.javajet

@@ -148,6 +148,7 @@ skeleton="../templates/db_output_bulk.skeleton"
 	  		%>
         		pstmt_<%=cid %>.addBatch();
         		nb_line_<%=cid%>++;
+        		<%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
 		  		<%
 		  		dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
 		  		%>
@@ -158,6 +159,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -249,6 +251,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -366,6 +369,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
         			<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -427,6 +431,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -526,6 +531,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + updateFlag_<%=cid%>;
                 if(updateFlag_<%=cid%> != 0){
             		nb_line_<%=cid%>++;
+            		<%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
     				<%dbLog.data().updating(dbLog.var("nb_line"));%>
                 }
             } catch(java.lang.Exception e) {
@@ -590,6 +596,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -668,6 +675,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;

main/plugins/org.talend.designer.components.localprovider/components/tVerticaOutput/tVerticaOutput_main.javajet

@@ -575,6 +575,7 @@ skeleton="../templates/db_output_bulk.skeleton"
 %>
             pstmt_<%=cid %>.addBatch();
             nb_line_<%=cid%>++;
+            <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
 <%
                 dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
 %>
@@ -585,6 +586,7 @@ skeleton="../templates/db_output_bulk.skeleton"
         try {
             insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
             nb_line_<%=cid%>++;
+            <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
             <%dbLog.data().inserting(dbLog.var("nb_line"));%>
         } catch(java.lang.Exception e) {
             whetherReject_<%=cid%> = true;
@@ -714,6 +716,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             %>
             pstmt_<%=cid %>.addBatch();
             nb_line_<%=cid%>++;
+            <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
             <%
                 dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
             %>
@@ -724,6 +727,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                 <%dbLog.data().updating(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;
@@ -878,6 +882,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmtUpdate_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -955,6 +960,7 @@ skeleton="../templates/db_output_bulk.skeleton"
                 try {
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 } catch(java.lang.Exception e) {
                     whetherReject_<%=cid%> = true;
@@ -1133,9 +1139,11 @@ skeleton="../templates/db_output_bulk.skeleton"
                 %>
                     insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmtInsert_<%=cid %>.executeUpdate();
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("insert_"+cid+"");%>
                     <%dbLog.data().inserting(dbLog.var("nb_line"));%>
                 }else{
                     nb_line_<%=cid%>++;
+                    <%dbLog.data().sqlExecuteTry("update_"+cid+"");%>
                     <%dbLog.data().updating(dbLog.var("nb_line"));%>
                 }
                 } catch(java.lang.Exception e) {
@@ -1215,6 +1223,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             %>
             pstmt_<%=cid %>.addBatch();
             nb_line_<%=cid%>++;
+            <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
             <%
             dbLog.data().addingToBatch(dbLog.var("nb_line"), dbLog.str(dataAction));
             %>
@@ -1225,6 +1234,7 @@ skeleton="../templates/db_output_bulk.skeleton"
             try {
                 deletedCount_<%=cid%> = deletedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
                 nb_line_<%=cid%>++;
+                <%dbLog.data().sqlExecuteTry("delete_"+cid+"");%>
                 <%dbLog.data().deleting(dbLog.var("nb_line"));%>
             } catch(java.lang.Exception e) {
                 whetherReject_<%=cid%> = true;