digiKam
Classes | Public Member Functions | Public Attributes | List of all members
Digikam::CoreDbBackendPrivate Class Reference
+ Inheritance diagram for Digikam::CoreDbBackendPrivate:

Classes

class  ChangesetContainer
 

Public Member Functions

bool checkOperationStatus ()
 
bool checkRetrySQLiteLockError (int retries)
 
void closeDatabaseForThread ()
 
void connectionErrorAbortQueries () override
 
void connectionErrorContinueQueries () override
 called by DbEngineErrorHandler, implementing DbEngineErrorAnswer More...
 
QString connectionName ()
 
 CoreDbBackendPrivate (CoreDbBackend *const backend)
 
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 sendToWatch (const AlbumChangeset &changeset)
 
void sendToWatch (const AlbumRootChangeset &changeset)
 
void sendToWatch (const CollectionImageChangeset &changeset)
 
void sendToWatch (const ImageChangeset &changeset)
 
void sendToWatch (const ImageTagChangeset &changeset)
 
void sendToWatch (const SearchChangeset &changeset)
 
void sendToWatch (const TagChangeset &changeset)
 
void setDatabaseErrorForThread (const QSqlError &lastError)
 
void setQueryOperationFlag (BdEngineBackend::QueryOperationStatus status)
 
void transactionFinished () override
 

Public Attributes

ChangesetContainer< AlbumChangeset > albumChangesetContainer
 
ChangesetContainer< AlbumRootChangeset > albumRootChangesetContainer
 
QString backendName
 
QWaitCondition busyWaitCondVar
 
QMutex busyWaitMutex
 
ChangesetContainer< CollectionImageChangeset > collectionImageChangesetContainer
 
int currentValidity
 
DbEngineErrorHandler * errorHandler
 
QWaitCondition errorLockCondVar
 
QMutex errorLockMutex
 
BdEngineBackend::QueryOperationStatus errorLockOperationStatus
 
ChangesetContainer< ImageChangeset > imageChangesetContainer
 
ChangesetContainer< ImageTagChangeset > imageTagChangesetContainer
 
bool isInTransaction
 
DbEngineLocking * lock
 
BdEngineBackend::QueryOperationStatus operationStatus
 
DbEngineParameters parameters
 
BdEngineBackend *const q
 
ChangesetContainer< SearchChangeset > searchChangesetContainer
 
BdEngineBackend::Status status
 
ChangesetContainer< TagChangeset > tagChangesetContainer
 
QThreadStorage< DbEngineThreadData * > threadDataStorage
 
CoreDbWatch * watch
 

Constructor & Destructor Documentation

◆ CoreDbBackendPrivate()

Digikam::CoreDbBackendPrivate::CoreDbBackendPrivate ( CoreDbBackend *const  backend)
inlineexplicit

Member Function Documentation

◆ checkOperationStatus()

bool Digikam::BdEngineBackendPrivate::checkOperationStatus ( )
inherited

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

◆ checkRetrySQLiteLockError()

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

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

◆ closeDatabaseForThread()

void Digikam::BdEngineBackendPrivate::closeDatabaseForThread ( )
inherited

References Digikam::BdEngineBackendPrivate::threadDataStorage.

Referenced by Digikam::BdEngineBackendPrivate::handleWithErrorHandler().

◆ connectionErrorAbortQueries()

void Digikam::BdEngineBackendPrivate::connectionErrorAbortQueries ( )
overridevirtualinherited

Implements Digikam::DbEngineErrorAnswer.

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

◆ connectionErrorContinueQueries()

void Digikam::BdEngineBackendPrivate::connectionErrorContinueQueries ( )
overridevirtualinherited

called by DbEngineErrorHandler, implementing DbEngineErrorAnswer

Implements Digikam::DbEngineErrorAnswer.

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

◆ connectionName()

QString Digikam::BdEngineBackendPrivate::connectionName ( )
inherited

References Digikam::BdEngineBackendPrivate::backendName.

Referenced by Digikam::BdEngineBackendPrivate::createDatabaseConnection().

◆ createDatabaseConnection()

QSqlDatabase Digikam::BdEngineBackendPrivate::createDatabaseConnection ( )
inherited

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

Referenced by Digikam::BdEngineBackendPrivate::databaseForThread().

◆ databaseErrorForThread()

QSqlError Digikam::BdEngineBackendPrivate::databaseErrorForThread ( )
inherited

References Digikam::BdEngineBackendPrivate::threadDataStorage.

◆ databaseForThread()

