database.hpp

Go to the documentation of this file.

#ifndef TIP_DB_PG_DATABASE_HPP_
#define TIP_DB_PG_DATABASE_HPP_

#include <string>
#include <memory>
#include <functional>
#include <map>
#include <boost/asio.hpp>
#include <boost/system/error_code.hpp>
#include <boost/optional.hpp>

#include <tip/db/pg/common.hpp>

namespace tip {
namespace db {
namespace pg {

namespace detail {
struct database_impl;
}
class db_service {
public:
    typedef boost::system::error_code error_code;

    typedef std::map< std::string, std::string > connection_params;
    typedef boost::optional<size_t> optional_size;
public:
    static const size_t DEFAULT_POOOL_SIZE = 4;
public:
    static void
    initialize(size_t pool_size, connection_params const& defaults);

    static void
    add_connection(std::string const& connection_string,
            optional_size pool_size = optional_size());

    static void
    begin(dbalias const&, transaction_callback const&,
            error_callback const&);

    static void
    run();
    static void
    stop();

    static boost::asio::io_service&
    io_service();
private:
    // No instances
    db_service() {}

    typedef std::shared_ptr<detail::database_impl> pimpl;
    static pimpl pimpl_;

    static pimpl
    impl(size_t pool_size = DEFAULT_POOOL_SIZE,
            connection_params const& defaults = {});
};

}  // namespace pg
}  // namespace db
}  // namespace tip

#endif /* TIP_DB_PG_DATABASE_HPP_ */