Mercurial > dive4elements > river
comparison flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java @ 2840:71175502d868
Added a parser for sediment yield files; started parsing and store values in db.
flys-backend/trunk@4277 c6561f87-3c4e-4783-a992-168aeb5c3f6f
| author | Ingo Weinzierl <ingo.weinzierl@intevation.de> |
|---|---|
| date | Thu, 19 Apr 2012 12:48:53 +0000 |
| parents | 163c037f2c7e |
| children | c4db0f75a94a |
comparison
equal
deleted
inserted
replaced
| 2839:163c037f2c7e | 2840:71175502d868 |
|---|---|
| 32 import de.intevation.flys.importer.parsers.MorphologicalWidthParser; | 32 import de.intevation.flys.importer.parsers.MorphologicalWidthParser; |
| 33 import de.intevation.flys.importer.parsers.AnnotationsParser; | 33 import de.intevation.flys.importer.parsers.AnnotationsParser; |
| 34 import de.intevation.flys.importer.parsers.AnnotationClassifier; | 34 import de.intevation.flys.importer.parsers.AnnotationClassifier; |
| 35 import de.intevation.flys.importer.parsers.PegelGltParser; | 35 import de.intevation.flys.importer.parsers.PegelGltParser; |
| 36 import de.intevation.flys.importer.parsers.SedimentDensityParser; | 36 import de.intevation.flys.importer.parsers.SedimentDensityParser; |
| 37 import de.intevation.flys.importer.parsers.SedimentYieldParser; | |
| 37 import de.intevation.flys.importer.parsers.WstParser; | 38 import de.intevation.flys.importer.parsers.WstParser; |
| 38 | 39 |
| 39 import org.hibernate.Session; | 40 import org.hibernate.Session; |
| 40 import org.hibernate.Query; | 41 import org.hibernate.Query; |
| 41 import org.hibernate.exception.ConstraintViolationException; | 42 import org.hibernate.exception.ConstraintViolationException; |
| 408 File epochDir = new File(sedimentYieldDir, SEDIMENT_YIELD_EPOCH_DIR); | 409 File epochDir = new File(sedimentYieldDir, SEDIMENT_YIELD_EPOCH_DIR); |
| 409 | 410 |
| 410 File[] singles = singleDir.listFiles(); | 411 File[] singles = singleDir.listFiles(); |
| 411 File[] epochs = epochDir.listFiles(); | 412 File[] epochs = epochDir.listFiles(); |
| 412 | 413 |
| 414 SedimentYieldParser parser = new SedimentYieldParser(); | |
| 415 | |
| 413 if (singles == null || singles.length == 0) { | 416 if (singles == null || singles.length == 0) { |
| 414 log.warn("Cannot parse directory '" + singleDir + "'"); | 417 log.warn("Cannot parse directory '" + singleDir + "'"); |
| 415 } | 418 } |
| 416 else { | 419 else { |
| 417 // TODO | 420 for (File file: singles) { |
| 421 if (file.isDirectory()) { | |
| 422 for (File child: file.listFiles()) { | |
| 423 parser.parse(child); | |
| 424 } | |
| 425 } | |
| 426 else { | |
| 427 parser.parse(file); | |
| 428 } | |
| 429 } | |
| 418 } | 430 } |
| 419 | 431 |
| 420 if (epochs == null || epochs.length == 0) { | 432 if (epochs == null || epochs.length == 0) { |
| 421 log.warn("Cannot parse directory '" + epochDir + "'"); | 433 log.warn("Cannot parse directory '" + epochDir + "'"); |
| 422 } | 434 } |
| 423 else { | 435 else { |
| 424 // TODO | 436 for (File file: epochs) { |
| 425 } | 437 if (file.isDirectory()) { |
| 438 for (File child: file.listFiles()) { | |
| 439 parser.parse(child); | |
| 440 } | |
| 441 } | |
| 442 else { | |
| 443 parser.parse(file); | |
| 444 } | |
| 445 } | |
| 446 } | |
| 447 | |
| 448 sedimentYields = parser.getSedimentYields(); | |
| 426 } | 449 } |
| 427 | 450 |
| 428 | 451 |
| 429 protected void parseBedHeightSingles(File dir) throws IOException { | 452 protected void parseBedHeightSingles(File dir) throws IOException { |
| 430 log.debug("Parse bed height singles"); | 453 log.debug("Parse bed height singles"); |