Mercurial > dive4elements > river
comparison flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java @ 2810:04eeb45df27b
Implemented model classes and importer classes for bed height epochs.
flys-backend/trunk@4222 c6561f87-3c4e-4783-a992-168aeb5c3f6f
| author | Ingo Weinzierl <ingo.weinzierl@intevation.de> |
|---|---|
| date | Thu, 12 Apr 2012 12:50:49 +0000 |
| parents | f283212966e8 |
| children | 8926571e47fb |
comparison
equal
deleted
inserted
replaced
| 2809:f283212966e8 | 2810:04eeb45df27b |
|---|---|
| 220 } | 220 } |
| 221 } | 221 } |
| 222 | 222 |
| 223 | 223 |
| 224 public void parseBedHeight() throws IOException { | 224 public void parseBedHeight() throws IOException { |
| 225 if (Config.INSTANCE.skipBedHeight()) { | |
| 226 log.info("skip parsing bed height."); | |
| 227 return; | |
| 228 } | |
| 229 | |
| 230 log.info("Parse bed height."); | 225 log.info("Parse bed height."); |
| 231 | 226 |
| 232 File minfoDir = getMinfoDir(); | 227 File minfoDir = getMinfoDir(); |
| 233 File bedHeightDir = new File(minfoDir, BED_HEIGHT_DIR); | 228 File bedHeightDir = new File(minfoDir, BED_HEIGHT_DIR); |
| 234 File singlesDir = new File(bedHeightDir, BED_HEIGHT_SINGLE_DIR); | 229 File singlesDir = new File(bedHeightDir, BED_HEIGHT_SINGLE_DIR); |
| 235 File epochDir = new File(bedHeightDir, BED_HEIGHT_EPOCH_DIR); | 230 File epochDir = new File(bedHeightDir, BED_HEIGHT_EPOCH_DIR); |
| 236 | 231 |
| 237 parseBedHeightSingles(singlesDir); | 232 if (Config.INSTANCE.skipBedHeightSingle()) { |
| 238 //parseBedHeightEpochs(epochDir); | 233 log.info("skip parsing bed height single."); |
| 234 } | |
| 235 else { | |
| 236 parseBedHeightSingles(singlesDir); | |
| 237 } | |
| 238 | |
| 239 if (Config.INSTANCE.skipBedHeightEpoch()) { | |
| 240 log.info("skip parsing bed height epochs."); | |
| 241 } | |
| 242 else { | |
| 243 parseBedHeightEpochs(epochDir); | |
| 244 } | |
| 239 | 245 |
| 240 log.info("Finished parsing bed heights."); | 246 log.info("Finished parsing bed heights."); |
| 241 } | 247 } |
| 242 | 248 |
| 243 | 249 |
| 699 } | 705 } |
| 700 } | 706 } |
| 701 | 707 |
| 702 | 708 |
| 703 public void storeBedHeight() { | 709 public void storeBedHeight() { |
| 704 if (!Config.INSTANCE.skipBedHeight()) { | 710 if (!Config.INSTANCE.skipBedHeightSingle()) { |
| 705 log.info("store bed heights"); | 711 log.info("store bed heights single"); |
| 706 River river = getPeer(); | 712 storeBedHeightSingle(); |
| 707 | 713 } |
| 708 if (bedHeightSingles != null) { | 714 |
| 709 for (ImportBedHeightSingle single: bedHeightSingles) { | 715 if (!Config.INSTANCE.skipBedHeightEpoch()) { |
| 710 String desc = single.getDescription(); | 716 log.info("store bed height epoch."); |
| 711 | 717 storeBedHeightEpoch(); |
| 712 log.debug("name: " + desc); | 718 } |
| 713 | 719 } |
| 714 try { | 720 |
| 715 single.storeDependencies(river); | 721 |
| 716 } | 722 private void storeBedHeightSingle() { |
| 717 catch (SQLException sqle) { | 723 River river = getPeer(); |
| 718 log.error("File '" + desc + "' is broken!"); | 724 |
| 719 } | 725 if (bedHeightSingles != null) { |
| 720 catch (ConstraintViolationException cve) { | 726 for (ImportBedHeightSingle single: bedHeightSingles) { |
| 721 log.error("File '" + desc + "' is broken!"); | 727 String desc = single.getDescription(); |
| 722 } | 728 |
| 729 log.debug("name: " + desc); | |
| 730 | |
| 731 try { | |
| 732 single.storeDependencies(river); | |
| 723 } | 733 } |
| 724 } | 734 catch (SQLException sqle) { |
| 725 else { | 735 log.error("File '" + desc + "' is broken!"); |
| 726 log.info("No single bed heights to store."); | 736 } |
| 727 } | 737 catch (ConstraintViolationException cve) { |
| 728 | 738 log.error("File '" + desc + "' is broken!"); |
| 729 if (bedHeightEpochs != null) { | 739 } |
| 730 for (ImportBedHeightEpoch epoch: bedHeightEpochs) { | 740 } |
| 731 log.debug("name: " + epoch.getDescription()); | 741 } |
| 742 else { | |
| 743 log.info("No single bed heights to store."); | |
| 744 } | |
| 745 } | |
| 746 | |
| 747 | |
| 748 private void storeBedHeightEpoch() { | |
| 749 River river = getPeer(); | |
| 750 | |
| 751 if (bedHeightEpochs != null) { | |
| 752 for (ImportBedHeightEpoch epoch: bedHeightEpochs) { | |
| 753 String desc = epoch.getDescription(); | |
| 754 | |
| 755 log.debug("name: " + desc); | |
| 756 | |
| 757 try { | |
| 732 epoch.storeDependencies(river); | 758 epoch.storeDependencies(river); |
| 733 } | 759 } |
| 734 } | 760 catch (SQLException sqle) { |
| 735 else { | 761 log.error("File '" + desc + "' is broken!"); |
| 736 log.info("No epoch bed heights to store."); | 762 } |
| 737 } | 763 catch (ConstraintViolationException cve) { |
| 764 log.error("File '" + desc + "' is broken!"); | |
| 765 } | |
| 766 } | |
| 767 } | |
| 768 else { | |
| 769 log.info("No epoch bed heights to store."); | |
| 738 } | 770 } |
| 739 } | 771 } |
| 740 | 772 |
| 741 public void storeAnnotations() { | 773 public void storeAnnotations() { |
| 742 if (!Config.INSTANCE.skipAnnotations()) { | 774 if (!Config.INSTANCE.skipAnnotations()) { |