Changeset 92:c307d90395db for atomisator/entries.py

Timestamp:

05/28/07 15:49:13 (18 months ago)

Author:

Tarek Ziad?? <tarek@…>

Message:

overall fix

Files:

• atomisator/entries.py (modified) (3 diffs)

atomisator/entries.py

@@ -24 +24 @@
 """
 from datetime import datetime
+from time import strftime
 from sqlalchemy import *
+from sqlalchemy.exceptions import *
 
 _connector = None
+TIME_FMT = '%Y-%m-%d %H:%M:%S'
 
 class Entries(object):
@@ -32 +35 @@
     def __init__(self, sqluri):
         self._mapper = self._getEntriesMapper(sqluri)
-        self._mapper.create()
+        try:
+            self._mapper.create()
+        except SQLError:
+            pass # already there
 
     def getConnector(self):
@@ -50 +56 @@
                      Column('creation_date', DateTime))
 
-    def insert_entry(self, url, title, content, date=datetime.now(),
-                     creation_date=datetime.now()):
+    def insert_entry(self, url, title, content, date=strftime(TIME_FMT),
+                     creation_date=strftime(TIME_FMT)):
         """inserts entry"""
         inserter = self._mapper.insert()
         inserter.execute(url=url, title=title, content=content, date=date,
                          creation_date=creation_date)
+
+    def insert_entries(self, entries):
+        """insert entries"""
+        for entry in entries:
+            if 'url' in entry:
+                url = entry['url']
+            else:
+                url = entry['link']
+
+            if 'creation_date' not in entry:
+                entry['creation_date'] = strftime(TIME_FMT)
+
+            content = entry['content']
+
+            entry_date = entry['date']
+            if isinstance(entry_date, basestring):
+                try:
+                    entry_date = datetime.strptime(entry_date,
+                                                   '%Y-%m-%dT%H:%M:%S+00:00')
+                    strftime(TIME_FMT, entry_date.timetuple())
+                except ValueError:
+                    pass
+
+            self.insert_entry(url, entry['title'], content,
+                              entry_date, entry['creation_date'])
+
 
     def select_entries(self, *args):