// Connector
//
// Douglas Thrift
//
// $Id$

#ifndef _Connector_hpp_
#define _Connector_hpp_

#include <cxx/platform.hpp>

#ifdef MENES_PRAGMA_ONCE
#pragma once
#endif

#include <api/threads.hpp>
#include <dbi/driver.hpp>
#include <dbi/connection.hpp>
#include <ext/stack.hpp>

class Connector : public ext::ReferenceCounted
{
private:
	_R<dbi::Driver> driver;
	cse::String host, user, password, database;
	api::ThreadMutex connectionsLock;
	ext::Stack<_R<dbi::Connection> > connections;
	bool running;
	_S<api::Thread> cleanup;
	int Cleanup();
public:
	Connector(const cse::String& configuration);
	~Connector() { running = false; cleanup.Join(); }
	_R<dbi::Connection> Connect();
	void Release(const _R<dbi::Connection>& connection);
};

#endif//_Connector_hpp_