qsql_impl.hpp

/* qsql_impl.hpp */
/* $Id$ */
#ifndef __hds_db_qsql_impl_hpp
#define __hds_db_qsql_impl_hpp

#include <hds_db/base/seismic.hpp>
#include <hds_db/qsql/dbcontext_qsql.hpp>
#include <QSqlDatabase>

class QMutex;

namespace hds
{
  namespace db
  {
    class QSqlImpl
    {
    public:
      
      enum TableLockType
    {
      TLT_READ = 0,  
      TLT_WRITE      
    };
      
      
      struct TableLockDescr
      {
    TableLockDescr():
      type(TLT_READ) 
    { /* nothing to do */}
    
    TableLockDescr(const TableLockType &i_type,
               const std::string &i_table_name):
      type(i_type), table_name(i_table_name) 
    { /* nothing to do */}
    
    TableLockType type;       
    std::string table_name;   
      };
      
      typedef std::vector<TableLockDescr> TLDVec;
      
      
      QSqlImpl();
      
      QSqlImpl(const ContextQSql &dbc);
      
      virtual ~QSqlImpl();
      
      
      const ContextQSql& getDbContext() const {return m_dbc;}
      
      QSqlDatabase& getDb() {return m_db;}
      
      bool supportTransactionsFlag() const;
      
      ErrCode dbConnect() const;
      
      
      QMutex& getDefaultMutex() const;

    protected:
      
      mutable QSqlDatabase m_db;

      ContextQSql m_dbc;
      
      mutable bool m_is_transaction_started;

      
      ErrCode db_init(const hds::db::ContextQSql &context);
      
      ErrCode db_close(const hds::db::ContextQSql &context);
      
      
      ErrCode db_lock_tables(const TLDVec &tld_vec);
      
      ErrCode db_release_tables_locks();
      
      
      ErrCode db_get_lock(const std::string &lock_name, 
              const size_t timeout = 3) const;
      
      ErrCode db_release_lock(const std::string &lock_name) const;
      
      ErrCode db_set_item_value(const std::string &table_name,
                const std::string &field_name,
                const std::string &key_name,
                const DbIndex &key_id,
                const std::string &value);
      
      ErrCode db_get_item_value(const std::string &table_name,
                const std::string &field_name,
                const std::string &key_name,
                const DbIndex &key_id,
                std::string &value) const;
      
      time_t db_table_creation_time(const std::string &table_name, 
                    ErrCode *prc = NULL) const;

      time_t db_table_modification_time(const std::string &table_name, 
                    ErrCode *prc = NULL) const;
      
      quint64 db_table_size(const std::string &table_name, ErrCode *prc = NULL) const;
      
      size_t db_table_rows_num(const std::string &table_name, ErrCode *prc = NULL) const;
      
      ErrCode db_transaction_begin() const;
      
      ErrCode db_transaction_commit();
      
      ErrCode db_transaction_rollback();


      QString get_db_name_hash(const hds::db::ContextQSql &context) const; 
    };
  };
};

#endif /* __hds_db_qsql_impl_hpp */