1 |
# Copyright (C) 2001, 2002, 2003 by Intevation GmbH |
# Copyright (C) 2001, 2002, 2003, 2004 by Intevation GmbH |
2 |
# Authors: |
# Authors: |
3 |
# Jan-Oliver Wagner <[email protected]> |
# Jan-Oliver Wagner <[email protected]> |
4 |
# Bernhard Herzog <[email protected]> |
# Bernhard Herzog <[email protected]> |
5 |
# Jonathan Coles <[email protected]> |
# Jonathan Coles <[email protected]> |
6 |
|
# Frank Koormann <[email protected]> |
7 |
# |
# |
8 |
# This program is free software under the GPL (>=v2) |
# This program is free software under the GPL (>=v2) |
9 |
# Read the file COPYING coming with GRASS for details. |
# Read the file COPYING coming with GRASS for details. |
101 |
|
|
102 |
class SessionLoader(XMLReader): |
class SessionLoader(XMLReader): |
103 |
|
|
104 |
def __init__(self, db_connection_callback = None): |
def __init__(self, db_connection_callback = None, |
105 |
|
shapefile_callback = None): |
106 |
"""Inititialize the Sax handler.""" |
"""Inititialize the Sax handler.""" |
107 |
XMLReader.__init__(self) |
XMLReader.__init__(self) |
108 |
|
|
109 |
self.db_connection_callback = db_connection_callback |
self.db_connection_callback = db_connection_callback |
110 |
|
self.shapefile_callback = shapefile_callback |
111 |
self.theSession = None |
self.theSession = None |
112 |
self.aMap = None |
self.aMap = None |
113 |
self.aLayer = None |
self.aLayer = None |
145 |
for xmlns in ("http://thuban.intevation.org/dtds/thuban-0.8.dtd", |
for xmlns in ("http://thuban.intevation.org/dtds/thuban-0.8.dtd", |
146 |
"http://thuban.intevation.org/dtds/thuban-0.9-dev.dtd", |
"http://thuban.intevation.org/dtds/thuban-0.9-dev.dtd", |
147 |
"http://thuban.intevation.org/dtds/thuban-0.9.dtd", |
"http://thuban.intevation.org/dtds/thuban-0.9.dtd", |
148 |
"http://thuban.intevation.org/dtds/thuban-1.0-dev.dtd"): |
"http://thuban.intevation.org/dtds/thuban-1.0-dev.dtd", |
149 |
|
"http://thuban.intevation.org/dtds/thuban-1.0rc1.dtd", |
150 |
|
"http://thuban.intevation.org/dtds/thuban-1.0.0.dtd", |
151 |
|
"http://thuban.intevation.org/dtds/thuban-1.1-dev.dtd"): |
152 |
for key, value in dispatchers.items(): |
for key, value in dispatchers.items(): |
153 |
dispatchers[(xmlns, key)] = value |
dispatchers[(xmlns, key)] = value |
154 |
|
|
260 |
normalized[d.name] = value |
normalized[d.name] = value |
261 |
return normalized |
return normalized |
262 |
|
|
263 |
|
def open_shapefile(self, filename): |
264 |
|
"""Open shapefile, with alternative path handling. |
265 |
|
|
266 |
|
If a shapefile cannot be opened and an IOError is raised, check for |
267 |
|
an alternative. This alternative can be specified interactively by |
268 |
|
the user or taken from a list of (potential) locations, depending on |
269 |
|
the callback implementation. |
270 |
|
|
271 |
|
The alternative is rechecked. If taken from a list the user |
272 |
|
has to confirm the alternative. |
273 |
|
""" |
274 |
|
|
275 |
|
# Flag if the alternative path was specified interactively / from list. |
276 |
|
from_list = 0 |
277 |
|
while 1: |
278 |
|
try: |
279 |
|
store = self.theSession.OpenShapefile(filename) |
280 |
|
if from_list: |
281 |
|
# A valid path has been guessed from a list |
282 |
|
# Let the user confirm - or select an alternative. |
283 |
|
filename, from_list = self.shapefile_callback( |
284 |
|
filename, "check") |
285 |
|
if filename is None: |
286 |
|
# Selection cancelled |
287 |
|
raise LoadCancelled |
288 |
|
elif store.FileName() == filename: |
289 |
|
# Proposed file has been accepted |
290 |
|
break |
291 |
|
else: |
292 |
|
# the filename has been changed, try the new file |
293 |
|
pass |
294 |
|
else: |
295 |
|
break |
296 |
|
except IOError: |
297 |
|
if self.shapefile_callback is not None: |
298 |
|
filename, from_list = self.shapefile_callback( |
299 |
|
filename, |
300 |
|
mode = "search", |
301 |
|
second_try = from_list) |
302 |
|
if filename is None: |
303 |
|
raise LoadCancelled |
304 |
|
else: |
305 |
|
raise |
306 |
|
return store |
307 |
|
|
308 |
def start_dbconnection(self, name, qname, attrs): |
def start_dbconnection(self, name, qname, attrs): |
309 |
attrs = self.check_attrs(name, attrs, |
attrs = self.check_attrs(name, attrs, |
310 |
[AttrDesc("id", True), |
[AttrDesc("id", True), |
348 |
AttrDesc("dbconn", True, |
AttrDesc("dbconn", True, |
349 |
conversion = "idref"), |
conversion = "idref"), |
350 |
AttrDesc("tablename", True, |
AttrDesc("tablename", True, |
351 |
|
conversion = "ascii"), |
352 |
|
# id_column and geometry_column were |
353 |
|
# newly introduced with thuban-1.1.dtd |
354 |
|
# where they're required. Since we |
355 |
|
# support the older formats too we |
356 |
|
# have them optional here. |
357 |
|
AttrDesc("id_column", False, "gid", |
358 |
|
conversion = "ascii"), |
359 |
|
AttrDesc("geometry_column", False, |
360 |
conversion = "ascii")]) |
conversion = "ascii")]) |
361 |
ID = attrs["id"] |
# The default value of geometry_column to use when instantiating |
362 |
db = attrs["dbconn"] |
# the db shapestore is None which we currently can't easily use |
363 |
tablename = attrs["tablename"] |
# in check_attrs |
364 |
self.idmap[ID] = self.theSession.OpenDBShapeStore(db, tablename) |
geometry_column = attrs["geometry_column"] |
365 |
|
if not geometry_column: |
366 |
|
geometry_column = None |
367 |
|
dbopen = self.theSession.OpenDBShapeStore |
368 |
|
self.idmap[attrs["id"]] = dbopen(attrs["dbconn"], attrs["tablename"], |
369 |
|
id_column = attrs["id_column"], |
370 |
|
geometry_column=geometry_column) |
371 |
|
|
372 |
def start_fileshapesource(self, name, qname, attrs): |
def start_fileshapesource(self, name, qname, attrs): |
373 |
attrs = self.check_attrs(name, attrs, |
attrs = self.check_attrs(name, attrs, |
380 |
filetype = attrs["filetype"] |
filetype = attrs["filetype"] |
381 |
if filetype != "shapefile": |
if filetype != "shapefile": |
382 |
raise LoadError("shapesource filetype %r not supported" % filetype) |
raise LoadError("shapesource filetype %r not supported" % filetype) |
383 |
self.idmap[ID] = self.theSession.OpenShapefile(filename) |
self.idmap[ID] = self.open_shapefile(filename) |
384 |
|
|
385 |
def start_derivedshapesource(self, name, qname, attrs): |
def start_derivedshapesource(self, name, qname, attrs): |
386 |
attrs = self.check_attrs(name, attrs, |
attrs = self.check_attrs(name, attrs, |
491 |
if attrs.has_key((None, "shapestore")): |
if attrs.has_key((None, "shapestore")): |
492 |
store = self.idmap[attrs[(None, "shapestore")]] |
store = self.idmap[attrs[(None, "shapestore")]] |
493 |
else: |
else: |
494 |
store = self.theSession.OpenShapefile(filename) |
store = self.open_shapefile(filename) |
495 |
|
|
496 |
self.aLayer = layer_class(title, store, |
self.aLayer = layer_class(title, store, |
497 |
fill = fill, stroke = stroke, |
fill = fill, stroke = stroke, |
498 |
lineWidth = stroke_width, |
lineWidth = stroke_width, |
508 |
filename = os.path.join(self.GetDirectory(), filename) |
filename = os.path.join(self.GetDirectory(), filename) |
509 |
filename = self.encode(filename) |
filename = self.encode(filename) |
510 |
visible = self.encode(attrs.get((None, 'visible'), "true")) != "false" |
visible = self.encode(attrs.get((None, 'visible'), "true")) != "false" |
511 |
|
useMask = self.encode(attrs.get((None, 'use_mask'), "false")) != "false" |
512 |
|
|
513 |
self.aLayer = layer_class(title, filename, visible = visible) |
self.aLayer = layer_class(title, filename, visible = visible) |
514 |
|
|
515 |
|
self.aLayer.SetUseMask(useMask) |
516 |
|
|
517 |
def end_rasterlayer(self, name, qname): |
def end_rasterlayer(self, name, qname): |
518 |
self.aMap.AddLayer(self.aLayer) |
self.aMap.AddLayer(self.aLayer) |
519 |
self.aLayer = None |
self.aLayer = None |
605 |
parse_color(attrs.get((None, 'stroke'), "None"))) |
parse_color(attrs.get((None, 'stroke'), "None"))) |
606 |
self.cl_prop.SetLineWidth( |
self.cl_prop.SetLineWidth( |
607 |
int(attrs.get((None, 'stroke_width'), "0"))) |
int(attrs.get((None, 'stroke_width'), "0"))) |
608 |
|
self.cl_prop.SetSize(int(attrs.get((None, 'size'), "5"))) |
609 |
self.cl_prop.SetFill(parse_color(attrs.get((None, 'fill'), "None"))) |
self.cl_prop.SetFill(parse_color(attrs.get((None, 'fill'), "None"))) |
610 |
|
|
611 |
def end_cldata(self, name, qname): |
def end_cldata(self, name, qname): |
615 |
self.aLayer = self.aMap.LabelLayer() |
self.aLayer = self.aMap.LabelLayer() |
616 |
|
|
617 |
def start_label(self, name, qname, attrs): |
def start_label(self, name, qname, attrs): |
618 |
x = float(attrs[(None, 'x')]) |
attrs = self.check_attrs(name, attrs, |
619 |
y = float(attrs[(None, 'y')]) |
[AttrDesc("x", True, conversion = float), |
620 |
text = self.encode(attrs[(None, 'text')]) |
AttrDesc("y", True, conversion = float), |
621 |
halign = attrs[(None, 'halign')] |
AttrDesc("text", True), |
622 |
valign = attrs[(None, 'valign')] |
AttrDesc("halign", True, |
623 |
|
conversion = "ascii"), |
624 |
|
AttrDesc("valign", True, |
625 |
|
conversion = "ascii")]) |
626 |
|
x = attrs['x'] |
627 |
|
y = attrs['y'] |
628 |
|
text = attrs['text'] |
629 |
|
halign = attrs['halign'] |
630 |
|
valign = attrs['valign'] |
631 |
|
if halign not in ("left", "center", "right"): |
632 |
|
raise LoadError("Unsupported halign value %r" % halign) |
633 |
|
if valign not in ("top", "center", "bottom"): |
634 |
|
raise LoadError("Unsupported valign value %r" % valign) |
635 |
self.aLayer.AddLabel(x, y, text, halign = halign, valign = valign) |
self.aLayer.AddLabel(x, y, text, halign = halign, valign = valign) |
636 |
|
|
637 |
def characters(self, chars): |
def characters(self, chars): |
638 |
pass |
pass |
639 |
|
|
640 |
|
|
641 |
def load_session(filename, db_connection_callback = None): |
def load_session(filename, db_connection_callback = None, |
642 |
|
shapefile_callback = None): |
643 |
"""Load a Thuban session from the file object file |
"""Load a Thuban session from the file object file |
644 |
|
|
645 |
The db_connection_callback, if given should be a callable object |
The db_connection_callback, if given should be a callable object |
652 |
corrected and perhaps additional parameters like a password or None |
corrected and perhaps additional parameters like a password or None |
653 |
to indicate that the user cancelled. |
to indicate that the user cancelled. |
654 |
""" |
""" |
655 |
handler = SessionLoader(db_connection_callback) |
handler = SessionLoader(db_connection_callback, shapefile_callback) |
656 |
handler.read(filename) |
handler.read(filename) |
657 |
|
|
658 |
session = handler.theSession |
session = handler.theSession |