Mercurial > dive4elements > framework
annotate artifact-database/src/main/java/org/dive4elements/artifactdatabase/db/SQLExecutor.java @ 541:3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
author | Sascha L. Teichmann <teichmann@intevation.de> |
---|---|
date | Thu, 03 Sep 2015 15:34:07 +0200 |
parents | 91b1435fb9ea |
children | 0e3ecf7cd461 |
rev | line source |
---|---|
475
415df0fc4fa1
Fixed maven group ids
Sascha L. Teichmann <teichmann@intevation.de>
parents:
473
diff
changeset
|
1 package org.dive4elements.artifactdatabase.db; |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
2 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
3 import java.sql.Connection; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
4 import java.sql.PreparedStatement; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
5 import java.sql.ResultSet; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
6 import java.sql.SQLException; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
7 |
540
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
8 import java.util.concurrent.locks.ReentrantReadWriteLock; |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
9 |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
10 import javax.sql.DataSource; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
11 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
12 import org.apache.log4j.Logger; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
13 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
14 public class SQLExecutor |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
15 { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
16 private static Logger logger = Logger.getLogger(SQLExecutor.class); |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
17 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
18 public class Instance { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
19 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
20 public Connection conn; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
21 public PreparedStatement stmnt; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
22 public ResultSet result; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
23 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
24 public Instance() { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
25 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
26 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
27 public void reset() throws SQLException { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
28 if (result != null) { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
29 result.close(); |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
30 result = null; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
31 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
32 if (stmnt != null) { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
33 result = null; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
34 stmnt.close(); |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
35 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
36 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
37 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
38 public PreparedStatement prepareStatement(String query) |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
39 throws SQLException { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
40 return stmnt = conn.prepareStatement(query); |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
41 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
42 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
43 public void close() { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
44 if (result != null) { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
45 try { result.close(); } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
46 catch (SQLException sqle) {} |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
47 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
48 if (stmnt != null) { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
49 try { stmnt.close(); } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
50 catch (SQLException sqle) {} |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
51 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
52 if (conn != null) { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
53 try { conn.close(); } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
54 catch (SQLException sqle) {} |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
55 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
56 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
57 |
541
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
58 public boolean runWriteNoRollback() { |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
59 rwLock.writeLock().lock(); |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
60 try { |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
61 DataSource dataSource = dbConnection.getDataSource(); |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
62 try { |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
63 conn = dataSource.getConnection(); |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
64 try { |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
65 conn.setAutoCommit(false); |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
66 return doIt(); |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
67 } |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
68 catch (SQLException sqle) { |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
69 throw sqle; |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
70 } |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
71 } |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
72 catch (SQLException sqle) { |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
73 logger.error(sqle.getLocalizedMessage(), sqle); |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
74 } |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
75 finally { |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
76 close(); |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
77 } |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
78 return false; |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
79 } |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
80 finally { |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
81 rwLock.writeLock().unlock(); |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
82 } |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
83 } |
3b1e48d22ce0
Experimentally let database cleaner and backend share the same sql executor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
540
diff
changeset
|
84 |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
85 public boolean runWrite() { |
540
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
86 rwLock.writeLock().lock(); |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
87 try { |
540
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
88 DataSource dataSource = dbConnection.getDataSource(); |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
89 try { |
540
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
90 conn = dataSource.getConnection(); |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
91 try { |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
92 conn.setAutoCommit(false); |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
93 return doIt(); |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
94 } |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
95 catch (SQLException sqle) { |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
96 conn.rollback(); |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
97 throw sqle; |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
98 } |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
99 } |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
100 catch (SQLException sqle) { |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
101 logger.error(sqle.getLocalizedMessage(), sqle); |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
102 } |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
103 finally { |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
104 close(); |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
105 } |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
106 return false; |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
107 } |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
108 finally { |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
109 rwLock.writeLock().unlock(); |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
110 } |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
111 } |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
112 |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
113 public boolean runRead() { |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
114 rwLock.readLock().lock(); |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
115 try { |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
116 DataSource dataSource = dbConnection.getDataSource(); |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
117 try { |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
118 conn = dataSource.getConnection(); |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
119 return doIt(); |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
120 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
121 catch (SQLException sqle) { |
540
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
122 logger.error(sqle.getLocalizedMessage(), sqle); |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
123 } |
540
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
124 finally { |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
125 close(); |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
126 } |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
127 return false; |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
128 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
129 finally { |
540
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
130 rwLock.readLock().unlock(); |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
131 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
132 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
133 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
134 public boolean doIt() throws SQLException { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
135 return true; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
136 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
137 } // class Instance |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
138 |
540
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
139 protected DBConnection dbConnection; |
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
140 protected ReentrantReadWriteLock rwLock; |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
141 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
142 public SQLExecutor() { |
540
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
143 rwLock = new ReentrantReadWriteLock(); |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
144 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
145 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
146 public SQLExecutor(DBConnection dbConnection) { |
540
91b1435fb9ea
Added R/W lock to SQLExecutor.
Sascha L. Teichmann <teichmann@intevation.de>
parents:
475
diff
changeset
|
147 this(); |
305
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
148 this.dbConnection = dbConnection; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
149 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
150 |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
151 public DBConnection getDBConnection() { |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
152 return dbConnection; |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
153 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
154 } |
f33401ea2a6c
Artifact database: Refactorized the usage of dialect independent SQL to be reusable.
Sascha L. Teichmann <sascha.teichmann@intevation.de>
parents:
diff
changeset
|
155 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 : |