almdboper.cpp

视频播放控制器程序

// AlmDbOper.cpp: implementation of the CAlmDbOper class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "AlmDbOper.h"
#include "MySqlOperator.h"
#include "MySqlRecordset.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CAlmDbOper::CAlmDbOper()
{

}

CAlmDbOper::~CAlmDbOper()
{

}

void CAlmDbOper::SetSqlOperator( CMySqlOperator *pSqlOper )
{
	m_pMySqlOper = pSqlOper;
}

CMySqlRecordset* CAlmDbOper::SelectAlms( COleDateTime STime, COleDateTime ETime, LPCTSTR szDevID )
{
	CString strSTime = STime.Format("%Y-%m-%d %H:%M:%S");
	CString strETime = ETime.Format("%Y-%m-%d %H:%M:%S");
	CString strSql = "select * from tbl_errlog,tbl_errcode, tbl_dev where errlog_devid = dev_id and errcode_id = errlog_code and \
		errlog_time >= '" + strSTime + "' and errlog_time <= '" + strETime + "' ";
	CString strDevID = szDevID;
	if ( strDevID != STR_ALL_DEV )
	{
		strSql = strSql + "and errlog_devid= '" + strDevID + "' ";
	}
	strSql = strSql + " ORDER BY errlog_time DESC";
	CMySqlRecordset *pNewRecordSet = NULL;
	HANDLE hMutex = OpenMutex( MUTEX_ALL_ACCESS, FALSE, MUTEX_SQLOPERATOR );
	if ( hMutex ) WaitForSingleObject( hMutex, 1000 );
	if ( m_pMySqlOper && m_pMySqlOper->IsConnected() )
	{
		pNewRecordSet = m_pMySqlOper->ExecuteQuery( strSql );
	}
	if ( hMutex ) ReleaseMutex(hMutex);
	return pNewRecordSet;
}

BOOL CAlmDbOper::DeleteAlm( int nAlmID )
{
	CString strSql;
	strSql.Format( "%d", nAlmID );
	strSql = "delete from tbl_errlog where errlog_id=" + strSql;
	HANDLE hMutex = OpenMutex( MUTEX_ALL_ACCESS, FALSE, MUTEX_SQLOPERATOR );
	if ( hMutex ) WaitForSingleObject( hMutex, 1000 );
	BOOL rt = FALSE;
	if ( m_pMySqlOper && m_pMySqlOper->IsConnected() )
	{
		rt = m_pMySqlOper->Execute( strSql );
	}
	if ( hMutex ) ReleaseMutex(hMutex);
	return rt;
}