Mercurial > dive4elements > river

comparison flys-artifacts/src/main/java/de/intevation/flys/artifacts/datacage/Datacage.java @ 996:f61fe8b561d2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Datacage: delete artifacts at initial scan, too. Fixed problem with writing content of state data. flys-artifacts/trunk@2432 c6561f87-3c4e-4783-a992-168aeb5c3f6f
author Sascha L. Teichmann <sascha.teichmann@intevation.de>
date Sun, 31 Jul 2011 19:47:41 +0000
parents e0df86bc6d31
children b0218f21c664
comparison
equal deleted inserted replaced
995:e0df86bc6d31 996:f61fe8b561d2
38 38
39 public static final String ARTEFACT_DATABASE_KEY = 39 public static final String ARTEFACT_DATABASE_KEY =
40 "global.artifact.database"; 40 "global.artifact.database";
41 41
42 private String SQL_DELETE_ALL_USERS = "delete.all.users"; 42 private String SQL_DELETE_ALL_USERS = "delete.all.users";
43 private String SQL_DELETE_ALL_ARTIFACTS = "delete.all.artifacts";
43 private String SQL_USER_ID_NEXTVAL = "user.id.nextval"; 44 private String SQL_USER_ID_NEXTVAL = "user.id.nextval";
44 private String SQL_USER_BY_GID = "user.by.gid"; 45 private String SQL_USER_BY_GID = "user.by.gid";
45 private String SQL_INSERT_USER = "insert.user"; 46 private String SQL_INSERT_USER = "insert.user";
46 private String SQL_COLLECTION_BY_GID = "collection.by.gid"; 47 private String SQL_COLLECTION_BY_GID = "collection.by.gid";
47 private String SQL_COLLECTION_ID_NEXTVAL = "collection.id.nextval"; 48 private String SQL_COLLECTION_ID_NEXTVAL = "collection.id.nextval";
315 // XXX: Where come the nulls from? 316 // XXX: Where come the nulls from?
316 String type = sd.getType(); 317 String type = sd.getType();
317 if (type == null) type = "String"; 318 if (type == null) type = "String";
318 stmnt.setString(3, type); 319 stmnt.setString(3, type);
319 stmnt.setString(4, sd.getName()); 320 stmnt.setString(4, sd.getName());
320 setString(stmnt, 5, sd); 321 setString(stmnt, 5, sd.getValue());
321 stmnt.execute(); 322 stmnt.execute();
322 } 323 }
323 324
324 conn.commit(); 325 conn.commit();
325 return true; 326 return true;
464 sqlExecutor = new SQLExecutor(config.getDBConnection()); 465 sqlExecutor = new SQLExecutor(config.getDBConnection());
465 } 466 }
466 467
467 protected void setupSQL(SQL sql) { 468 protected void setupSQL(SQL sql) {
468 SQL_DELETE_ALL_USERS = sql.get(SQL_DELETE_ALL_USERS); 469 SQL_DELETE_ALL_USERS = sql.get(SQL_DELETE_ALL_USERS);
470 SQL_DELETE_ALL_ARTIFACTS = sql.get(SQL_DELETE_ALL_ARTIFACTS);
469 SQL_USER_ID_NEXTVAL = sql.get(SQL_USER_ID_NEXTVAL); 471 SQL_USER_ID_NEXTVAL = sql.get(SQL_USER_ID_NEXTVAL);
470 SQL_USER_BY_GID = sql.get(SQL_USER_BY_GID); 472 SQL_USER_BY_GID = sql.get(SQL_USER_BY_GID);
471 SQL_INSERT_USER = sql.get(SQL_INSERT_USER); 473 SQL_INSERT_USER = sql.get(SQL_INSERT_USER);
472 SQL_COLLECTION_BY_GID = sql.get(SQL_COLLECTION_BY_GID); 474 SQL_COLLECTION_BY_GID = sql.get(SQL_COLLECTION_BY_GID);
473 SQL_COLLECTION_ID_NEXTVAL = sql.get(SQL_COLLECTION_ID_NEXTVAL); 475 SQL_COLLECTION_ID_NEXTVAL = sql.get(SQL_COLLECTION_ID_NEXTVAL);
548 log.debug("cleanDatabase"); 550 log.debug("cleanDatabase");
549 551
550 boolean success = sqlExecutor.new Instance() { 552 boolean success = sqlExecutor.new Instance() {
551 @Override 553 @Override
552 public boolean doIt() throws SQLException { 554 public boolean doIt() throws SQLException {
553 log.debug("doIt");
554 prepareStatement(SQL_DELETE_ALL_USERS); 555 prepareStatement(SQL_DELETE_ALL_USERS);
555 log.debug("prepareStatement");
556 stmnt.execute(); 556 stmnt.execute();
557 log.debug("execute"); 557 prepareStatement(SQL_DELETE_ALL_ARTIFACTS);
558 stmnt.execute();
558 conn.commit(); 559 conn.commit();
559 log.debug("commit");
560 return true; 560 return true;
561 } 561 }
562 }.runWrite(); 562 }.runWrite();
563 563
564 log.debug("after runWrite(): " + success); 564 log.debug("after runWrite(): " + success);
http://dive4elements.wald.intevation.org