ConnectionVectorSh.hpp

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

#ifndef FIRE_PLUGIN_DATA_SHARED_CONNECTIONVECTORSH_HPP_INCLUDED
#define FIRE_PLUGIN_DATA_SHARED_CONNECTIONVECTORSH_HPP_INCLUDED

#include <string>
#include <exception>

#include "fire/gis/export.hpp"
#include "fire/exception/Exception.hpp"
#include "fire/source/shared/ConnectionSh.hpp"
#include "fire/source/vector/ConnectionVector.hpp"
#include "fire/source/vector/shared/DataSetSh.hpp"

namespace fire {
namespace source {
namespace vector {
namespace shared {

class FIRE_GIS_DLL ConnectionVectorSh : public source::shared::ConnectionSh {
 public:
  explicit ConnectionVectorSh(ConnectionVector* ptr): source::shared::ConnectionSh(ptr) {
  }

  explicit ConnectionVectorSh(source::shared::ConnectionSh const & c): source::shared::ConnectionSh(c) {
  }

  inline ConnectionVectorSh & operator=(ConnectionVectorSh const & c) {
        source::shared::ConnectionSh::operator =(c);
        return *this;
  }

  inline ConnectionVectorSh & operator=(source::shared::ConnectionSh const & c) {
        source::shared::ConnectionSh::operator =(c);
        return *this;
  }

  inline virtual bool isEmpty() const {
    return _getPtr() == NULL;
  }

  inline virtual VectorLayerInfo::VectorLayerInfoShp getLayerInfo(std::string const & name) const {
      return _getPtr()->getLayerInfo(name);
  }

  inline virtual DataSet::DataSetShp const getData(const std::string &schema, std::string const & tbl) const  {
      return _getPtr()->getData(schema, tbl);
  }

  inline VectorLayerInfo::VectorLayerInfoShp createTable(const Metadata::MetadataShp& mtd) {
      return _getPtr()->createTable(mtd);
  }

  inline VectorLayerInfo::VectorLayerInfoShp createTable(const Metadata::MetadataShp& mtd, const source::vector::VectorLayerInfo::VctEnvelope& extents) {
      return _getPtr()->createTable(mtd, extents);
  }

  inline virtual DataSet::DataSetShp getData(const std::string &schema, std::string const & tbl)  {
      return _getPtr()->getData(schema, tbl);
  }

  inline virtual DataSet::DataSetShp const getData(const std::string &schema, std::string const & tbl, gear::geom::Envelope::EnvelopeShp const & rect) const {
      return _getPtr()->getData(schema, tbl, rect);
  }

  inline virtual DataSet::DataSetShp getData(const std::string &schema, std::string const & tbl, gear::geom::Envelope::EnvelopeShp const & rect)  {
      return _getPtr()->getData(schema, tbl, rect);
  }

  inline virtual DataSet::DataSetShp const execQuery(std::string const & query, const DataRow::MapSqlParam& params = DataRow::MapSqlParam()) const {
      return _getPtr()->execQuery(query, params);
  }

  inline virtual DataSet::DataSetShp execQuery(std::string const & query, const DataRow::MapSqlParam& params = DataRow::MapSqlParam())  {
      return _getPtr()->execQuery(query, params);
  }

  inline virtual void eraseTable(const std::string& schema, const std::string& tbl, const VectorLayerType::VectorLayerType vlt)  {
      return _getPtr()->eraseTable(schema, tbl, vlt);
  }

  inline virtual void execUpdate(std::string const & query, DataRow::MapSqlParam const & params)  {
      _getPtr()->execUpdate(query, params);
  }

  inline virtual void execUpdate(std::string const & query)  {
      _getPtr()->execUpdate(query);
  }

  inline virtual void saveOrUpdate(DataRow& row)  {
      _getPtr()->saveOrUpdate(row);
  }

  inline virtual void insert(DataRow& row)  {
      _getPtr()->insert(row);
  }

  inline virtual void update(DataRow& row)  {
      _getPtr()->update(row);
  }

  inline virtual void erase(DataRow& row)  {
      _getPtr()->erase(row);
  }

 private:
  inline ConnectionVector* _getPtr() {
      ConnectionVector* ret = dynamic_cast< ConnectionVector* >(_ptr.get());
      if (NULL == ret)
          throw fire::exception::Exception("Invalid ConnectionVector pointer");

      return ret;
  }

  inline const ConnectionVector* _getPtr() const {
      const ConnectionVector* ret  = dynamic_cast< const ConnectionVector* >(_ptr.get());
      if (NULL == ret)
          throw fire::exception::Exception("Invalid ConnectionVector pointer");

      return ret;
  }
};
}  // namespace shared
}  // namespace vector
}  // namespace source
}  // namespace fire

#endif