Mercurial > dive4elements > river
comparison backend/src/main/java/org/dive4elements/river/importer/ImportRiver.java @ 8412:17db08570637
SCHEMA CHANGE: removed superfluous columns station and river_id from measurement_stations and adapted other components accordingly.
| author | Tom Gottfried <tom@intevation.de> |
|---|---|
| date | Wed, 15 Oct 2014 19:20:26 +0200 |
| parents | 9d2e69f971f5 |
| children | d115d0ed6624 |
comparison
equal
deleted
inserted
replaced
| 8411:b8c6cb36607e | 8412:17db08570637 |
|---|---|
| 674 return; | 674 return; |
| 675 } | 675 } |
| 676 | 676 |
| 677 log.debug("Parse sediment load data at measurement stations"); | 677 log.debug("Parse sediment load data at measurement stations"); |
| 678 | 678 |
| 679 SedimentLoadParser parser = new SedimentLoadParser(name); | 679 SedimentLoadParser parser = new SedimentLoadParser(getPeer()); |
| 680 | 680 |
| 681 File minfoDir = getMinfoDir(); | 681 File minfoDir = getMinfoDir(); |
| 682 File sedimentLoadDir = new File(minfoDir, SEDIMENT_LOAD_DIR); | 682 File sedimentLoadDir = new File(minfoDir, SEDIMENT_LOAD_DIR); |
| 683 File sedimentLoadMSDir = new File(sedimentLoadDir, | 683 File sedimentLoadMSDir = new File(sedimentLoadDir, |
| 684 SEDIMENT_LOAD_MS_DIR); | 684 SEDIMENT_LOAD_MS_DIR); |
| 804 if (files == null) { | 804 if (files == null) { |
| 805 log.warn("Cannot read directory '" + sqDir + "'"); | 805 log.warn("Cannot read directory '" + sqDir + "'"); |
| 806 return; | 806 return; |
| 807 } | 807 } |
| 808 | 808 |
| 809 SQRelationParser parser = new SQRelationParser(); | 809 SQRelationParser parser = new SQRelationParser(getPeer()); |
| 810 | 810 |
| 811 for (File file: files) { | 811 for (File file: files) { |
| 812 parser.parse(file); | 812 parser.parse(file); |
| 813 } | 813 } |
| 814 | 814 |