*
*/
+#include "postgresql_store.h"
+
+#include "stg/common.h" // str2x, printfd
+
#include <string>
#include <vector>
#include <libpq-fe.h>
-#include "stg/module_settings.h"
-#include "stg/plugin_creator.h"
-#include "postgresql_store_utils.h"
-#include "postgresql_store.h"
-
-namespace
-{
-PLUGIN_CREATOR<POSTGRESQL_STORE> pgsc;
-}
-
-extern "C" STORE * GetStore();
-
-//-----------------------------------------------------------------------------
-STORE * GetStore()
+extern "C" STG::Store* GetStore()
{
-return pgsc.GetPlugin();
+ static POSTGRESQL_STORE plugin;
+ return &plugin;
}
//-----------------------------------------------------------------------------
version(0),
retries(3),
connection(NULL),
- logger(GetPluginLogger(GetStgLogger(), "store_postgresql"))
+ logger(STG::PluginLogger::get("store_postgresql"))
{
-pthread_mutex_init(&mutex, NULL);
}
//-----------------------------------------------------------------------------
POSTGRESQL_STORE::~POSTGRESQL_STORE()
{
PQfinish(connection);
}
-pthread_mutex_destroy(&mutex);
}
//-----------------------------------------------------------------------------
int POSTGRESQL_STORE::ParseSettings()
{
-std::vector<PARAM_VALUE>::iterator i;
-std::string s;
+std::vector<STG::ParamValue>::iterator i;
for(i = settings.moduleParams.begin(); i != settings.moduleParams.end(); ++i)
{
if (i->value.empty())
continue;
- s = ToLower(i->param);
+ std::string s = ToLower(i->param);
if (s == "server")
{
server = i->value.front();