Inheritance diagram for Digikam::BdEngineBackendPrivate:

Classes
class	AbstractUnlocker

class	AbstractWaitingUnlocker

class	BusyWaiter

class	ErrorLocker

Public Member Functions
	BdEngineBackendPrivate (BdEngineBackend *const backend)

bool	checkOperationStatus ()

bool	checkRetrySQLiteLockError (int retries)

void	closeDatabaseForThread ()

void	connectionErrorAbortQueries () override

void	connectionErrorContinueQueries () override
	called by DbEngineErrorHandler, implementing DbEngineErrorAnswer More...

QString	connectionName ()

QSqlDatabase	createDatabaseConnection ()

QSqlError	databaseErrorForThread ()

QSqlDatabase	databaseForThread ()

void	debugOutputFailedQuery (const QSqlQuery &query) const

void	debugOutputFailedTransaction (const QSqlError &error) const

bool	decrementTransactionCount ()

bool	handleWithErrorHandler (const DbEngineSqlQuery *const query)
	Returns true if the query shall be retried. More...

bool	incrementTransactionCount ()

void	init (const QString &connectionName, DbEngineLocking *const locking)

bool	isConnectionError (const DbEngineSqlQuery &query) const

bool	isInMainThread () const

bool	isInUIThread () const

bool	isSQLiteLockError (const DbEngineSqlQuery &query) const

bool	isSQLiteLockTransactionError (const QSqlError &lastError) const

bool	needToConsultUserForError (const DbEngineSqlQuery &query) const

bool	needToHandleWithErrorHandler (const DbEngineSqlQuery &query) const

void	queryOperationWakeAll (BdEngineBackend::QueryOperationStatus status)

bool	reconnectOnError () const

void	setDatabaseErrorForThread (const QSqlError &lastError)

void	setQueryOperationFlag (BdEngineBackend::QueryOperationStatus status)

virtual void	transactionFinished ()

	~BdEngineBackendPrivate () override

Public Attributes
QString	backendName

QWaitCondition	busyWaitCondVar

QMutex	busyWaitMutex

int	currentValidity

DbEngineErrorHandler *	errorHandler

QWaitCondition	errorLockCondVar

QMutex	errorLockMutex

BdEngineBackend::QueryOperationStatus	errorLockOperationStatus

bool	isInTransaction

DbEngineLocking *	lock

BdEngineBackend::QueryOperationStatus	operationStatus

DbEngineParameters	parameters

BdEngineBackend *const	q

BdEngineBackend::Status	status

QThreadStorage< DbEngineThreadData * >	threadDataStorage

Friends
class	AbstractUnlocker

Constructor & Destructor Documentation

◆ BdEngineBackendPrivate()

Digikam::BdEngineBackendPrivate::BdEngineBackendPrivate ( BdEngineBackend *const backend )

explicit

◆ ~BdEngineBackendPrivate()

Digikam::BdEngineBackendPrivate::~BdEngineBackendPrivate ( )

override

References threadDataStorage.

Member Function Documentation

◆ checkOperationStatus()

bool Digikam::BdEngineBackendPrivate::checkOperationStatus ( )

References Digikam::BdEngineBackend::AbortQueries, Digikam::BdEngineBackend::ExecuteNormal, operationStatus, Digikam::BdEngineBackend::Wait, and Digikam::BdEngineBackendPrivate::ErrorLocker::wait().

◆ checkRetrySQLiteLockError()

bool Digikam::BdEngineBackendPrivate::checkRetrySQLiteLockError ( int retries )

References isInUIThread(), and Digikam::BdEngineBackendPrivate::AbstractWaitingUnlocker::wait().

◆ closeDatabaseForThread()

void Digikam::BdEngineBackendPrivate::closeDatabaseForThread ( )

References threadDataStorage.

Referenced by handleWithErrorHandler().

◆ connectionErrorAbortQueries()

void Digikam::BdEngineBackendPrivate::connectionErrorAbortQueries ( )

overridevirtual

Implements Digikam::DbEngineErrorAnswer.

References Digikam::BdEngineBackend::AbortQueries, lock, Digikam::DbEngineLocking::mutex, and queryOperationWakeAll().

◆ connectionErrorContinueQueries()

void Digikam::BdEngineBackendPrivate::connectionErrorContinueQueries ( )

overridevirtual

called by DbEngineErrorHandler, implementing DbEngineErrorAnswer

Implements Digikam::DbEngineErrorAnswer.

References Digikam::BdEngineBackend::ExecuteNormal, lock, Digikam::DbEngineLocking::mutex, and queryOperationWakeAll().

◆ connectionName()

QString Digikam::BdEngineBackendPrivate::connectionName ( )

References backendName.

Referenced by createDatabaseConnection().

◆ createDatabaseConnection()

QSqlDatabase Digikam::BdEngineBackendPrivate::createDatabaseConnection ( )

