locker_qsql.hpp

/* qsql_locker.hpp */
/* $Id$ */
#ifndef __locker_qsql_hpp
#define __locker_qsql_hpp

#include <QSqlQuery>
#include <hds_db/base/locker.hpp>
#include <hds_db/qsql/qsql_impl.hpp>

namespace hds
{
  namespace db
  {
    class LockerQSql : public Locker, public QSqlImpl
    {
    public:
      
      LockerQSql(const QSqlDatabase &db,
         const std::string &name = "hds_db_locker", 
         const size_t timeout = 1);
      
      LockerQSql(const ContextQSql &dbc,
         const std::string &name = "hds_db_locker", 
         const size_t timeout = 1);
      
      virtual ~LockerQSql();
      
      virtual DbIndex lock(const LockDescription &ld);
      
      virtual void release(const DbIndex &id);

      virtual size_t releaseAll();
      
      virtual void list(LockDescriptionVec &locks);
      
      
      virtual ErrCode lastError() const;
      
    protected:
      
      ErrCode init(const std::string &mutex_name, 
           const size_t timeout);
      
      ErrCode db_create_locks_table() const;
      
      ErrCode db_get_locks_num(const std::string &name,
                   const LockType &lt,
                   unsigned int &locks_num) const;

      ErrCode db_clear_invalid_locks();
            
    private:
      
      std::string m_mutex_name;
      
      QSqlQuery m_client_connected_query;
      
      QSqlQuery m_del_lock_by_cid_query;
      
      QSqlQuery m_locks_list_query;
      
      mutable ErrCode m_last_error;
    };
  };
};

#endif /* locker_qsql.hpp */