Changeset 3531 for pykota/trunk/pykota/storages/sqlitestorage.py
- Timestamp:
- 04/17/10 23:08:15 (14 years ago)
- Files:
-
- 1 modified
Legend:
- Unmodified
- Added
- Removed
-
pykota/trunk/pykota/storages/sqlitestorage.py
r3528 r3531 38 38 """Opens the SQLite database connection.""" 39 39 BaseStorage.__init__(self, pykotatool) 40 40 self.doModify = self.doQuery 41 41 self.tool.logdebug("Trying to open database (dbname=%s)..." % repr(dbname)) 42 42 self.database = sqlite.connect(dbname, isolation_level=None) 43 43 self.cursor = self.database.cursor() 44 44 self.closed = False 45 try : 46 self.doQuery("PRAGMA foreign_keys = True;") 47 except PyKotaStorageError : 48 pass 45 49 self.tool.logdebug("Database opened (dbname=%s)" % repr(dbname)) 46 50 … … 68 72 self.tool.logdebug("Transaction aborted.") 69 73 70 def do RawSearch(self, query) :71 """ Does a raw searchquery."""74 def doQuery(self, query) : 75 """Executes an SQL query.""" 72 76 query = query.strip() 73 77 if not query.endswith(';') : … … 77 81 self.cursor.execute(query) 78 82 except self.database.Error, msg : 83 self.tool.logdebug("Query failed : %s" % repr(msg)) 79 84 raise PyKotaStorageError, repr(msg) 80 else : 81 result = self.cursor.fetchall() 82 return result 85 86 def doRawSearch(self, query) : 87 """Executes a raw search query.""" 88 self.doQuery(query) 89 result = self.cursor.fetchall() 90 return result 83 91 84 92 def doSearch(self, query) : … … 101 109 rows.append(rowdict) 102 110 return rows 103 104 def doModify(self, query) :105 """Does a (possibly multiple) modify query."""106 query = query.strip()107 if not query.endswith(';') :108 query += ';'109 self.querydebug("QUERY : %s" % query)110 try :111 self.cursor.execute(query)112 except self.database.Error, msg :113 self.tool.logdebug("Query failed : %s" % repr(msg))114 raise PyKotaStorageError, repr(msg)115 111 116 112 def doQuote(self, field) :