ConnectionQtSql.hpp

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

#ifndef FIRE_CONNECTION_QT_CONNECTIONQTSQL_HPP_INCLUDED
#define FIRE_CONNECTION_QT_CONNECTIONQTSQL_HPP_INCLUDED

#include <QtSql/QSqlError>
#include <QtSql/QSqlQuery>
#include <boost/thread.hpp>
#include <QtCore/QByteArray>
#include <QtSql/QSqlDatabase>
#include <fire/logging/Logger.hpp>
#include <boost/thread/mutex.hpp>
#include <fire/source/vector/Metadata.hpp>
#include <boost/thread/condition_variable.hpp>
#include <fire/gear/geom/shared/EnvelopeSh.hpp>
#include <fire/source/vector/shared/MetadataSh.hpp>

#include <string>
#include <exception>

#include "fire/source/vector/ConnectionSpatialDb.hpp"

namespace fire {
namespace connection {
namespace qt {

namespace shared {
class ConnectionQtSqlSh;
}  // namespace shared

class ConnectionQtSql : public source::vector::ConnectionSpatialDb {
 public:
  typedef shared::ConnectionQtSqlSh ConnectionQtSqlShp;

  static void qtToVal(source::vector::DataValue::DataValueShp& data, QVariant const & val, const std::string& poolName);

  static QVariant valToQt(const source::vector::DataValue::DataValueShp& val);

  ConnectionQtSql();

  virtual ~ConnectionQtSql();

  virtual void beginTransaction();
  virtual void commitTransaction();
  virtual void rollbackTransaction();

  virtual bool isValid() const;
  virtual source::Features const getFeatures() const;
  virtual LayerList getLayers() const;
  virtual source::vector::VectorLayerInfo::VectorLayerInfoShp getLayerInfo(std::string const & name) const;
  virtual source::vector::DataSet::DataSetShp const getData(const std::string &schema, std::string const & tbl) const;
  virtual source::vector::DataSet::DataSetShp getData(const std::string &schema, std::string const & tbl);
  virtual source::vector::DataSet::DataSetShp const getData(const std::string &schema, std::string const & tbl, gear::geom::Envelope::EnvelopeShp const & rect) const;
  virtual source::vector::DataSet::DataSetShp getData(const std::string &schema, std::string const & tbl, const gear::geom::Envelope::EnvelopeShp &rect);
  virtual source::vector::DataSet::DataSetShp const execQuery(std::string const & sql, const source::vector::DataRow::MapSqlParam& params = source::vector::DataRow::MapSqlParam()) const;
  virtual source::vector::DataSet::DataSetShp execQuery(std::string const & sql, const source::vector::DataRow::MapSqlParam& params = source::vector::DataRow::MapSqlParam());
  virtual void execUpdate(std::string const & sql, const source::vector::DataRow::MapSqlParam &params);
  using source::vector::ConnectionSpatialDb::execUpdate;
  virtual source::vector::VectorLayerInfo::VectorLayerInfoShp createTable(const source::vector::Metadata::MetadataShp & mtd, const source::vector::VectorLayerInfo::VctEnvelope& extents);

  virtual gear::geom::Geometry* buff2Geom(const QByteArray& buff) const;
  size_t getCount(const std::string & name, const std::string & schema) const;
  int getSrid(const std::string & name, const std::string & schema, const std::string & geom) const;
  virtual source::vector::Metadata::MetadataShp buildMetadata(const std::string & tblName, const std::string & schemaName) const;
  source::vector::Metadata::MetadataShp buildMetadata(const std::string & sql, const source::vector::DataRow::MapSqlParam &prams) const;
  gear::geom::Envelope::EnvelopeShp getExtent(const std::string & tblName, const std::string & schemaName, const std::string & geomFld) const;

 protected:
  virtual void _openNoWait();
  virtual void _closeNoWait();
  virtual bool _isOpenNoWait() const;

  virtual std::string const _getTestSql() const = 0;
  virtual std::string const _getQtDriverName() const = 0;
  virtual bool _isGeometryNativeType(const int &id) const = 0;
  virtual bool _isGeographyNativeType(const int &id) const = 0;
  virtual void _configureDb(ConnectionParams const & pramas);
  virtual void _configureDbNoWait(ConnectionParams const & pramas);
  virtual std::string const _getBuff2GeomSql(const bool& useWkb) const = 0;
  virtual std::string const _getLayersSql(const std::string & schema, const std::string & tbl) const = 0;
  virtual std::string  _getSridSql(const std::string & tblName, const std::string & schemaName, const std::string & geomFld) const = 0;
  virtual std::string const _getLayerExtentSql(const std::string & tblName, const std::string & schemaName, const std::string & geomFld) const = 0;

  // sezione da spostare sul QueryBuilder
  virtual const std::string _getCreationFieldSql(const source::vector::Field::FieldShp& fld) const = 0;
  virtual const std::string _getSpatialIndexCreationSql(const std::string& schema, const std::string& tbl, const source::vector::Field::FieldShp& fld) const = 0;
  virtual const std::string _getCatalogInsertSql(const std::string &schema, const std::string& tbl, const source::vector::Field::FieldShp& fld, const gear::geom::Envelope::EnvelopeShp& extent) const = 0;
  virtual const std::string _getPkSql(const std::string& tbl, const source::vector::Metadata::MetadataShp& mtd) const = 0;
  // end

  QVariant _valToQt(const source::vector::DataValue::DataValueShp& val) const;
  std::string const _getConnectionIdNoWait(ConnectionParams const & cnnParams) const;
  source::vector::Metadata::MetadataShp _buildMetadata(const std::string & sql, const source::vector::DataRow::MapSqlParam &prams) const;
  QSqlDatabase _getQtDbNoWait(std::string const & name, const bool &verify = true) const;
  source::vector::Metadata::MetadataShp _recordToMetadataNoWait(QSqlRecord const & rec) const;
  int _getSridNoWait(const std::string & name, const std::string & schema, const std::string &geom) const;
  QSqlQuery _execQueryNoWait(std::string const & sql, const std::string & dbName, const source::vector::DataRow::MapSqlParam& params = source::vector::DataRow::MapSqlParam()) const;
  source::vector::DataSet::DataSetShp _execQueryNoWait(std::string const & sql, const std::string & tbl, const std::string & schema, const std::string & dbName, const source::vector::DataRow::MapSqlParam& params = source::vector::DataRow::MapSqlParam()) const;

  std::string _dbName;
  std::string _defaultSchema;
};

}  // namespace qt
}  // namespace connection
}  // namespace fire

#endif