Cyclone-Team/gramps
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

use db.THREAD

Browse Source 
svn: r6182
This commit is contained in:
Don Allingham 2006-03-21 00:05:07 +00:00
parent 842372e040
commit f3b8387c06
2 changed files with 31 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
gramps2/ChangeLog
View File

@ -1,3 +1,7 @@
2006-03-20 Don Allingham <don@gramps-project.org>
* src/GrampsDb/_GrampsBSDDB.py: use db.THREAD to avoid
RUNRECOVERY error, fix cursors
2006-03-19 Don Allingham <don@gramps-project.org> 2006-03-19 Don Allingham <don@gramps-project.org>
* src/Editors/_EditFamily.py: select person used for children * src/Editors/_EditFamily.py: select person used for children
* src/PeopleModel.py: used raw data functions for name display * src/PeopleModel.py: used raw data functions for name display

31
gramps2/src/GrampsDb/_GrampsBSDDB.py
View File

@ -109,7 +109,30 @@ class GrampsBSDDBCursor(GrampsCursor):
def delete(self): def delete(self):
self.cursor.delete() self.cursor.delete()
class GrampsBSDDBDupCursor(GrampsBSDDBCursor): class GrampsBSDDBAssocCursor(GrampsCursor):
def __init__(self,source,txn=None):
self.cursor = source.cursor(txn)
def first(self):
d = self.cursor.first()
if d:
return (d[0],pickle.loads(d[1]))
return None
def next(self):
d = self.cursor.next()
if d:
return (d[0],pickle.loads(d[1]))
return None
def close(self):
self.cursor.close()
def delete(self):
self.cursor.delete()
class GrampsBSDDBDupCursor(GrampsBSDDBAssocCursor):
"""Cursor that includes handling for duplicate keys""" """Cursor that includes handling for duplicate keys"""
def set(self,key): def set(self,key):
@ -175,7 +198,7 @@ class GrampsBSDDB(GrampsDbBase):
return GrampsBSDDBCursor(self.media_map,self.txn) return GrampsBSDDBCursor(self.media_map,self.txn)
def get_repository_cursor(self): def get_repository_cursor(self):
return GrampsBSDDBCursor(self.repository_map,self.txn) return GrampsBSDDBAssocCursor(self.repository_map,self.txn)
def has_person_handle(self,handle): def has_person_handle(self,handle):
""" """
@ -248,7 +271,7 @@ class GrampsBSDDB(GrampsDbBase):
# the main index is unique, the others allow duplicate entries. # the main index is unique, the others allow duplicate entries.
def get_reference_map_cursor(self): def get_reference_map_cursor(self):
return GrampsBSDDBCursor(self.reference_map,self.txn) return GrampsBSDDBAssocCursor(self.reference_map,self.txn)
def get_reference_map_primary_cursor(self): def get_reference_map_primary_cursor(self):
return GrampsBSDDBDupCursor(self.reference_map_primary_map,self.txn) return GrampsBSDDBDupCursor(self.reference_map_primary_map,self.txn)
@ -283,7 +306,7 @@ class GrampsBSDDB(GrampsDbBase):
if self.UseTXN: if self.UseTXN:
env_flags = db.DB_CREATE|db.DB_RECOVER|db.DB_PRIVATE|\ env_flags = db.DB_CREATE|db.DB_RECOVER|db.DB_PRIVATE|\
db.DB_INIT_MPOOL|db.DB_INIT_LOCK|\ db.DB_INIT_MPOOL|db.DB_INIT_LOCK|\
db.DB_INIT_LOG|db.DB_INIT_TXN db.DB_INIT_LOG|db.DB_INIT_TXN|db.DB_THREAD
else: else:
env_flags = db.DB_CREATE|db.DB_PRIVATE|\ env_flags = db.DB_CREATE|db.DB_PRIVATE|\
db.DB_INIT_MPOOL|db.DB_INIT_LOG db.DB_INIT_MPOOL|db.DB_INIT_LOG