aesqloperation.h

OTL是一个通用的可以跨平台的ODBC访问源

// ***************************************************************
// AESQLOperation.h	 版本:	3.1
// -------------------------------------------------------------
// SQL语句转换层，实现对关系数据库操作
// -------------------------------------------------------------
// Copyright (C) 2007 - 北京三维力控科技有限公司
// ***************************************************************
// 当前版本：3.1
// 作    者：张冬练、刘玉玲
// 完成日期：2007年10月10日
// 
// 取代版本：
// 原作者  ：
// 完成日期：2007年10月10日
//
// ***************************************************************

#ifndef AESQLOperation_h__				
#define AESQLOperation_h__

#pragma once

#include "publicstruct.h"
#include "AEInfoList.h"
#include "AEFilterInfo.h"
#include "AEFieldInfo.h"

class CAESQLOperation
{
public:
	
	CAESQLOperation(void);

	// 初始化数据库连接
	psInt32 ConnectMySQL();

	// 断开数据库连接
	psVoid DisconnectMySQL();

	// 供第一次启动时调用，创建数据表
	psInt32 CreateTheTable();

	// 向数据库中写入事件信息
	psInt32 InsertAEInfo(CAEInfo Info);

	// SQL查询语句条件字符串的连接
	psVoid  SqlCondition(psChar *sqlstr, CAEFilterInfo filter);

	// 按照条件查询，并将查询结果返回给链表
	psInt32 SelectAEInfo(CAEFilterInfo filter, CAEFieldInfo fieldInfo, CAEInfoList *pAEInfoList);

	// 写入应答信息
	psInt32 UpDateAckedSQL(psUInt64 ulEventNumber, psUInt16 usActorID, TimeInfo	AckTime, psUInt8 ucAcked);

	// 写入结束时间,前三个参数唯一确定一个报警，最后是写入的结束时间
	psInt32 UpdateEndTimeSQL(psUInt32 unItemID, TimeInfo StartTime, psUInt8 ucEventCategory, TimeInfo EndTime);

	// 删除指定测点的事件
    psInt32 DeleteByItemID(psUInt32 unItemID);

	// 删除表
	psVoid  DropTable();

	// ---------------------------------------------------------------
	// 内部函数(仅供单元测试用)
	// ---------------------------------------------------------------
	// 删除表存放的所有信息
	psInt32 DeleteInfo();

public:
	~CAESQLOperation(void);

private:
	otl_connect db;
};

#endif