References connectionName(), Digikam::DbEngineParameters::connectOptions, Digikam::DbEngineParameters::databaseNameCore, Digikam::DbEngineParameters::databaseType, Digikam::DbEngineParameters::hostName, Digikam::DbEngineParameters::isSQLite(), parameters, Digikam::DbEngineParameters::password, Digikam::DbEngineParameters::port, and Digikam::DbEngineParameters::userName.

Referenced by databaseForThread().

◆ databaseErrorForThread()

QSqlError Digikam::BdEngineBackendPrivate::databaseErrorForThread ( )

References threadDataStorage.

◆ databaseForThread()

QSqlDatabase Digikam::BdEngineBackendPrivate::databaseForThread ( )

References Digikam::DbEngineThreadData::closeDatabase(), createDatabaseConnection(), currentValidity, Digikam::DbEngineThreadData::database, threadDataStorage, and Digikam::DbEngineThreadData::valid.

Referenced by handleWithErrorHandler().

◆ debugOutputFailedQuery()

void Digikam::BdEngineBackendPrivate::debugOutputFailedQuery ( const QSqlQuery & query ) const

◆ debugOutputFailedTransaction()

void Digikam::BdEngineBackendPrivate::debugOutputFailedTransaction ( const QSqlError & error ) const

◆ decrementTransactionCount()

bool Digikam::BdEngineBackendPrivate::decrementTransactionCount ( )

References threadDataStorage.

◆ handleWithErrorHandler()

bool Digikam::BdEngineBackendPrivate::handleWithErrorHandler ( const DbEngineSqlQuery *const query )

Returns true if the query shall be retried.

References Digikam::BdEngineBackend::AbortQueries, closeDatabaseForThread(), databaseForThread(), errorHandler, errorLockOperationStatus, Digikam::BdEngineBackend::ExecuteNormal, isConnectionError(), Digikam::DbEngineSqlQuery::lastQuery(), needToConsultUserForError(), operationStatus, setQueryOperationFlag(), Digikam::BdEngineBackend::Wait, and Digikam::BdEngineBackendPrivate::ErrorLocker::wait().

◆ incrementTransactionCount()

bool Digikam::BdEngineBackendPrivate::incrementTransactionCount ( )

References threadDataStorage.

◆ init()

void Digikam::BdEngineBackendPrivate::init	(	const QString &	connectionName,
		DbEngineLocking *const	locking
	)

References backendName, and lock.

Referenced by Digikam::BdEngineBackend::BdEngineBackend().

◆ isConnectionError()

bool Digikam::BdEngineBackendPrivate::isConnectionError ( const DbEngineSqlQuery & query ) const

References Digikam::DbEngineParameters::isSQLite(), and parameters.

Referenced by handleWithErrorHandler(), and needToHandleWithErrorHandler().

◆ isInMainThread()

bool Digikam::BdEngineBackendPrivate::isInMainThread ( ) const

◆ isInUIThread()

bool Digikam::BdEngineBackendPrivate::isInUIThread ( ) const

Referenced by checkRetrySQLiteLockError().

◆ isSQLiteLockError()

bool Digikam::BdEngineBackendPrivate::isSQLiteLockError ( const DbEngineSqlQuery & query ) const

References Digikam::DbEngineParameters::isSQLite(), and parameters.

◆ isSQLiteLockTransactionError()

bool Digikam::BdEngineBackendPrivate::isSQLiteLockTransactionError ( const QSqlError & lastError ) const

References Digikam::DbEngineParameters::isSQLite(), and parameters.

◆ needToConsultUserForError()

bool Digikam::BdEngineBackendPrivate::needToConsultUserForError ( const DbEngineSqlQuery & query ) const

Referenced by handleWithErrorHandler(), and needToHandleWithErrorHandler().

◆ needToHandleWithErrorHandler()

bool Digikam::BdEngineBackendPrivate::needToHandleWithErrorHandler ( const DbEngineSqlQuery & query ) const

References isConnectionError(), and needToConsultUserForError().

◆ queryOperationWakeAll()

void Digikam::BdEngineBackendPrivate::queryOperationWakeAll ( BdEngineBackend::QueryOperationStatus status )

Set the wait flag to queryStatus and wake all waiting threads. Typically, call wakeAll with status ExecuteNormal or AbortQueries.

References errorLockCondVar, errorLockMutex, errorLockOperationStatus, operationStatus, and status.

Referenced by connectionErrorAbortQueries(), and connectionErrorContinueQueries().

◆ reconnectOnError()

bool Digikam::BdEngineBackendPrivate::reconnectOnError ( ) const

References Digikam::DbEngineParameters::isMySQL(), and parameters.

◆ setDatabaseErrorForThread()

void Digikam::BdEngineBackendPrivate::setDatabaseErrorForThread ( const QSqlError & lastError )

References threadDataStorage.

◆ setQueryOperationFlag()

void Digikam::BdEngineBackendPrivate::setQueryOperationFlag ( BdEngineBackend::QueryOperationStatus status )

Set the wait flag to queryStatus. Typically, call this with Wait.

References errorLockMutex, errorLockOperationStatus, operationStatus, and status.

Referenced by handleWithErrorHandler().

