X-Git-Url: https://git.phdru.name/?a=blobdiff_plain;f=reload_db.py;h=8d8b0df815142eab3245485dae832a77574938ea;hb=199f6beec9c9bf6eb08446a4c956ff709aef8fa7;hp=4c38208c045ee8d174059c66379bd37130e62854;hpb=ab98eea27897a184bd13b402a7b797881ddb1916;p=xsetbg.git diff --git a/reload_db.py b/reload_db.py index 4c38208..8d8b0df 100755 --- a/reload_db.py +++ b/reload_db.py @@ -5,25 +5,56 @@ This file is a part of XSetBg. """ -__version__ = "$Revision: 17 $"[11:-2] -__revision__ = "$Id: print_all.py 17 2007-06-14 10:37:08Z phd $"[5:-2] -__date__ = "$Date: 2007-06-14 14:37:08 +0400 (Thu, 14 Jun 2007) $"[7:-2] - -__author__ = "Oleg BroytMann " -__copyright__ = "Copyright (C) 2007 PhiloSoft Design" +__author__ = "Oleg Broytman " +__copyright__ = "Copyright (C) 2007-2015 PhiloSoft Design" __license__ = "GNU GPL" -import sys, os, shelve - -xsetbg_dir = os.path.join(os.environ["HOME"], "lib", "xsetbg") -os.chdir(xsetbg_dir) +import sys +from sqlobject import sqlhub, SQLObjectNotFound +from sqlobject.sqlbuilder import Insert +from xsetbg_conf import xsetbg_conf +from xsetbg_db import recreate_db -global_db_name = "xsetbg.db" +fs_encoding = xsetbg_conf.get("images", "fs_encoding") dump_file = open(sys.argv[1], 'rU') +xsetbg_db = recreate_db() + + +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 -global_db = shelve.open(global_db_name, flag='n') 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 fs_encoding != 'utf-8': + filename = filename.decode(fs_encoding).encode('utf-8') + try: + row = xsetbg_db.byFull_name(filename) + except SQLObjectNotFound: + values = {'last_shown': timestamp, 'full_name': filename} + if id: + values['id'] = id + query = txn.sqlrepr(Insert(xsetbg_db.sqlmeta.table, values=values)) + txn.query(query) + else: + assert id is None or row.id == id + assert row.last_shown == timestamp + +txn.commit() dump_file.close() + +connection.query("VACUUM %s" % xsetbg_db.sqlmeta.table)