database.h

电力故障信息采集,主要是针对南自的保护装置,这个程序用在Linux操作系统下

#ifndef DATABASE_H
#define DATABASE_H

#include "ysheader.h"

#define BUFSIZE                  1024

class CDataBase
{
    public:
    CDataBase();
    ~CDataBase();
    public:
    bool ConnectDataBase();						//连接数据库
    bool ConnectDataBase(long &hdbc);
    bool ConnectDataBase(long &hdbc,QString dbname,QString dbuser,QString dbpass);
    
    bool DisConnectDataBase(long &hdbc);					//断开数据库
    int GetDbConnectState(long hdbc);					//得到数据库的连接状态
     int SqlExec(long hdbc,QString SqlStr);
    long SqlSelect(long hdbc,QString SqlStr,long &result);			//查询数据;返回记录数
    int  GetRecordCount(long result);					//得到记录数
    int  GetFieldCount(long result);					//得到字段数量
    QCString GetFieldName(long result,unsigned int iField);			//得到字段名称
    int GetFieldType(long result,unsigned int iField);				//得到字段类型
    QCString GetFieldValue(long result,unsigned int iRow,unsigned int iField);	//得到字段值
    void ClearResult(long &result);						//释放结果内存
    void ClearResult(long hdbc,long &result);
    //使用游标查询数据库
    bool OpenCursor(long hdbc,QCString SqlStr,long &pCursor);		//打开一个光标
    bool FetchPriorRow(long hdbc,long pCursor,long &result);			//读取当前记录的上一条记录
    bool FetchNextRow(long hdbc,long pCursor,long &result);			//读取当前记录的下一条记录
    bool FetchAllRow(long hdbc,long pCursor,long &result);			//读取所有记录
    void CloseCursor(long hdbc,long &pCursor);				//关闭光标
    //大文本对象的处理
    bool InsertWithLargeObject(long hdbc,QString SqlStr,QStringList FileList); //插入大对象
    bool InsertWithLargeObject(long hdbc,QString SqlStr,QString FileName);
    bool DeleteWithLargeObject(long hdbc,QString Table,QString WhereStr,QStringList FieldList,
							   bool bForceDele=0,bool bDeleRow=1);    //删除大对象
    bool UpdateLargeObject(long hdbc,QString SqlStr,QStringList FileList);   //修改大对象
    public:
	QString FillParam(QString SqlStr,int ParamIndex,int ParamType,QString param);
    
    void GetTableFromSql(QString SqlStr,QString &Table,QString &WhereStr,QStringList &FieldList);
  
    Oid importfile(long hdbc,char *filename);
    bool pickout(long hdbc,Oid objId,int start,int len,void* retbuf);
    bool overwrite(long hdbc,Oid lobjId,int start,int len,void* srcbuf);
    bool exportfile(long hdbc,Oid objId,char *filename);
    public:
    PGconn 		      *m_pconnect;
    QCString   			m_pghost;
    QCString 			m_pgport;
    QCString			m_pgoptions;
    QCString			m_pgtty;
    QCString			m_dbname;
    QCString			m_dbuser;
    QCString			m_dbpassword;
    //引入影射变量
    long 			 m_hdbc;
    bool                     m_bconnect;
    
};
#endif