DataRow.hpp

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

#ifndef FIRE_SOURCE_VECTOR_DATAROW_HPP_INCLUDED
#define FIRE_SOURCE_VECTOR_DATAROW_HPP_INCLUDED

#include <boost/thread/mutex.hpp>

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

#include "fire/gis/export.hpp"
#include "fire/source/vector/Metadata.hpp"
#include "fire/source/vector/DataValue.hpp"
#include "fire/source/vector/shared/MetadataSh.hpp"

namespace fire {
namespace source {
namespace vector {

class ConnectionVectorSh;

namespace shared {
class DataRowSh;
}  // namespace shared

class FIRE_GIS_DLL DataRow {
 public:
  typedef shared::DataRowSh DataRowShp;

  typedef std::vector< DataValue::DataValueShp > VctValue;

  typedef std::map< std::string, DataValue::DataValueShp > MapSqlParam;

 public:
  static DataRow::DataRowShp newRow(Metadata::MetadataShp const & mtd);

  explicit DataRow(const Metadata::MetadataShp& md);

  virtual ~DataRow();

  Metadata::MetadataShp const getMetadata() const;

  int getCount() const;

  bool isChanged() const;

  void set(const size_t &idx, const DataValue::DataValueShp& val);

  void set(const std::string& name, const DataValue::DataValueShp& val);

  DataValue::DataValueShp const get(const int& idx) const;
  DataValue::DataValueShp get(const int& idx);

  const DataValue::DataValueShp get(const std::string& name) const;
  DataValue::DataValueShp get(const std::string& name);

  void getPrimaryKey(VctValue& list) const;

  void saveOrUpdate();

  void insert();

  void update();

  void erase();

  void committed();

 private:
  DataRow(const DataRow& source);
  DataRow& operator=(const DataRow& source);

  bool _isValidIndexNoWait(const size_t& idx) const;
  void _validateIndexNoWait(const size_t& idx) const;
  size_t _name2IndexNoWait(const std::string& name) const;
  std::string _getUpdateSql(VctValue& params) const;
  void _setNoWait(const size_t &idx, const DataValue::DataValueShp& val);

  bool _changed;
  VctValue _values;
  Metadata::MetadataShp  const _mtd;

  mutable boost::mutex _mtx;
};
}  // namespace vector
}  // namespace source
}  // namespace fire

#endif