Mercurial > dive4elements > river
comparison flys-artifacts/src/main/java/de/intevation/flys/artifacts/datacage/Datacage.java @ 1006:1917f32701dc
Forwarded kill collections and artifacts events to datacage.
flys-artifacts/trunk@2447 c6561f87-3c4e-4783-a992-168aeb5c3f6f
| author | Sascha L. Teichmann <sascha.teichmann@intevation.de> |
|---|---|
| date | Tue, 02 Aug 2011 11:38:20 +0000 |
| parents | 0e8c03b69627 |
| children | ed918497873b |
comparison
equal
deleted
inserted
replaced
| 1005:52949da92f7a | 1006:1917f32701dc |
|---|---|
| 75 "delete.artifact.data.by.artifact.id"; | 75 "delete.artifact.data.by.artifact.id"; |
| 76 private String SQL_DELETE_OUTS_BY_ARTIFACT_ID = | 76 private String SQL_DELETE_OUTS_BY_ARTIFACT_ID = |
| 77 "delete.outs.by.artifact.id"; | 77 "delete.outs.by.artifact.id"; |
| 78 private String SQL_DELETE_FACETS_BY_ARTIFACT_ID = | 78 private String SQL_DELETE_FACETS_BY_ARTIFACT_ID = |
| 79 "delete.facets.by.artifacts.id"; | 79 "delete.facets.by.artifacts.id"; |
| 80 private String SQL_DELETE_ARTIFACT_BY_GID = | |
| 81 "delete.artifact.by.gid"; | |
| 80 | 82 |
| 81 protected SQLExecutor sqlExecutor; | 83 protected SQLExecutor sqlExecutor; |
| 82 | 84 |
| 83 public class InitialScan | 85 public class InitialScan |
| 84 implements ArtifactDatabase.ArtifactLoadedCallback | 86 implements ArtifactDatabase.ArtifactLoadedCallback |
| 370 sql.get(SQL_DELETE_ARTIFACT_DATA_BY_ARTIFACT_ID); | 372 sql.get(SQL_DELETE_ARTIFACT_DATA_BY_ARTIFACT_ID); |
| 371 SQL_DELETE_OUTS_BY_ARTIFACT_ID = | 373 SQL_DELETE_OUTS_BY_ARTIFACT_ID = |
| 372 sql.get(SQL_DELETE_OUTS_BY_ARTIFACT_ID); | 374 sql.get(SQL_DELETE_OUTS_BY_ARTIFACT_ID); |
| 373 SQL_DELETE_FACETS_BY_ARTIFACT_ID = | 375 SQL_DELETE_FACETS_BY_ARTIFACT_ID = |
| 374 sql.get(SQL_DELETE_FACETS_BY_ARTIFACT_ID); | 376 sql.get(SQL_DELETE_FACETS_BY_ARTIFACT_ID); |
| 377 SQL_DELETE_ARTIFACT_BY_GID = | |
| 378 sql.get(SQL_DELETE_ARTIFACT_BY_GID); | |
| 375 } | 379 } |
| 376 | 380 |
| 377 protected static final int numFacets(List<Output> outs) { | 381 protected static final int numFacets(List<Output> outs) { |
| 378 int sum = 0; | 382 int sum = 0; |
| 379 for (Output out: outs) { | 383 for (Output out: outs) { |
| 991 | 995 |
| 992 if (!exec.runWrite()) { | 996 if (!exec.runWrite()) { |
| 993 log.error("storing facets failed"); | 997 log.error("storing facets failed"); |
| 994 } | 998 } |
| 995 } | 999 } |
| 1000 | |
| 1001 public void killedCollections( | |
| 1002 final List<String> identifiers, | |
| 1003 GlobalContext context | |
| 1004 ) { | |
| 1005 log.debug("killedCollections"); | |
| 1006 | |
| 1007 SQLExecutor.Instance exec = sqlExecutor.new Instance() { | |
| 1008 @Override | |
| 1009 public boolean doIt() throws SQLException { | |
| 1010 prepareStatement(SQL_DELETE_COLLECTION_BY_GID); | |
| 1011 for (String identifier: identifiers) { | |
| 1012 stmnt.setString(1, identifier); | |
| 1013 stmnt.execute(); | |
| 1014 } | |
| 1015 conn.commit(); | |
| 1016 return true; | |
| 1017 } | |
| 1018 }; | |
| 1019 | |
| 1020 if (!exec.runWrite()) { | |
| 1021 log.error("killing collections failed"); | |
| 1022 } | |
| 1023 } | |
| 1024 | |
| 1025 public void killedArtifacts( | |
| 1026 final List<String> identifiers, | |
| 1027 GlobalContext context | |
| 1028 ) { | |
| 1029 log.debug("killedArtifacts"); | |
| 1030 | |
| 1031 SQLExecutor.Instance exec = sqlExecutor.new Instance() { | |
| 1032 @Override | |
| 1033 public boolean doIt() throws SQLException { | |
| 1034 prepareStatement(SQL_DELETE_ARTIFACT_BY_GID); | |
| 1035 for (String identifier: identifiers) { | |
| 1036 stmnt.setString(1, identifier); | |
| 1037 stmnt.execute(); | |
| 1038 } | |
| 1039 conn.commit(); | |
| 1040 return true; | |
| 1041 } | |
| 1042 }; | |
| 1043 | |
| 1044 if (!exec.runWrite()) { | |
| 1045 log.error("killing artifacts failed"); | |
| 1046 } | |
| 1047 } | |
| 996 } | 1048 } |
| 997 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 : | 1049 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 : |