Connection.hpp

// Copyright © 2015 GEOSYSTEMS SRL
// All Rights Reserved.

#ifndef FIRE_DATA_CONNECTION_HPP_INCLUDED
#define FIRE_DATA_CONNECTION_HPP_INCLUDED

#include <fire/Object.hpp>
#include <fire/logging/Logger.hpp>
#include <boost/thread/mutex.hpp>

#include <exception>
#include <string>
#include <vector>
#include <map>

#include "fire/gis/export.hpp"
#include "fire/source/Features.hpp"
#include "fire/source/ConnectionType.hpp"
#include "fire/source/vector/shared/VectorLayerInfoSh.hpp"

namespace fire {
namespace source {

namespace shared {
class ConnectionSh;
}  // namespace shared

class FIRE_GIS_DLL Connection : public fire::Object {
 public:
  typedef std::map< int, std::string > ConnectionParams;
  typedef std::vector< std::string > LayerList;
  typedef shared::ConnectionSh ConnectionShp;

  friend class shared::ConnectionSh;

  enum paramName {
      HOST = 1,
      DATASOURCE = 2,
      USER = 3,
      PASSWORD = 4,
      PORT = 5
  };

  static std::string idFromParams(Connection::ConnectionParams const & params);

  Connection();

  virtual ~Connection();

 protected:
  ConnectionParams const & getConnectionString() const;

  void open();

  void open(ConnectionParams const & cnnStr);

  bool isOpen() const;

  virtual bool isValid() const = 0;

  void close();

  virtual ConnectionType::ConnectionType getType() const;

  virtual Features const getFeatures() const = 0;

  virtual LayerList getLayers() const = 0;

  virtual std::string getNamespace() const = 0;

  void setId(const std::string& pool, const std::string& id);

  std::string getId() const;

  std::string getInstanceId() const;

  std::string getPoolId() const;

  void setConnectionString(const Connection::ConnectionParams& val);

// protected:
  virtual void _openNoWait() = 0;
  virtual void _closeNoWait() = 0;

  const ConnectionParams& _getConnectionStringNoWait() const;

  const std::string _readParam(ConnectionParams const & pars, unsigned int const & name) const;

  const int _readIntParam(ConnectionParams const & pars, unsigned int const & name) const;

  std::string _getPoolIdNoWait() const;

  std::string _getInstanceIdNoWait() const;

  virtual bool _isOpenNoWait() const;

  bool _isOpen;
  fire::logging::Logger * _log;
  mutable boost::mutex _mtx;

 private:
  Connection(Connection const & c) {}
  Connection & operator=(Connection const &) { return *this; }

  std::string _poolId;
  std::string _instanceId;
  Connection::ConnectionParams _cnnStr;
};

}  // namespace source
}  // namespace fire

#endif