|| || || || || || || ||

---

RepositoryInMonetDB.h

Go to the documentation of this file.

#ifndef Impala_Persistency_RepositoryInMonetDB_h
#define Impala_Persistency_RepositoryInMonetDB_h

#include "Link/Monet/Connection.h"
#include "Basis/StringList.h"
#include "Persistency/Locator.h"
#include "Util/SimpleMap.h"

namespace Impala
{
namespace Persistency
{


class RepositoryInMonetDB
{
public:
    typedef Link::Monet::Connection Connection;

    static RepositoryInMonetDB&
    GetInstance()
    {
        static RepositoryInMonetDB theRepositoryInMonetDB;
        return theRepositoryInMonetDB;
    }

    Connection*
    GetConnection(const Locator& loc)
    {
        Connection* conn = 0;
        if (mMap.Get(loc.ToString(), conn))
            return conn;

        StringList sl(loc.GetHost(), ':');
        std::cout << "list size = " << sl.size() << std::endl;
        StringListCI it = sl.begin();
        if (it == sl.end())
        {
            ILOG_ERROR("Missing host specification for mapi");
            return 0;
        }

        String host = *it++;
        if (it == sl.end())
        {
            ILOG_ERROR("Missing port specification for mapi");
            return 0;
        }

        int port = atol(*it++);
        String setName = loc.GetDataSet();
        String db = (it == sl.end()) ? FileNameBase(setName) : *it;
        ILOG_INFO("Mapi connection to " << host << ":" << port << ":" << db);
        conn = new Connection(host, port, db);
        if (!conn->Valid())
        {
            ILOG_ERROR("Failed to set up connection to " << host << ":" <<
                       port << ":" << db);
            delete conn;
            return 0;
        }

        mMap.Add(loc.ToString(), conn);
        return conn;
    }

private:

    RepositoryInMonetDB()
    {
    }

    Util::SimpleMapDelete<String, Connection*> mMap;

    ILOG_VAR_DEC;

};

ILOG_VAR_INIT(RepositoryInMonetDB, Impala.Persistency);

} // namespace Persistency
} // namespace Impala

#endif

---