aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/async/SqlEffectExecutor.java
diff options
context:
space:
mode:
authorTrygve Laugstøl <trygvis@inamo.no>2013-06-18 02:01:07 +0200
committerTrygve Laugstøl <trygvis@inamo.no>2013-06-18 02:01:07 +0200
commit72ae5827aa7bc2b7eba49da1491c7d32d254209a (patch)
tree5f4d3cce48c5bfceaab87bffd27639cb24a1a608 /src/main/java/io/trygvis/async/SqlEffectExecutor.java
parent6ab5741f811a4a2f6b5672811899f19a726786ec (diff)
downloadquartz-based-queue-72ae5827aa7bc2b7eba49da1491c7d32d254209a.tar.gz
quartz-based-queue-72ae5827aa7bc2b7eba49da1491c7d32d254209a.tar.bz2
quartz-based-queue-72ae5827aa7bc2b7eba49da1491c7d32d254209a.tar.xz
quartz-based-queue-72ae5827aa7bc2b7eba49da1491c7d32d254209a.zip
wip
Diffstat (limited to 'src/main/java/io/trygvis/async/SqlEffectExecutor.java')
-rw-r--r--src/main/java/io/trygvis/async/SqlEffectExecutor.java52
1 files changed, 0 insertions, 52 deletions
diff --git a/src/main/java/io/trygvis/async/SqlEffectExecutor.java b/src/main/java/io/trygvis/async/SqlEffectExecutor.java
deleted file mode 100644
index 3da2cd3..0000000
--- a/src/main/java/io/trygvis/async/SqlEffectExecutor.java
+++ /dev/null
@@ -1,52 +0,0 @@
-package io.trygvis.async;
-
-import javax.sql.DataSource;
-import java.sql.Connection;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
-
-public class SqlEffectExecutor {
-
- private final DataSource dataSource;
-
- public SqlEffectExecutor(DataSource dataSource) {
- this.dataSource = dataSource;
- }
-
- public <A> A transaction(SqlEffect<A> effect) throws SQLException {
-// int pid;
-
- try (Connection c = dataSource.getConnection()) {
-// pid = getPid(c);
-// System.out.println("pid = " + pid);
-
- boolean ok = false;
- try {
- A a = effect.doInConnection(c);
- c.commit();
- ok = true;
- return a;
- } finally {
-// System.out.println("Closing, pid = " + pid);
- if (!ok) {
- try {
- c.rollback();
- } catch (SQLException e) {
- // ignore
- }
- }
- }
- }
- }
-
- public void transaction(final SqlEffect.Void effect) throws SQLException {
- transaction(new SqlEffect<Object>() {
- @Override
- public Object doInConnection(Connection c) throws SQLException {
- effect.doInConnection(c);
- return null;
- }
- });
- }
-}