Set.hpp

Go to the documentation of this file.

// ANNA - Anna is Not Nothingness Anymore                                                         //
//                                                                                                //
// (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo                         //
//                                                                                                //
// See project site at http://redmine.teslayout.com/projects/anna-suite                           //
// See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE //


#ifndef anna_dbos_Set_hpp
#define anna_dbos_Set_hpp

#include <anna/core/mt/SafeRecycler.hpp>
#include <anna/core/mt/Guard.hpp>
#include <anna/core/Allocator.hpp>

#include <anna/dbms/Statement.hpp>
#include <anna/dbms/DatabaseException.hpp>

#include <anna/dbos/Object.hpp>

namespace anna {

namespace dbos {

template <typename T> class Set : public Object {
public:
  typedef typename anna::SafeRecycler <T, anna::Allocator<T> > Container;

  typedef typename Container::const_iterator const_iterator;

  typedef typename Container::iterator iterator;

  const_iterator begin() const { return a_objects.begin(); }

  iterator begin() { return a_objects.begin(); }

  const_iterator end() const { return a_objects.end(); }

  iterator end() { return a_objects.end(); }

  T* append() noexcept(false) { return a_objects.create(); }

  void remove(T*& t) noexcept(false) { a_objects.release(t); t = NULL; }

  int size() const { return a_objects.size(); }

  static T* data(iterator& ii) { return Container::data(ii); }

  static const T* data(const_iterator& ii) { return Container::data(ii); }

private:
  Container a_objects;

  void initialize(Loader& loader)
  noexcept(false) {
    T* object;
    dbms::Statement* statement = loader.getStatement();

    try {
      do {
        a_objects.create()->initialize(loader);
      } while(statement->fetch() == true);
    } catch(RuntimeException&) {
      destroy();
      throw;
    } catch(dbms::DatabaseException&) {
      destroy();
      throw;
    }
  }

  void destroy()
  {
    for(iterator ii = begin(), maxii = end(); ii != maxii; ii ++)
      data(ii)->destroy();

    a_objects.clear();
  }
};

}
}

#endif