Changeset 4811 for waeup/branches/ulif-importers/src

Timestamp:

14 Jan 2010, 17:29:16 (15 years ago)

Author:

uli

Message:

Respect new converter API.

File:

• waeup/branches/ulif-importers/src/waeup/utils/batching.py (modified) (6 diffs)

waeup/branches/ulif-importers/src/waeup/utils/batching.py

@@ -86 +86 @@
 
     def applyMapping(self, row, mapping):
+        """Apply mapping to a row of CSV data.
+        """
         result = dict()
         for key, replacement in mapping.items():
@@ -92 +94 @@
         
     def getMapping(self, path, headerfields):
+        """Get a mapping from CSV file headerfields to actually used
+           fieldnames.
+        """
         reader = csv.reader(open(path, 'rb'))
         raw_header = reader.next()
@@ -98 +103 @@
 
     def getFieldConverters(self, fieldnames):
+        """Get converters for fieldnames.
+        """
         result = dict()
         for key, field in getFields(self.iface).items():
@@ -107 +114 @@
     
     def convertToTypes(self, row, converter_dict):
+        """Convert values in given row to destination type.
+        """
         if '--IGNORE--' in row.keys():
             del row['--IGNORE--']
@@ -112 +121 @@
             converter = converter_dict.get(key, None)
             if converter:
-                row.update({key:converter_dict[key].convert(value)})
+                row.update({key:converter_dict[key].fromString(value)})
         return row
 
@@ -119 +128 @@
 
     def parentsExist(self, row, site):
+        """Tell whether the parent object for data in ``row`` exists.
+        """
         raise NotImplementedError('method not implemented')
 
     def entryExists(self, row, site):
+        """Tell whether there already exists an entry for ``row`` data.
+        """
         raise NotImplementedError('method not implemented')
 
     def getParent(self, row, site):
+        """Get the parent object for the entry in ``row``.
+        """
         raise NotImplementedError('method not implemented')
     
     def addEntry(self, obj, row, site):
+        """Add the entry given given by ``row`` data.
+        """
         raise NotImplementedError('method not implemented')
 
     def delEntry(self, row, site):
+        """Delete entry given by ``row`` data.
+        """
         raise NotImplementedError('method not implemented')        
 
     def updateEntry(self, obj, row, site):
+        """Update entry given by ``row`` with data delivered therein.
+        """
         raise NotImplementedError('method not implemented')
     
     def doImport(self, path, headerfields, mode='create'):
+        """Perform actual import.
+        """
         self.checkHeaders(headerfields, mode)
         mapping = self.getMapping(path, headerfields)