X-Git-Url: https://git.phdru.name/?a=blobdiff_plain;ds=sidebyside;f=reload_db.py;h=c12607a2f3fa00aab5a99748ecdf8ff3968c87d7;hb=a0577ff865f17f5988b5192adae263e0ef32b09a;hp=1bee46e92dde9517f826152043dced4f5ff87469;hpb=76c9a423c497a1b7c2831087e02e6d8dbda5cb58;p=xsetbg.git diff --git a/reload_db.py b/reload_db.py index 1bee46e..c12607a 100755 --- a/reload_db.py +++ b/reload_db.py @@ -1,22 +1,59 @@ -#! /usr/bin/env python +#! /usr/bin/env python3 """Reload a dump into DB This file is a part of XSetBg. """ -__author__ = "Oleg Broytman " -__copyright__ = "Copyright (C) 2007-2014 PhiloSoft Design" -__license__ = "GNU GPL" +import sys +from sqlobject import SQLObjectNotFound +from sqlobject.sqlbuilder import Insert +from xsetbg_conf import xsetbg_conf +from xsetbg_db import recreate_db, SQLiteMassInsert -import sys, shelve -from xsetbg_db import xsetbg_db_path -dump_file = open(sys.argv[1], 'rU') +def convert_str(s): + if s == "None": + return None + else: + return int(float(s)) + + +dump_file = open(sys.argv[1], 'r', + encoding=xsetbg_conf.get("images", "fs_encoding")) +xsetbg_db = recreate_db() +count_new = count_old = count_updated = 0 + +with SQLiteMassInsert() as txn: + for line in dump_file: + id, timestamp, filename = line.strip().split(None, 2) + id = convert_str(id) + timestamp = convert_str(timestamp) + try: + if id: + row = xsetbg_db.get(id) + else: + row = xsetbg_db.byFull_name(filename) + except SQLObjectNotFound: + values = {'last_shown': timestamp, + 'full_name': filename.encode('utf-8')} + if id: + values['id'] = id + query = txn.sqlrepr(Insert(xsetbg_db.sqlmeta.table, values=values)) + txn.query(query) + count_new += 1 + else: + assert id is None or row.id == id + if row.last_shown is not None: + assert row.last_shown == timestamp + if row.full_name == filename: + count_old += 1 + else: + row.full_name = filename + count_updated += 1 -xsetbg_db = shelve.open(xsetbg_db_path, flag='n') -for line in dump_file: - timestamp, filename = line.strip().split(None, 1) - xsetbg_db[filename] = float(timestamp) -xsetbg_db.close() dump_file.close() + +print("New images:", count_new) +print("Existing images:", count_old) +print("Updated images:", count_updated)