Mercurial > dive4elements > river

comparison flys-backend/contrib/shpimporter/importer.py @ 4876:884afa149192

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
(importer) Style: Remove some empty lines
author Andre Heinecke <aheinecke@intevation.de>
date Fri, 25 Jan 2013 10:43:38 +0100
parents a563e9f58f93
children 852d4c508f33
comparison
equal deleted inserted replaced
4875:37fa93f65971 4876:884afa149192
15 self.dest_srs.ImportFromEPSG(config.target_srs) 15 self.dest_srs.ImportFromEPSG(config.target_srs)
16 16
17 def getKind(self, path): 17 def getKind(self, path):
18 raise NotImplementedError("Importer.getKind is abstract!") 18 raise NotImplementedError("Importer.getKind is abstract!")
19 19
20
21 def getPath(self, base): 20 def getPath(self, base):
22 raise NotImplementedError("Importer.getPath is abstract!") 21 raise NotImplementedError("Importer.getPath is abstract!")
23
24 22
25 def getTablename(self): 23 def getTablename(self):
26 raise NotImplementedError("Importer.getTablename is abstract!") 24 raise NotImplementedError("Importer.getTablename is abstract!")
27 25
28
29 def getName(self): 26 def getName(self):
30 raise NotImplementedError("Importer.getTablename is abstract!") 27 raise NotImplementedError("Importer.getTablename is abstract!")
31
32 28
33 def IsFieldSet(self, feat, name): 29 def IsFieldSet(self, feat, name):
34 try: 30 try:
35 isset = feat.GetField(name) 31 isset = feat.GetField(name)
36 return isset is not None 32 return isset is not None
43 isset = feat.GetFieldAsDouble(name) 39 isset = feat.GetFieldAsDouble(name)
44 return isset is not None 40 return isset is not None
45 except: 41 except:
46 return False 42 return False
47 43
48
49 def isShapeRelevant(self, name, path): 44 def isShapeRelevant(self, name, path):
50 return True 45 return True
51
52 46
53 def walkOverShapes(self, shape): 47 def walkOverShapes(self, shape):
54 (name, path) = shape 48 (name, path) = shape
55 if not self.isShapeRelevant(name, path): 49 if not self.isShapeRelevant(name, path):
56 shpimporter.INFO("Skip shapefile '%s'" % path) 50 shpimporter.INFO("Skip shapefile '%s'" % path)
68 shpimporter.ERROR("Layer '%s' was not found!" % name) 62 shpimporter.ERROR("Layer '%s' was not found!" % name)
69 return 63 return
70 64
71 return self.shape2Database(srcLayer, name, path) 65 return self.shape2Database(srcLayer, name, path)
72 66
73
74 def transform(self, feat): 67 def transform(self, feat):
75 geometry = feat.GetGeometryRef() 68 geometry = feat.GetGeometryRef()
76 src_srs = geometry.GetSpatialReference() 69 src_srs = geometry.GetSpatialReference()
77 70
78 if src_srs is None: 71 if src_srs is None:
81 74
82 transformer = osr.CoordinateTransformation(src_srs, self.dest_srs) 75 transformer = osr.CoordinateTransformation(src_srs, self.dest_srs)
83 geometry.Transform(transformer) 76 geometry.Transform(transformer)
84 77
85 return feat 78 return feat
86
87 79
88 def shape2Database(self, srcLayer, name, path): 80 def shape2Database(self, srcLayer, name, path):
89 destLayer = self.dbconn.GetLayerByName(self.getTablename()) 81 destLayer = self.dbconn.GetLayerByName(self.getTablename())
90 82
91 if srcLayer is None: 83 if srcLayer is None:
144 destLayer.CommitTransaction() 136 destLayer.CommitTransaction()
145 except e: 137 except e:
146 shpimporter.ERROR("Exception while committing transaction.") 138 shpimporter.ERROR("Exception while committing transaction.")
147 139
148 return geomType 140 return geomType
149
http://dive4elements.wald.intevation.org