tr_bodies_cache_qsql.hpp

/* tr_bodies_cache_qsql.hpp */
/* $Id$ */
#ifndef __tr_bodies_cache_qsql_hpp
#define __tr_bodies_cache_qsql_hpp

#include <QSqlQuery>
#include <hds_db/base/defines.hpp>
#include <hds_db/qsql/lru_cache.h>

namespace hds
{
  namespace db
  {
    class SeismicQSql;
    
    class TrBodiesCacheQSql
    {
    public:
      
      TrBodiesCacheQSql();
      
      TrBodiesCacheQSql(SeismicQSql *pseis,
            const size_t read_cache_size,
            const size_t write_cache_size);
      
      void init(SeismicQSql *pseis,
        const size_t read_cache_size,
        const size_t write_cache_size);
      
      const TrBody& get(const DbIndex &id);
      
      void update(const DbIndex &id, const TrBody &body);
      
      DbIndex append(const TrBody &body);

      void clear();

      void flush();
      
      ErrCode lastError() const {return m_last_error;}
      
    protected:
      
      LRUCache<DbIndex, hds::db::TrBody> m_cache;
      
      SeismicQSql *mp_seis;

      ErrCode m_last_error;
      
      QSqlQuery m_get_body_query;
      QSqlQuery m_update_body_query;
      QSqlQuery m_append_body_query;
            
      ErrCode db_get_body(const DbIndex &trace_id, TrBody &body);
      
      ErrCode db_update_body(const DbIndex &trace_id, const TrBody &body);
      
      ErrCode db_append_body(const TrBody &body, DbIndex &trace_id);
    };
    
  }; // db
}; // hds

#endif /* tr_bodies_cache_qsql.hpp */