QSqlDatabase Digikam::BdEngineBackendPrivate::databaseForThread ( )
inherited

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

Referenced by Digikam::BdEngineBackendPrivate::handleWithErrorHandler().

◆ debugOutputFailedQuery()

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

◆ debugOutputFailedTransaction()

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

◆ decrementTransactionCount()

bool Digikam::BdEngineBackendPrivate::decrementTransactionCount ( )
inherited

References Digikam::BdEngineBackendPrivate::threadDataStorage.

◆ handleWithErrorHandler()

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

Returns true if the query shall be retried.

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

◆ incrementTransactionCount()

bool Digikam::BdEngineBackendPrivate::incrementTransactionCount ( )
inherited

References Digikam::BdEngineBackendPrivate::threadDataStorage.

◆ init()

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

References Digikam::BdEngineBackendPrivate::backendName, and Digikam::BdEngineBackendPrivate::lock.

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

◆ isConnectionError()

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

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

Referenced by Digikam::BdEngineBackendPrivate::handleWithErrorHandler(), and Digikam::BdEngineBackendPrivate::needToHandleWithErrorHandler().

◆ isInMainThread()

bool Digikam::BdEngineBackendPrivate::isInMainThread ( ) const
inherited

◆ isInUIThread()

bool Digikam::BdEngineBackendPrivate::isInUIThread ( ) const
inherited

Referenced by Digikam::BdEngineBackendPrivate::checkRetrySQLiteLockError().

◆ isSQLiteLockError()

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

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

◆ isSQLiteLockTransactionError()

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

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

◆ needToConsultUserForError()

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

Referenced by Digikam::BdEngineBackendPrivate::handleWithErrorHandler(), and Digikam::BdEngineBackendPrivate::needToHandleWithErrorHandler().

◆ needToHandleWithErrorHandler()

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

References Digikam::BdEngineBackendPrivate::isConnectionError(), and Digikam::BdEngineBackendPrivate::needToConsultUserForError().

◆ queryOperationWakeAll()

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

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

References Digikam::BdEngineBackendPrivate::errorLockCondVar, Digikam::BdEngineBackendPrivate::errorLockMutex, Digikam::BdEngineBackendPrivate::errorLockOperationStatus, Digikam::BdEngineBackendPrivate::operationStatus, and Digikam::BdEngineBackendPrivate::status.

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

◆ reconnectOnError()

bool Digikam::BdEngineBackendPrivate::reconnectOnError ( ) const
inherited

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

◆ sendToWatch() [1/7]

void Digikam::CoreDbBackendPrivate::sendToWatch ( const AlbumChangeset &  changeset)
inline

References Digikam::CoreDbWatch::sendAlbumChange().

◆ sendToWatch() [2/7]

void Digikam::CoreDbBackendPrivate::sendToWatch ( const AlbumRootChangeset &  changeset)
inline

References Digikam::CoreDbWatch::sendAlbumRootChange().

◆ sendToWatch() [3/7]

void Digikam::CoreDbBackendPrivate::sendToWatch ( const CollectionImageChangeset &  changeset)
inline

References Digikam::CoreDbWatch::sendCollectionImageChange().

◆ sendToWatch() [4/7]

void Digikam::CoreDbBackendPrivate::sendToWatch ( const ImageChangeset &  changeset)
inline

References Digikam::CoreDbWatch::sendImageChange().

◆ sendToWatch() [5/7]

void Digikam::CoreDbBackendPrivate::sendToWatch ( const ImageTagChangeset &  changeset)
inline

References Digikam::CoreDbWatch::sendImageTagChange().

◆ sendToWatch() [6/7]

void Digikam::CoreDbBackendPrivate::sendToWatch ( const SearchChangeset &  changeset)
inline

References Digikam::CoreDbWatch::sendSearchChange().

◆ sendToWatch() [7/7]

void Digikam::CoreDbBackendPrivate::sendToWatch ( const TagChangeset &  changeset)
inline

References Digikam::CoreDbWatch::sendTagChange().

◆ setDatabaseErrorForThread()

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

References Digikam::BdEngineBackendPrivate::threadDataStorage.

◆ setQueryOperationFlag()

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

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

References Digikam::BdEngineBackendPrivate::errorLockMutex, Digikam::BdEngineBackendPrivate::errorLockOperationStatus, Digikam::BdEngineBackendPrivate::operationStatus, and Digikam::BdEngineBackendPrivate::status.

Referenced by Digikam::BdEngineBackendPrivate::handleWithErrorHandler().

