diff --git a/gramps2/ChangeLog b/gramps2/ChangeLog
index e232ac655..9d91b0792 100644
--- a/gramps2/ChangeLog
+++ b/gramps2/ChangeLog
@@ -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>
 	* src/Editors/_EditFamily.py: select person used for children
 	* src/PeopleModel.py: used raw data functions for name display
diff --git a/gramps2/src/GrampsDb/_GrampsBSDDB.py b/gramps2/src/GrampsDb/_GrampsBSDDB.py
index 64c71bba3..d4dfdc7f7 100644
--- a/gramps2/src/GrampsDb/_GrampsBSDDB.py
+++ b/gramps2/src/GrampsDb/_GrampsBSDDB.py
@@ -109,7 +109,30 @@ class GrampsBSDDBCursor(GrampsCursor):
     def delete(self):
         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"""
 
     def set(self,key):
@@ -175,7 +198,7 @@ class GrampsBSDDB(GrampsDbBase):
         return GrampsBSDDBCursor(self.media_map,self.txn)
 
     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):
         """
@@ -248,7 +271,7 @@ class GrampsBSDDB(GrampsDbBase):
     # the main index is unique, the others allow duplicate entries.
 
     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):
         return GrampsBSDDBDupCursor(self.reference_map_primary_map,self.txn)
@@ -283,7 +306,7 @@ class GrampsBSDDB(GrampsDbBase):
         if self.UseTXN:
             env_flags = db.DB_CREATE|db.DB_RECOVER|db.DB_PRIVATE|\
                         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:
             env_flags = db.DB_CREATE|db.DB_PRIVATE|\
                         db.DB_INIT_MPOOL|db.DB_INIT_LOG