X-Git-Url: https://git.phdru.name/?a=blobdiff_plain;f=reload_db.py;h=187bfb353f04ac8b374042d4724ce3fc5fe2e494;hb=72abad5af9e89331952a64578b8f24c146a6e767;hp=af037104762dbeab193a5ff54d4c7d3b4a1ab92c;hpb=9f11c26113add5270ade4da28c7a2adb84194b1b;p=xsetbg.git diff --git a/reload_db.py b/reload_db.py index af03710..187bfb3 100755 --- a/reload_db.py +++ b/reload_db.py @@ -6,20 +6,58 @@ This file is a part of XSetBg. """ __author__ = "Oleg Broytman " -__copyright__ = "Copyright (C) 2007-2012 PhiloSoft Design" +__copyright__ = "Copyright (C) 2007-2015 PhiloSoft Design" __license__ = "GNU GPL" -import sys, os, shelve +import sys +from sqlobject import SQLObjectNotFound, sqlhub +from sqlobject.sqlbuilder import Insert +from m_lib.defenc import default_encoding +from xsetbg_db import SqliteSequence, XSetBg, xsetbg_db -xsetbg_dir = os.path.join(os.environ["HOME"], "lib", "xsetbg") -os.chdir(xsetbg_dir) - -global_db_name = "xsetbg.db" dump_file = open(sys.argv[1], 'rU') -global_db = shelve.open(global_db_name, flag='n') +if xsetbg_db: + try: + seq = SqliteSequence.byName(XSetBg.sqlmeta.table) + except SQLObjectNotFound: + SqliteSequence(name=XSetBg.sqlmeta.table, seq=0) + else: + seq.seq = 0 # Reset autoincrement counter + xsetbg_db.clearTable() +else: + xsetbg_db = XSetBg + xsetbg_db.createTable() + +def convert_str(s): + if s == "None": + return None + else: + return int(float(s)) + +connection = xsetbg_db._connection + +connection.query("PRAGMA synchronous=OFF") +connection.query("PRAGMA count_changes=OFF") +connection.query("PRAGMA journal_mode=MEMORY") +connection.query("PRAGMA temp_store=MEMORY") + +txn = connection.transaction() +sqlhub.processConnection = txn + for line in dump_file: - timestamp, filename = line.strip().split(None, 1) - global_db[filename] = float(timestamp) -global_db.close() + id, timestamp, filename = line.strip().split(None, 2) + id = convert_str(id) + timestamp = convert_str(timestamp) + if default_encoding != 'utf-8': + filename = filename.decode(default_encoding).encode('utf-8') + values = {'last_shown': timestamp, 'full_name': filename} + if id: + values['id'] = id + query = txn.sqlrepr(Insert(XSetBg.sqlmeta.table, values=values)) + txn.query(query) + +txn.commit() +sqlhub.processConnection = connection + dump_file.close()