◆ transactionFinished()

void Digikam::BdEngineBackendPrivate::transactionFinished ( )

virtual

Reimplemented in Digikam::CoreDbBackendPrivate.

References busyWaitCondVar.

Referenced by Digikam::CoreDbBackendPrivate::transactionFinished().

Friends And Related Function Documentation

◆ AbstractUnlocker

friend class AbstractUnlocker

friend

Member Data Documentation

◆ backendName

QString Digikam::BdEngineBackendPrivate::backendName

Referenced by connectionName(), and init().

◆ busyWaitCondVar

QWaitCondition Digikam::BdEngineBackendPrivate::busyWaitCondVar

Referenced by transactionFinished().

◆ busyWaitMutex

QMutex Digikam::BdEngineBackendPrivate::busyWaitMutex

◆ currentValidity

int Digikam::BdEngineBackendPrivate::currentValidity

This compares to DbEngineThreadData's valid. If currentValidity is increased and > valid, the db is marked as invalid

Referenced by databaseForThread().

◆ errorHandler

DbEngineErrorHandler* Digikam::BdEngineBackendPrivate::errorHandler

Referenced by handleWithErrorHandler().

◆ errorLockCondVar

QWaitCondition Digikam::BdEngineBackendPrivate::errorLockCondVar

Referenced by queryOperationWakeAll().

◆ errorLockMutex

QMutex Digikam::BdEngineBackendPrivate::errorLockMutex

Referenced by queryOperationWakeAll(), and setQueryOperationFlag().

◆ errorLockOperationStatus

BdEngineBackend::QueryOperationStatus Digikam::BdEngineBackendPrivate::errorLockOperationStatus

Referenced by handleWithErrorHandler(), queryOperationWakeAll(), and setQueryOperationFlag().

◆ isInTransaction

bool Digikam::BdEngineBackendPrivate::isInTransaction

◆ lock

DbEngineLocking* Digikam::BdEngineBackendPrivate::lock

Referenced by Digikam::BdEngineBackendPrivate::AbstractUnlocker::AbstractUnlocker(), connectionErrorAbortQueries(), connectionErrorContinueQueries(), and init().

◆ operationStatus

BdEngineBackend::QueryOperationStatus Digikam::BdEngineBackendPrivate::operationStatus

Referenced by checkOperationStatus(), handleWithErrorHandler(), queryOperationWakeAll(), and setQueryOperationFlag().

◆ parameters

DbEngineParameters Digikam::BdEngineBackendPrivate::parameters

Referenced by createDatabaseConnection(), isConnectionError(), isSQLiteLockError(), isSQLiteLockTransactionError(), and reconnectOnError().

◆ q

BdEngineBackend* const Digikam::BdEngineBackendPrivate::q

◆ status

BdEngineBackend::Status Digikam::BdEngineBackendPrivate::status

Referenced by queryOperationWakeAll(), and setQueryOperationFlag().

◆ threadDataStorage

QThreadStorage<DbEngineThreadData*> Digikam::BdEngineBackendPrivate::threadDataStorage

Referenced by closeDatabaseForThread(), databaseErrorForThread(), databaseForThread(), decrementTransactionCount(), incrementTransactionCount(), setDatabaseErrorForThread(), and ~BdEngineBackendPrivate().

The documentation for this class was generated from the following files:

core/libs/database/engine/dbenginebackend_p.h
core/libs/database/engine/dbenginebackend.cpp

Classes

Public Member Functions

Public Attributes

Friends

Constructor & Destructor Documentation

◆ BdEngineBackendPrivate()

◆ ~BdEngineBackendPrivate()

Member Function Documentation

◆ checkOperationStatus()

◆ checkRetrySQLiteLockError()

◆ closeDatabaseForThread()

◆ connectionErrorAbortQueries()

◆ connectionErrorContinueQueries()

◆ connectionName()

◆ createDatabaseConnection()

◆ databaseErrorForThread()

◆ databaseForThread()

◆ debugOutputFailedQuery()

◆ debugOutputFailedTransaction()

◆ decrementTransactionCount()

◆ handleWithErrorHandler()

◆ incrementTransactionCount()

◆ init()

◆ isConnectionError()

◆ isInMainThread()

◆ isInUIThread()

◆ isSQLiteLockError()

◆ isSQLiteLockTransactionError()

◆ needToConsultUserForError()

◆ needToHandleWithErrorHandler()

◆ queryOperationWakeAll()

◆ reconnectOnError()

◆ setDatabaseErrorForThread()

◆ setQueryOperationFlag()

◆ transactionFinished()

Friends And Related Function Documentation

◆ AbstractUnlocker

Member Data Documentation

◆ backendName

◆ busyWaitCondVar

◆ busyWaitMutex

◆ currentValidity

◆ errorHandler

◆ errorLockCondVar

◆ errorLockMutex

◆ errorLockOperationStatus

◆ isInTransaction

◆ lock

◆ operationStatus

◆ parameters

◆ q

◆ status

◆ threadDataStorage