coco
116 lines
2.7 KiB
C++
116 lines
2.7 KiB
C++
// UpdateDataBase.h: interface for the CUpdateDataBase class.
|
|
//
|
|
//////////////////////////////////////////////////////////////////////
|
|
#include "Markup.h"
|
|
|
|
#if !defined(AFX_UPDATEDATABASE_H__65574C8D_6ABD_4A5C_8943_C38142D7BDD5__INCLUDED_)
|
|
#define AFX_UPDATEDATABASE_H__65574C8D_6ABD_4A5C_8943_C38142D7BDD5__INCLUDED_
|
|
|
|
#if _MSC_VER > 1000
|
|
#pragma once
|
|
#endif // _MSC_VER > 1000
|
|
|
|
#include <vector>
|
|
|
|
|
|
typedef struct STCOLUMNINFO
|
|
{
|
|
CString strColName;//列名
|
|
CString strRefTableName;//外键约束的表名
|
|
CString strRefTableCol;//外键约束的字段名
|
|
int nModifyType; //操作的类型，0:不更改， 1: 增加 2:删除 3:修改，主键的属性是不能进行修改的
|
|
int nValueType; //从1开始
|
|
int nAttrType;
|
|
int nIsPrimaryKey;
|
|
int nIsForeignKey;
|
|
int nIndex;
|
|
int nIsEmpty;
|
|
int nIsCompress;
|
|
STCOLUMNINFO()
|
|
{
|
|
strColName = _T("");
|
|
strRefTableName = _T("");
|
|
strRefTableCol = _T("");
|
|
nModifyType = 0;
|
|
nValueType = 1;
|
|
nAttrType = 50;
|
|
nIsPrimaryKey = 0;
|
|
nIsForeignKey = 0;
|
|
nIndex = 0;
|
|
nIsEmpty = 0;
|
|
nIsCompress = 0;
|
|
}
|
|
}STColInfo;
|
|
|
|
typedef struct STTABLEINFO
|
|
{
|
|
CString strTableName;
|
|
int nModifyType; //操作的类型，0:不更改， 1: 增加 2:删除 3:修改
|
|
std::vector<STColInfo> vtColInfo;
|
|
STTABLEINFO()
|
|
{
|
|
strTableName = _T("");
|
|
nModifyType = 0;
|
|
vtColInfo.clear();
|
|
}
|
|
|
|
}STTableInfo;
|
|
|
|
typedef enum EN_UPDATEDB_RES
|
|
{
|
|
enResFail = 0,
|
|
enResSuccess,
|
|
enResNoUpdate
|
|
}EnUpdateDBRes;
|
|
|
|
static char* chValueType[20] = {"varchar", "text", "tinyint", "smallint", "integer", "real",
|
|
"float", "money", "counter", "datetime", "bit", "image"};
|
|
|
|
|
|
class CUpdateDataBase
|
|
{
|
|
public:
|
|
CUpdateDataBase(_ConnectionPtr pConnection, CString strVer);
|
|
virtual ~CUpdateDataBase();
|
|
bool ParserUpdateDBXml();
|
|
int UpdateDBInfo();
|
|
|
|
|
|
protected:
|
|
//functions
|
|
bool QueryPreVersion();
|
|
|
|
bool WriteVersionToDB();
|
|
|
|
void PrintLog(CString& strLog);
|
|
|
|
bool GetDBUpdatesInfo(); //解析数据库的更新新，前提是必须先跳转到pre_version元素中
|
|
|
|
STColInfo GetColumnInfo(int nType);
|
|
|
|
|
|
bool AddDBTable(STTableInfo pstTable);
|
|
|
|
bool DeleteDBTable(STTableInfo stTable);
|
|
|
|
bool ModifyDBTable(STTableInfo stTable);
|
|
|
|
bool AddTableCol(CString strTable, STColInfo stCol, std::vector<CString>& vtSql);
|
|
|
|
bool ModifyTableCol(CString strTable, STColInfo stCol, std::vector<CString>& vtSql);
|
|
|
|
bool CheckNecessaryVersion();//为了填补1.5版本中versioninfo表中没有字段的问题而引入的临时解决方案
|
|
|
|
//member
|
|
STTableInfo m_stDBModifyInfo;
|
|
std::vector<STTableInfo> m_vtUpdateDBInfo;
|
|
CMarkup m_opXml;
|
|
FILE* m_pLog;
|
|
CString m_strPreVersion;
|
|
_ConnectionPtr m_pConnection;
|
|
CString m_strCurVer;
|
|
|
|
};
|
|
|
|
#endif // !defined(AFX_UPDATEDATABASE_H__65574C8D_6ABD_4A5C_8943_C38142D7BDD5__INCLUDED_)
|