X-Git-Url: https://git.phdru.name/?a=blobdiff_plain;f=m_librarian%2Fdb.py;h=628675ef1e2c9d3ce4573ba1240b542784d5e499;hb=dd4b72d4628efc1e2a31e7c65fc119c49808a8d7;hp=7e5744f243e64eabebe14afadd66f768a08e2430;hpb=07794a8efe6512dd65b98c692d35a1a41ed5683e;p=m_librarian.git diff --git a/m_librarian/db.py b/m_librarian/db.py index 7e5744f..628675e 100755 --- a/m_librarian/db.py +++ b/m_librarian/db.py @@ -1,16 +1,18 @@ #! /usr/bin/env python -__all__ = ['Author', 'Book', 'Extension', 'Genre', 'Language', - 'AuthorBook', 'BookGenre', 'open_db', 'init_db', - 'insert_name', 'insert_author', 'update_counters', - ] - +from __future__ import print_function import os from sqlobject import SQLObject, StringCol, UnicodeCol, IntCol, BoolCol, \ ForeignKey, DateCol, DatabaseIndex, RelatedJoin, \ connectionForURI, sqlhub, SQLObjectNotFound, dberrors +from .compat import string_type from .config import get_config +__all__ = ['Author', 'Book', 'Extension', 'Genre', 'Language', + 'AuthorBook', 'BookGenre', 'open_db', 'init_db', + 'insert_name', 'insert_author', 'update_counters', + ] + class Author(SQLObject): surname = UnicodeCol(notNull=True) @@ -20,6 +22,12 @@ class Author(SQLObject): books = RelatedJoin('Book', otherColumn='book_id', intermediateTable='author_book', createRelatedTable=False) + + @property + def fullname(self): + fullnames = filter(None, (self.surname, self.name, self.misc_name)) + return ' '.join(fullnames) + full_name_idx = DatabaseIndex(surname, name, misc_name, unique=True) count_idx = DatabaseIndex(count) @@ -124,7 +132,7 @@ def find_sqlite_dburi(db_dirs=None): else: # octal; -rw-------; # make the database file/directory readable/writeable only by the user - os.umask(0066) + os.umask(0o66) db_dir = db_dirs[0] try: os.makedirs(db_dir) @@ -142,11 +150,16 @@ def open_db(db_uri=None): except: db_uri = find_sqlite_dburi() + if '://' not in db_uri: + db_uri = 'sqlite://' + os.path.abspath(db_uri).replace(os.sep, '/') + sqlhub.processConnection = connection = connectionForURI(db_uri) if connection.dbName == 'sqlite': def lower(s): - return s.lower() + if isinstance(s, string_type): + return s.lower() + return s sqlite = connection.module @@ -209,8 +222,9 @@ def update_counters(): def test(): db_dirs = find_sqlite_db_dirs() - print "DB dirs:", db_dirs - print "DB URI:", find_sqlite_dburi() + print("DB dirs:", db_dirs) + print("DB URI:", find_sqlite_dburi()) + if __name__ == '__main__': test()