1 files changed, 26 insertions, 0 deletions
diff --git a/plugins/org.eclipse.net4j.db/src/org/eclipse/net4j/db/DBUtil.java b/plugins/org.eclipse.net4j.db/src/org/eclipse/net4j/db/DBUtil.java
index f799a4a029..9e3f5bb84e 100644
--- a/plugins/org.eclipse.net4j.db/src/org/eclipse/net4j/db/DBUtil.java
+++ b/plugins/org.eclipse.net4j.db/src/org/eclipse/net4j/db/DBUtil.java
@@ -11,11 +11,13 @@
 package org.eclipse.net4j.db;
 
 import org.eclipse.net4j.internal.db.DBSchema;
+import org.eclipse.net4j.internal.db.DBTransaction;
 import org.eclipse.net4j.internal.db.bundle.OM;
 import org.eclipse.net4j.util.ReflectUtil;
 
 import javax.sql.DataSource;
 
+import java.sql.Connection;
 import java.util.Map;
 
 /**
@@ -58,4 +60,28 @@ public final class DBUtil
   {
     return IDBAdapter.REGISTRY.get(adapterName);
   }
+
+  public static IDBTransaction createTransaction(DataSource dataSource)
+  {
+    try
+    {
+      return createTransaction(dataSource.getConnection());
+    }
+    catch (Exception ex)
+    {
+      throw new DBException(ex);
+    }
+  }
+
+  public static IDBTransaction createTransaction(Connection connection)
+  {
+    try
+    {
+      return new DBTransaction(connection);
+    }
+    catch (Exception ex)
+    {
+      throw new DBException(ex);
+    }
+  }
 }