tr_hdrs_cache_qsql.hpp

/* tr_hdrs_cache_qsql.hpp */
/* $Id$ */
#ifndef __tr_hdrs_cache_qsql_hpp
#define __tr_hdrs_cache_qsql_hpp

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

namespace hds
{
  namespace db
  {
    class SeismicQSql;
    
    class TrHdrsCacheQSql
    {
    public:
      
      TrHdrsCacheQSql();
      
      TrHdrsCacheQSql(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 TrHeader& get(const DbIndex &id);
      
      void update(const DbIndex &id, const TrHeader &hdr);
      
      DbIndex append(const TrHeader &hdr);

      void clear();

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

      ErrCode m_last_error;
      
      QSqlQuery m_get_hdr_query;
      QSqlQuery m_get_all_hdrs_query;
      QSqlQuery m_update_hdr_query;
      QSqlQuery m_append_hdr_query;
      
      
      ErrCode db_get_header(const DbIndex &trace_id, TrHeader &hdr);
      
      ErrCode db_update_header(const DbIndex &trace_id, const TrHeader &hdr);
      
      ErrCode db_append_header(const TrHeader &hdr, DbIndex &trace_id);

      ErrCode db_cache_all_headers(LRUCache<DbIndex, TrHeader> &hdrs_cache);
      
      ErrCode query2hdr(const QSqlQuery &query, TrHeader &hdr) const;
    };
    
  }; // db
}; // hds

#endif /* tr_hdrs_cache_qsql.hpp */