DataSetQt.hpp

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

#ifndef FIRE_PLUGIN_CONNECTION_DATASETQT_HPP_INCLUDED
#define FIRE_PLUGIN_CONNECTION_DATASETQT_HPP_INCLUDED

#include <QtSql/QSqlQuery>
#include <boost/thread/mutex.hpp>
#include <fire/source/vector/DataSet.hpp>

#include <string>
#include <exception>

#include "fire/plugin-impl/connection/qt/ConnectionQtSql.hpp"

namespace fire {
namespace connection {
namespace qt {

class DataSetQt: public source::vector::DataSet {
 public:
  explicit DataSetQt(QSqlQuery ds, std::string const & cnnName, const std::string &tblName = "", const std::string &schemaName = "", const source::vector::DataRow::MapSqlParam& params = source::vector::DataRow::MapSqlParam());
  virtual ~DataSetQt();
  source::vector::DataRow::DataRowShp next();
  source::vector::DataRow::DataRowShp const next() const;
  bool reset() const;
  source::vector::Metadata::MetadataShp const getMetadata() const;
  source::vector::DataRow::DataRowShp createEmptyRow() const;
  source::vector::DataRow::DataRowShp current();
  const source::vector::DataRow::DataRowShp current() const;

 private:
  explicit DataSetQt(const DataSetQt& source);
  DataSetQt& operator=(const DataSetQt& source);

  source::vector::DataRow::DataRowShp _buildRowNoWait() const;
  source::vector::DataRow::DataRowShp _nextNoWait(QSqlQuery & ds) const;
  ConnectionQtSql::ConnectionQtSqlShp const _getConnectionNoWait() const;
  source::vector::Metadata::MetadataShp const _getMetadataNoWait() const;

  std::string _tblName;
  std::string _cnnName;
  mutable QSqlQuery _ds;
  std::string _schemaName;
  mutable boost::mutex _mtx;
  source::vector::DataRow::MapSqlParam _params;
  mutable source::vector::DataRow::DataRowShp _current;  // definito mutable per consentire la "lazy initialization"
  mutable source::vector::Metadata::MetadataShp _mtd;  // definito mutable per consentire la "lazy initialization"
};

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

#endif