X-Git-Url: https://git.stg.codes/stg.git/blobdiff_plain/f907011b4827e85763372cdea76944b3b1cc3fd2..3bbc755fc0e1ab3a1e47cb39c4eeaa986d4b0d8b:/projects/stargazer/plugins/store/firebird/firebird_store.cpp diff --git a/projects/stargazer/plugins/store/firebird/firebird_store.cpp b/projects/stargazer/plugins/store/firebird/firebird_store.cpp index 8bddf9ca..3c4f32ad 100644 --- a/projects/stargazer/plugins/store/firebird/firebird_store.cpp +++ b/projects/stargazer/plugins/store/firebird/firebird_store.cpp @@ -26,18 +26,23 @@ * */ -#include -#include -#include +#include "firebird_store.h" #include "stg/ibpp.h" #include "stg/plugin_creator.h" -#include "stg/logger.h" -#include "firebird_store.h" -using namespace std; +#include +#include +#include + +#include +namespace +{ PLUGIN_CREATOR frsc; +} + +extern "C" STORE * GetStore(); //----------------------------------------------------------------------------- STORE * GetStore() { @@ -59,7 +64,7 @@ FIREBIRD_STORE::FIREBIRD_STORE() til(IBPP::ilConcurrency), tlr(IBPP::lrWait), schemaVersion(0), - WriteServLog(GetStgLogger()) + logger(GetPluginLogger(GetStgLogger(), "store_firebird")) { pthread_mutex_init(&mutex, NULL); } @@ -71,61 +76,47 @@ db->Disconnect(); //----------------------------------------------------------------------------- int FIREBIRD_STORE::ParseSettings() { -vector::iterator i; -string s; +std::vector::iterator i; +std::string s; for(i = settings.moduleParams.begin(); i != settings.moduleParams.end(); ++i) { s = i->param; - transform(s.begin(), s.end(), s.begin(), ToLower()); + + std::transform(s.begin(), s.end(), s.begin(), ::tolower); + if (s == "server") - { db_server = *(i->value.begin()); - } + if (s == "database") - { db_database = *(i->value.begin()); - } + if (s == "user") - { db_user = *(i->value.begin()); - } + if (s == "password") - { db_password = *(i->value.begin()); - } // Advanced settings block if (s == "isolationLevel") { if (*(i->value.begin()) == "Concurrency") - { til = IBPP::ilConcurrency; - } else if (*(i->value.begin()) == "DirtyRead") - { til = IBPP::ilReadDirty; - } else if (*(i->value.begin()) == "ReadCommitted") - { til = IBPP::ilReadCommitted; - } else if (*(i->value.begin()) == "Consistency") - { til = IBPP::ilConsistency; - } } + if (s == "lockResolution") { if (*(i->value.begin()) == "Wait") - { tlr = IBPP::lrWait; - } else if (*(i->value.begin()) == "NoWait") - { tlr = IBPP::lrNoWait; - } } } @@ -150,8 +141,6 @@ int FIREBIRD_STORE::CheckVersion() IBPP::Transaction tr = IBPP::TransactionFactory(db, IBPP::amRead, til, tlr); IBPP::Statement st = IBPP::StatementFactory(db, tr); -string name; - try { tr->Start(); @@ -167,7 +156,7 @@ try st->Get(1, schemaVersion); } tr->Commit(); - WriteServLog("FIREBIRD_STORE: Current DB schema version: %d", schemaVersion); + logger("FIREBIRD_STORE: Current DB schema version: %d", schemaVersion); } catch (IBPP::Exception & ex)