Mercurial > dive4elements > framework

comparison artifact-database/src/main/java/de/intevation/artifactdatabase/Backend.java @ 14:0d16d1bb2df0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Initial checkin of artigact persistents back by database. artifacts/trunk@29 c6561f87-3c4e-4783-a992-168aeb5c3f6f
author Sascha L. Teichmann <sascha.teichmann@intevation.de>
date Mon, 07 Sep 2009 08:41:05 +0000
parents 0d6badf6af42
children 9ad6ec2d09c3
comparison
equal deleted inserted replaced
13:0d6badf6af42 14:0d16d1bb2df0
1 package de.intevation.artifactdatabase; 1 package de.intevation.artifactdatabase;
2
3 import org.w3c.dom.Document;
4
5 import java.util.UUID;
6
7 import java.sql.Connection;
8 import java.sql.SQLException;
9 import java.sql.PreparedStatement;
10 import java.sql.Types;
11 import java.sql.ResultSet;
12
13 import javax.sql.DataSource;
14
15 import java.io.IOException;
16 import java.io.ByteArrayOutputStream;
17 import java.io.ObjectOutputStream;
18
19 import java.util.zip.GZIPOutputStream;
2 20
3 import de.intevation.artifacts.ArtifactFactory; 21 import de.intevation.artifacts.ArtifactFactory;
4 import de.intevation.artifacts.Artifact; 22 import de.intevation.artifacts.Artifact;
5 23
6 /** 24 /**
7 * @author Sascha L. Teichmann 25 * @author Sascha L. Teichmann
8 */ 26 */
9 public class Backend 27 public class Backend
10 { 28 {
29 public static final String SQL_NEXT_ID =
30 SQL.get("artifacts.id.nextval");
31
32 public static final String SQL_INSERT =
33 SQL.get("artifacts.insert");
34
35 public static final String SQL_UPDATE =
36 SQL.get("artifacts.update");
37
38 public static final String SQL_TOUCH =
39 SQL.get("artifacts.touch");
40
41 /**
42 * Used to wrap the calls to invole database actions.
43 */
44 public class ArtifactProxy
45 implements Artifact
46 {
47 protected Artifact original;
48 protected int id;
49 protected boolean unwritten;
50
51 public ArtifactProxy() {
52 }
53
54 public ArtifactProxy(Artifact original, int id, boolean unwritten) {
55 this.original = original;
56 this.id = id;
57 this.unwritten = unwritten;
58 }
59
60 public Artifact getOriginal() {
61 return original;
62 }
63
64 public int getId() {
65 return id;
66 }
67
68 public boolean isUnwritten() {
69 return unwritten;
70 }
71
72 public String identifier() {
73 return original.identifier();
74 }
75
76 public String hash() {
77 return original.hash();
78 }
79
80 public Document describe(Object context) {
81 try {
82 return original.describe(context);
83 }
84 finally {
85 touch(this);
86 }
87 }
88
89 public Document advance(Document target, Object context) {
90 try {
91 return original.advance(target, context);
92 }
93 finally {
94 store(this);
95 }
96 }
97
98 public Document feed(Document data, Object context) {
99 try {
100 return original.feed(data, context);
101 }
102 finally {
103 store(this);
104 }
105 }
106
107 public byte [] out(Document format, Object context) {
108 try {
109 return original.out(format, context);
110 }
111 finally {
112 touch(this);
113 }
114 }
115
116 public void setup(String identifier, Object context) {
117 original.setup(identifier, context);
118 }
119
120 public void endOfLife(Object context) {
121 original.endOfLife(context);
122 }
123
124 public byte [] toBytes() {
125 try {
126 ByteArrayOutputStream bos = new ByteArrayOutputStream();
127 GZIPOutputStream gos = new GZIPOutputStream(bos);
128 ObjectOutputStream oos = new ObjectOutputStream(gos);
129
130 oos.writeObject(original);
131 oos.flush();
132
133 return bos.toByteArray();
134 }
135 catch (IOException ioe) {
136 throw new RuntimeException(ioe);
137 }
138 }
139 } // class ArtifactProxy
140
11 public Backend() { 141 public Backend() {
12 } 142 }
13 143
14 public Artifact getArtifact(String idenitfier) { 144 public Artifact getArtifact(String idenitfier) {
15 return null; 145 return null;
16 } 146 }
17 147
18 public Artifact createArtifactWithFactory( 148 public Artifact createArtifactWithFactory(
19 ArtifactFactory factory, Object context 149 ArtifactFactory factory, Object context
20 ) { 150 ) {
21 return null; 151 UUID uuid = UUID.randomUUID();
22 } 152 Artifact artifact = factory.createArtifact(
153 uuid.toString(), context);
154
155 Long ttl = factory.timeToLiveUntouched(
156 artifact, context);
157
158 int id = insertDatabase(uuid, ttl);
159
160 return new ArtifactProxy(artifact, id, true);
161 }
162
163 protected int insertDatabase(UUID uuid, Long ttl) {
164 Connection connection = null;
165 PreparedStatement stmnt_next_id = null;
166 PreparedStatement stmnt_insert = null;
167 ResultSet res_id = null;
168
169 DataSource dataSource = DBConnection.getDataSource();
170 try {
171 connection = dataSource.getConnection();
172 try {
173 connection.setAutoCommit(false);
174
175 stmnt_next_id = connection.prepareStatement(SQL_NEXT_ID);
176 stmnt_insert = connection.prepareStatement(SQL_INSERT);
177
178 res_id = stmnt_next_id.executeQuery();
179
180 if (!res_id.next()) {
181 throw new RuntimeException("No id generated");
182 }
183
184 int id = res_id.getInt(1);
185
186 stmnt_insert.setInt(1, id);
187 stmnt_insert.setString(2, uuid.toString());
188 if (ttl == null) {
189 stmnt_insert.setNull(3, Types.BIGINT);
190 }
191 else {
192 stmnt_insert.setLong(3, ttl.longValue());
193 }
194
195 stmnt_insert.execute();
196
197 connection.commit();
198
199 return id;
200 }
201 catch (SQLException sqle) {
202 connection.rollback();
203 throw sqle;
204 }
205 }
206 catch (SQLException sqle) {
207 sqle.printStackTrace(System.err);
208 }
209 finally {
210 if (res_id != null) {
211 try { res_id.close(); }
212 catch (SQLException sqle) {}
213 }
214 if (stmnt_insert != null) {
215 try { stmnt_insert.close(); }
216 catch (SQLException sqle) {}
217 }
218 if (stmnt_next_id != null) {
219 try { stmnt_next_id.close(); }
220 catch (SQLException sqle) {}
221 }
222 if (connection != null) {
223 try { connection.close(); }
224 catch (SQLException sqle) {}
225 }
226 }
227 throw new RuntimeException("failed insert artifact into database");
228 }
229
230 public void touch(ArtifactProxy proxy) {
231 System.err.println("touch: " + proxy);
232 if (proxy.isUnwritten()) {
233 store(proxy);
234 return;
235 }
236 Connection connection = null;
237 PreparedStatement stmnt_touch = null;
238 DataSource dataSource = DBConnection.getDataSource();
239 try {
240 connection = dataSource.getConnection();
241 try {
242 connection.setAutoCommit(false);
243 stmnt_touch = connection.prepareStatement(SQL_UPDATE);
244 stmnt_touch.setInt(1, proxy.getId());
245 stmnt_touch.execute();
246 connection.commit();
247 }
248 catch (SQLException sqle) {
249 connection.rollback();
250 }
251 }
252 catch (SQLException sqle) {
253 sqle.printStackTrace(System.err);
254 }
255 finally {
256 if (stmnt_touch != null) {
257 try { stmnt_touch.close(); }
258 catch (SQLException sqle) {}
259 }
260 if (connection != null) {
261 try { connection.close(); }
262 catch (SQLException sqle) {}
263 }
264 }
265 }
266
267 public void store(ArtifactProxy proxy) {
268 System.err.println("store: " + proxy);
269 Connection connection = null;
270 PreparedStatement stmnt_update = null;
271 DataSource dataSource = DBConnection.getDataSource();
272 try {
273 connection = dataSource.getConnection();
274 try {
275 connection.setAutoCommit(false);
276 stmnt_update = connection.prepareStatement(SQL_UPDATE);
277 stmnt_update.setInt(1, proxy.getId());
278 stmnt_update.setBytes(2, proxy.toBytes());
279 stmnt_update.execute();
280 connection.commit();
281 }
282 catch (SQLException sqle) {
283 connection.rollback();
284 }
285 }
286 catch (SQLException sqle) {
287 sqle.printStackTrace(System.err);
288 }
289 finally {
290 if (stmnt_update != null) {
291 try { stmnt_update.close(); }
292 catch (SQLException sqle) {}
293 }
294 if (connection != null) {
295 try { connection.close(); }
296 catch (SQLException sqle) {}
297 }
298 }
299 }
300
23 } 301 }
24 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8: 302 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8:
http://dive4elements.wald.intevation.org