In .:
* src/GrampsDb/_DbUtils.py (db_copy): Use UpdateCallback class. * src/BasicUtils.py: Add module. * src/Makefile.am (gdir_PYTHON): Add new file. In po: 2006-05-10 Alex Roitman <shura@gramps-project.org> * POTFILES.in: Add new file. svn: r6617
This commit is contained in:
parent
009b4b5cfa
commit
ae59d17a60
@ -1,4 +1,7 @@
|
||||
2006-05-10 Alex Roitman <shura@gramps-project.org>
|
||||
* src/GrampsDb/_DbUtils.py (db_copy): Use UpdateCallback class.
|
||||
* src/BasicUtils.py: Add module.
|
||||
* src/Makefile.am (gdir_PYTHON): Add new file.
|
||||
* src/DataViews/_MediaView.py (edit): Handle the exception.
|
||||
* src/plugins/BookReport.py (__init__): Fix url.
|
||||
* src/plugins/ChangeTypes.py (run_tool): Disable/enable signals.
|
||||
|
@ -1,3 +1,6 @@
|
||||
2006-05-10 Alex Roitman <shura@gramps-project.org>
|
||||
* POTFILES.in: Add new file.
|
||||
|
||||
2006-05-07 Alex Roitman <shura@gramps-project.org>
|
||||
* POTFILES.in: Add missing file.
|
||||
|
||||
|
@ -9,6 +9,7 @@ src/ArgHandler.py
|
||||
src/Assistant.py
|
||||
src/AutoComp.py
|
||||
src/BaseDoc.py
|
||||
src/BasicUtils.py
|
||||
src/Bookmarks.py
|
||||
src/ColumnOrder.py
|
||||
src/const.py
|
||||
|
83
gramps2/src/BasicUtils.py
Normal file
83
gramps2/src/BasicUtils.py
Normal file
@ -0,0 +1,83 @@
|
||||
#
|
||||
# Gramps - a GTK+/GNOME based genealogy program
|
||||
#
|
||||
# Copyright (C) 2004-2006 Donald N. Allingham
|
||||
#
|
||||
# This program is free software; you can redistribute it and/or modify
|
||||
# it under the terms of the GNU General Public License as published by
|
||||
# the Free Software Foundation; either version 2 of the License, or
|
||||
# (at your option) any later version.
|
||||
#
|
||||
# This program is distributed in the hope that it will be useful,
|
||||
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
# GNU General Public License for more details.
|
||||
#
|
||||
# You should have received a copy of the GNU General Public License
|
||||
# along with this program; if not, write to the Free Software
|
||||
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
||||
#
|
||||
|
||||
# $Id: __init__.py 6086 2006-03-06 03:54:58Z dallingham $
|
||||
|
||||
"""
|
||||
A set of basic utilities that everything in GRAMPS can depend upon.
|
||||
|
||||
The goal is to have this module not depend on any other gramps module.
|
||||
That way, e.g. database classes can safely depend on that without
|
||||
other GRAMPS baggage.
|
||||
"""
|
||||
|
||||
#-------------------------------------------------------------------------
|
||||
#
|
||||
# Python modules
|
||||
#
|
||||
#-------------------------------------------------------------------------
|
||||
import time
|
||||
|
||||
#-------------------------------------------------------------------------
|
||||
#
|
||||
# Callback updater
|
||||
#
|
||||
#-------------------------------------------------------------------------
|
||||
class UpdateCallback:
|
||||
"""
|
||||
Basic class providing way of calling the callback to update
|
||||
things during lenghty operations.
|
||||
"""
|
||||
|
||||
def __init__(self,callback,interval=1):
|
||||
"""
|
||||
@param callback: a function with one arg to execute every so often
|
||||
@type callback: function
|
||||
@param interval: number of seconds at most between the updates
|
||||
@type callback: int
|
||||
"""
|
||||
if '__call__' in dir(callback): # callback is really callable
|
||||
self.update = self.update_real
|
||||
self.callback = callback
|
||||
|
||||
self.count = 0
|
||||
self.oldval = 0
|
||||
self.oldtime = 0
|
||||
self.total = self.get_total()
|
||||
self.interval = interval
|
||||
else:
|
||||
self.update = self.update_empty
|
||||
|
||||
def get_total(self):
|
||||
assert False, "Needs to be defined in the derived class"
|
||||
|
||||
def update_empty(self):
|
||||
pass
|
||||
|
||||
def update_real(self):
|
||||
self.count += 1
|
||||
newval = int(100.0*self.count/self.total)
|
||||
newtime = time.time()
|
||||
time_has_come = self.interval and (newtime-self.oldtime>self.interval)
|
||||
value_changed = newval!=self.oldval
|
||||
if value_changed or time_has_come:
|
||||
self.callback(newval)
|
||||
self.oldval = newval
|
||||
self.oldtime = newtime
|
@ -22,6 +22,7 @@
|
||||
|
||||
|
||||
import RelLib
|
||||
import BasicUtils
|
||||
|
||||
def remove_family_relationships(db, family_handle, trans=None):
|
||||
family = db.get_family_from_handle(family_handle)
|
||||
@ -145,25 +146,27 @@ def add_child_to_family(db, family, child,
|
||||
db.transaction_commit(trans, _('Add child to family') )
|
||||
|
||||
|
||||
def db_copy(from_db,to_db,callback):
|
||||
if '__call__' in dir(callback): # callback is really callable
|
||||
update = update_real
|
||||
class DbUpdateCallback(BasicUtils.UpdateCallback):
|
||||
def __init__(self,db,callback,interval=1):
|
||||
self.db = db
|
||||
BasicUtils.UpdateCallback.__init__(self,callback,interval)
|
||||
|
||||
# Prepare length for the callback
|
||||
person_len = from_db.get_number_of_people()
|
||||
family_len = from_db.get_number_of_families()
|
||||
event_len = from_db.get_number_of_events()
|
||||
source_len = from_db.get_number_of_sources()
|
||||
place_len = from_db.get_number_of_places()
|
||||
repo_len = from_db.get_number_of_repositories()
|
||||
obj_len = from_db.get_number_of_media_objects()
|
||||
def get_total(self):
|
||||
person_len = self.db.get_number_of_people()
|
||||
family_len = self.db.get_number_of_families()
|
||||
event_len = self.db.get_number_of_events()
|
||||
source_len = self.db.get_number_of_sources()
|
||||
place_len = self.db.get_number_of_places()
|
||||
repo_len = self.db.get_number_of_repositories()
|
||||
obj_len = self.db.get_number_of_media_objects()
|
||||
|
||||
return person_len + family_len + event_len + \
|
||||
place_len + source_len + obj_len + repo_len
|
||||
|
||||
total = person_len + family_len + event_len + place_len + \
|
||||
source_len + obj_len + repo_len
|
||||
else:
|
||||
update = update_empty
|
||||
total = 0
|
||||
|
||||
def db_copy(from_db,to_db,callback):
|
||||
uc = DbUpdateCallback(from_db,callback)
|
||||
|
||||
primary_tables = {
|
||||
'Person': {'cursor_func': from_db.get_person_cursor,
|
||||
'table': to_db.person_map },
|
||||
@ -190,9 +193,6 @@ def db_copy(from_db,to_db,callback):
|
||||
else:
|
||||
add_data = add_data_dict
|
||||
|
||||
oldval = 0
|
||||
count = 0
|
||||
|
||||
# Start batch transaction to use async TXN and other tricks
|
||||
trans = to_db.transaction_begin("",batch=True)
|
||||
|
||||
@ -206,8 +206,7 @@ def db_copy(from_db,to_db,callback):
|
||||
(handle,data) = item
|
||||
add_data(to_db,table,handle,data)
|
||||
item = cursor.next()
|
||||
count,oldval = update(callback,count,oldval,total)
|
||||
update(callback,count,oldval,total)
|
||||
uc.update()
|
||||
cursor.close()
|
||||
|
||||
# Commit batch transaction: does nothing, except undoing the tricks
|
||||
@ -219,7 +218,6 @@ def db_copy(from_db,to_db,callback):
|
||||
data = from_db.metadata.get(handle)
|
||||
to_db.metadata[handle] = data
|
||||
|
||||
|
||||
def add_data_txn(db,table,handle,data):
|
||||
the_txn = db.env.txn_begin()
|
||||
table.put(handle,data,txn=the_txn)
|
||||
@ -230,14 +228,3 @@ def add_data_notxn(db,table,handle,data):
|
||||
|
||||
def add_data_dict(db,table,handle,data):
|
||||
table[handle] = data
|
||||
|
||||
def update_empty(callback,count,oldval,total):
|
||||
pass
|
||||
|
||||
def update_real(callback,count,oldval,total):
|
||||
count += 1
|
||||
newval = int(100.0*count/total)
|
||||
if newval != oldval:
|
||||
callback(newval)
|
||||
oldval = newval
|
||||
return count,oldval
|
||||
|
@ -78,7 +78,8 @@ gdir_PYTHON = \
|
||||
ViewManager.py\
|
||||
SelectFamily.py\
|
||||
SelectSource.py\
|
||||
UndoHistory.py
|
||||
UndoHistory.py\
|
||||
BasicUtils.py
|
||||
|
||||
# Clean up all the byte-compiled files
|
||||
MOSTLYCLEANFILES = *pyc *pyo
|
||||
|
Loading…
Reference in New Issue
Block a user