9541: Make backend methods protected

This commit is contained in:
Nick Hall 2016-12-05 19:41:12 +00:00
parent c835c6f87c
commit 9d77418b30
3 changed files with 21 additions and 21 deletions

View File

@ -136,7 +136,7 @@ class DbGenericUndo(DbUndo):
# Process all records in the transaction # Process all records in the transaction
try: try:
self.db.transaction_backend_begin() self.db._txn_begin()
for record_id in subitems: for record_id in subitems:
(key, trans_type, handle, old_data, new_data) = \ (key, trans_type, handle, old_data, new_data) = \
pickle.loads(self.undodb[record_id]) pickle.loads(self.undodb[record_id])
@ -145,9 +145,9 @@ class DbGenericUndo(DbUndo):
self.undo_reference(new_data, handle) self.undo_reference(new_data, handle)
else: else:
self.undo_data(new_data, handle, key, db.emit, SIGBASE[key]) self.undo_data(new_data, handle, key, db.emit, SIGBASE[key])
self.db.transaction_backend_commit() self.db._txn_commit()
except: except:
self.db.transaction_backend_abort() self.db._txn_abort()
raise raise
# Notify listeners # Notify listeners
@ -179,7 +179,7 @@ class DbGenericUndo(DbUndo):
# Process all records in the transaction # Process all records in the transaction
try: try:
self.db.transaction_backend_begin() self.db._txn_begin()
for record_id in subitems: for record_id in subitems:
(key, trans_type, handle, old_data, new_data) = \ (key, trans_type, handle, old_data, new_data) = \
pickle.loads(self.undodb[record_id]) pickle.loads(self.undodb[record_id])
@ -189,9 +189,9 @@ class DbGenericUndo(DbUndo):
else: else:
self.undo_data(old_data, handle, key, db.emit, SIGBASE[key]) self.undo_data(old_data, handle, key, db.emit, SIGBASE[key])
self.db.transaction_backend_commit() self.db._txn_commit()
except: except:
self.db.transaction_backend_abort() self.db._txn_abort()
raise raise
# Notify listeners # Notify listeners
@ -541,7 +541,7 @@ class DbGeneric(DbWriteBase, DbReadBase, UpdateCallback, Callback):
if directory: if directory:
self.load(directory) self.load(directory)
def initialize_backend(self, directory): def _initialize(self, directory):
""" """
Initialize database backend. Initialize database backend.
""" """
@ -569,7 +569,7 @@ class DbGeneric(DbWriteBase, DbReadBase, UpdateCallback, Callback):
str(current_schema_version), str(current_schema_version),
str(current_schema_version)) str(current_schema_version))
# run backend-specific code: # run backend-specific code:
self.initialize_backend(directory) self._initialize(directory)
# Load metadata # Load metadata
self.name_formats = self.get_metadata('name_formats') self.name_formats = self.get_metadata('name_formats')
@ -640,7 +640,7 @@ class DbGeneric(DbWriteBase, DbReadBase, UpdateCallback, Callback):
""" """
self.load(self._directory) self.load(self._directory)
def close_backend(self): def _close(self):
""" """
Close database backend. Close database backend.
""" """
@ -661,7 +661,7 @@ class DbGeneric(DbWriteBase, DbReadBase, UpdateCallback, Callback):
touch(filename) touch(filename)
# Save metadata # Save metadata
self.transaction_backend_begin() self._txn_begin()
self.set_metadata('name_formats', self.name_formats) self.set_metadata('name_formats', self.name_formats)
self.set_metadata('researcher', self.owner) self.set_metadata('researcher', self.owner)
@ -712,9 +712,9 @@ class DbGeneric(DbWriteBase, DbReadBase, UpdateCallback, Callback):
self.set_metadata('omap_index', self.omap_index) self.set_metadata('omap_index', self.omap_index)
self.set_metadata('rmap_index', self.rmap_index) self.set_metadata('rmap_index', self.rmap_index)
self.set_metadata('nmap_index', self.nmap_index) self.set_metadata('nmap_index', self.nmap_index)
self.transaction_backend_commit() self._txn_commit()
self.close_backend() self._close()
self.db_is_open = False self.db_is_open = False
self._directory = None self._directory = None
@ -808,21 +808,21 @@ class DbGeneric(DbWriteBase, DbReadBase, UpdateCallback, Callback):
return self.get_table_func(table_name) return self.get_table_func(table_name)
return None return None
def transaction_backend_begin(self): def _txn_begin(self):
""" """
Lowlevel interface to the backend transaction. Lowlevel interface to the backend transaction.
Executes a db BEGIN; Executes a db BEGIN;
""" """
pass pass
def transaction_backend_commit(self): def _txn_commit(self):
""" """
Lowlevel interface to the backend transaction. Lowlevel interface to the backend transaction.
Executes a db END; Executes a db END;
""" """
pass pass
def transaction_backend_abort(self): def _txn_abort(self):
""" """
Lowlevel interface to the backend transaction. Lowlevel interface to the backend transaction.
Executes a db ROLLBACK; Executes a db ROLLBACK;

View File

@ -146,7 +146,7 @@ class DBAPI(DbGeneric):
shutil.copy2(settings_py, directory) shutil.copy2(settings_py, directory)
shutil.copy2(settings_ini, directory) shutil.copy2(settings_ini, directory)
def initialize_backend(self, directory): def _initialize(self, directory):
# Run code from directory # Run code from directory
from gramps.gen.utils.configmanager import ConfigManager from gramps.gen.utils.configmanager import ConfigManager
config_file = os.path.join(directory, 'settings.ini') config_file = os.path.join(directory, 'settings.ini')
@ -312,10 +312,10 @@ class DBAPI(DbGeneric):
'ON reference(obj_handle)') 'ON reference(obj_handle)')
def close_backend(self): def _close(self):
self.dbapi.close() self.dbapi.close()
def transaction_backend_begin(self): def _txn_begin(self):
""" """
Lowlevel interface to the backend transaction. Lowlevel interface to the backend transaction.
Executes a db BEGIN; Executes a db BEGIN;
@ -323,7 +323,7 @@ class DBAPI(DbGeneric):
_LOG.debug(" DBAPI %s transaction begin", hex(id(self))) _LOG.debug(" DBAPI %s transaction begin", hex(id(self)))
self.dbapi.begin() self.dbapi.begin()
def transaction_backend_commit(self): def _txn_commit(self):
""" """
Lowlevel interface to the backend transaction. Lowlevel interface to the backend transaction.
Executes a db END; Executes a db END;
@ -331,7 +331,7 @@ class DBAPI(DbGeneric):
_LOG.debug(" DBAPI %s transaction commit", hex(id(self))) _LOG.debug(" DBAPI %s transaction commit", hex(id(self)))
self.dbapi.commit() self.dbapi.commit()
def transaction_backend_abort(self): def _txn_abort(self):
""" """
Lowlevel interface to the backend transaction. Lowlevel interface to the backend transaction.
Executes a db ROLLBACK; Executes a db ROLLBACK;

View File

@ -37,7 +37,7 @@ class InMemoryDB(DBAPI):
}) })
return summary return summary
def initialize_backend(self, directory): def _initialize(self, directory):
""" """
Create an in-memory sqlite database. Create an in-memory sqlite database.
""" """