]> git.phdru.name Git - m_librarian.git/blobdiff - m_librarian/db.py
Add indices
[m_librarian.git] / m_librarian / db.py
index 6888ab8d418fe7f0c3845d244c95daa7f5e18a28..98e541e95732378344f2e6f47b6b5f2cb1af2f3c 100755 (executable)
@@ -1,12 +1,12 @@
 #! /usr/bin/env python
 
 __all__ = ['Author', 'Book', 'Extension', 'Genre', 'Language',
-           'init_db', 'insert_name',
+           'init_db', 'insert_name', 'update_counters',
            ]
 
 import os
 from sqlobject import SQLObject, StringCol, UnicodeCol, IntCol, BoolCol, \
-    ForeignKey, DateCol, RelatedJoin, \
+    ForeignKey, DateCol, DatabaseIndex, RelatedJoin, \
     connectionForURI, sqlhub, SQLObjectNotFound, dberrors
 from .config import ml_conf
 
@@ -40,12 +40,21 @@ if not db_uri:
 
     db_uri = 'sqlite://%s' % db_file.replace(os.sep, '/')
 
-sqlhub.processConnection = connectionForURI(db_uri)
+
+sqlhub.processConnection = connection = connectionForURI(db_uri)
+
+if connection.dbName == 'sqlite':
+    # Speedup SQLite connection
+    connection.query("PRAGMA synchronous=OFF")
+    connection.query("PRAGMA count_changes=OFF")
+    connection.query("PRAGMA journal_mode=MEMORY")
+    connection.query("PRAGMA temp_store=MEMORY")
 
 
 class Author(SQLObject):
     name = UnicodeCol(unique=True)
     count = IntCol()
+    count_idx = DatabaseIndex('count')
     books = RelatedJoin('Book', otherColumn='book_id')
 
 
@@ -63,23 +72,27 @@ class Book(SQLObject):
     extension = ForeignKey('Extension')
     date = DateCol()
     language = ForeignKey('Language')
+    archive_file_idx = DatabaseIndex('archive', 'file', unique=True)
 
 
 class Extension(SQLObject):
     name = StringCol(unique=True)
     count = IntCol()
+    count_idx = DatabaseIndex('count')
 
 
 class Genre(SQLObject):
     name = StringCol(unique=True)
     title = UnicodeCol()
     count = IntCol()
+    count_idx = DatabaseIndex('count')
     books = RelatedJoin('Book', otherColumn='book_id')
 
 
 class Language(SQLObject):
     name = StringCol(unique=True)
     count = IntCol()
+    count_idx = DatabaseIndex('count')
 
 
 def init_db():
@@ -94,11 +107,11 @@ def init_db():
         return
 
 
-def insert_name(table, name):
+def insert_name(table, name, **kw):
     try:
         return table.byName(name)
     except SQLObjectNotFound:
-        return table(name=name, count=0)
+        return table(name=name, count=0, **kw)
 
 
 def test():