◆ transactionFinished()

void Digikam::CoreDbBackendPrivate::transactionFinished ( )
inlineoverridevirtual

Reimplemented from Digikam::BdEngineBackendPrivate.

References Digikam::CoreDbBackendPrivate::ChangesetContainer< T >::sendOut(), and Digikam::BdEngineBackendPrivate::transactionFinished().

Member Data Documentation

◆ albumChangesetContainer

ChangesetContainer<AlbumChangeset> Digikam::CoreDbBackendPrivate::albumChangesetContainer

◆ albumRootChangesetContainer

ChangesetContainer<AlbumRootChangeset> Digikam::CoreDbBackendPrivate::albumRootChangesetContainer

◆ backendName

QString Digikam::BdEngineBackendPrivate::backendName
inherited

Referenced by Digikam::BdEngineBackendPrivate::connectionName(), and Digikam::BdEngineBackendPrivate::init().

◆ busyWaitCondVar

QWaitCondition Digikam::BdEngineBackendPrivate::busyWaitCondVar
inherited

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

◆ busyWaitMutex

QMutex Digikam::BdEngineBackendPrivate::busyWaitMutex
inherited

◆ collectionImageChangesetContainer

ChangesetContainer<CollectionImageChangeset> Digikam::CoreDbBackendPrivate::collectionImageChangesetContainer

◆ currentValidity

int Digikam::BdEngineBackendPrivate::currentValidity
inherited

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

Referenced by Digikam::BdEngineBackendPrivate::databaseForThread().

◆ errorHandler

DbEngineErrorHandler* Digikam::BdEngineBackendPrivate::errorHandler
inherited

Referenced by Digikam::BdEngineBackendPrivate::handleWithErrorHandler().

◆ errorLockCondVar

QWaitCondition Digikam::BdEngineBackendPrivate::errorLockCondVar
inherited

Referenced by Digikam::BdEngineBackendPrivate::queryOperationWakeAll().

◆ errorLockMutex

QMutex Digikam::BdEngineBackendPrivate::errorLockMutex
inherited

Referenced by Digikam::BdEngineBackendPrivate::queryOperationWakeAll(), and Digikam::BdEngineBackendPrivate::setQueryOperationFlag().

◆ errorLockOperationStatus

BdEngineBackend::QueryOperationStatus Digikam::BdEngineBackendPrivate::errorLockOperationStatus
inherited

Referenced by Digikam::BdEngineBackendPrivate::handleWithErrorHandler(), Digikam::BdEngineBackendPrivate::queryOperationWakeAll(), and Digikam::BdEngineBackendPrivate::setQueryOperationFlag().

◆ imageChangesetContainer

ChangesetContainer<ImageChangeset> Digikam::CoreDbBackendPrivate::imageChangesetContainer

◆ imageTagChangesetContainer

ChangesetContainer<ImageTagChangeset> Digikam::CoreDbBackendPrivate::imageTagChangesetContainer

◆ isInTransaction

bool Digikam::BdEngineBackendPrivate::isInTransaction
inherited

◆ lock

DbEngineLocking* Digikam::BdEngineBackendPrivate::lock
inherited

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

◆ operationStatus

BdEngineBackend::QueryOperationStatus Digikam::BdEngineBackendPrivate::operationStatus
inherited

Referenced by Digikam::BdEngineBackendPrivate::checkOperationStatus(), Digikam::BdEngineBackendPrivate::handleWithErrorHandler(), Digikam::BdEngineBackendPrivate::queryOperationWakeAll(), and Digikam::BdEngineBackendPrivate::setQueryOperationFlag().

◆ parameters

DbEngineParameters Digikam::BdEngineBackendPrivate::parameters
inherited

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

◆ q

BdEngineBackend* const Digikam::BdEngineBackendPrivate::q
inherited

◆ searchChangesetContainer

ChangesetContainer<SearchChangeset> Digikam::CoreDbBackendPrivate::searchChangesetContainer

◆ status

BdEngineBackend::Status Digikam::BdEngineBackendPrivate::status
inherited

Referenced by Digikam::BdEngineBackendPrivate::queryOperationWakeAll(), and Digikam::BdEngineBackendPrivate::setQueryOperationFlag().

◆ tagChangesetContainer

ChangesetContainer<TagChangeset> Digikam::CoreDbBackendPrivate::tagChangesetContainer

◆ threadDataStorage

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

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

◆ watch

CoreDbWatch* Digikam::CoreDbBackendPrivate::watch
The documentation for this class was generated from the following file: