users.cpp

变压器监控程序

// Users.cpp: implementation of the CUsers class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "trans.h"
#include "Users.h"
#include "TransConn.h"

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

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

CUsers::CUsers()
{
	UserId=0;
	UserName="";
	UserPwd="";


}

int CUsers::GetUserId()
{
	return UserId;
}
void CUsers::SetUserId(int vUserId)
{
	UserId=vUserId;
}
//=========

CString CUsers::GetUserName()
{
	return UserName;
}
void CUsers::SetUserName(CString vUserName)
{
	UserName=vUserName;
}
//=========
CString CUsers::GetUserPwd()
{
	return UserPwd;
}

void CUsers::SetUserPwd(CString vUserPwd)
{
	UserPwd=vUserPwd;
}
//==================
CString CUsers::GetUserType()
{
	return UserType;
}
void CUsers::SetUserType(CString vUserType)
{
	UserType=vUserType;
}

//==========================
void CUsers::sql_insert()
{
	//连接数据库
	CTransConn m_TransConn;
	m_TransConn.OnInitTransConn();
	// 设置INSERT语句
	_bstr_t vSQL;
	vSQL = "INSERT INTO Users (UserName, UserPwd, UserType) VALUES('"
		+ UserName + "','" + UserPwd + "','UserType')";
	
	//执行INSERT语句
	m_TransConn.ExecuteSQL(vSQL);	
	//断开与数据库的连接
	m_TransConn.ExitConnect();
}
void CUsers::sql_delete(CString cUserId)
{
	
	//连接数据库
	CTransConn m_TransConn;
	m_TransConn.OnInitTransConn();
	// 设置DELETE语句
	_bstr_t vSQL;
	vSQL = "DELETE FROM Users WHERE UserId=" + cUserId;
	//执行DELETE语句
	m_TransConn.ExecuteSQL(vSQL);	
	//断开与数据库的连接
	m_TransConn.ExitConnect();
}
void CUsers::sql_updata(CString cUserId)
{
	//连接数据库
	CTransConn m_TransConn;
	m_TransConn.OnInitTransConn();
	//设置UPDATE语句
	_bstr_t vSQL;
	vSQL = "UPDATE Users SET UserName='" + UserName 
		+ "', UserPwd='" + UserPwd +"',UserType='UserType' WHERE UserId=" + cUserId;
	//执行UPDATE语句
	m_TransConn.ExecuteSQL(vSQL);	
	//断开与数据库的连接
	m_TransConn.ExitConnect();
}
void CUsers::GetData(CString cUserName)
{
	//连接数据库
	CTransConn m_TransConn;
	m_TransConn.OnInitTransConn();
	//设置SELECT语句
	_bstr_t vSQL;
	vSQL = "SELECT * FROM Users WHERE UserName='" + cUserName+"'";
	//执行SELETE语句
	_RecordsetPtr m_pRecordset;
	m_pRecordset = m_TransConn.GetRecordSet(vSQL);

	//返回各列的值
	if (m_pRecordset->adoEOF == 1)
		CUsers();
	else
	{
	//	UserId = atoi(cUserId);
		UserName = (LPCTSTR)(_bstr_t)m_pRecordset->GetCollect("UserName");
		UserPwd = (LPCTSTR)(_bstr_t)m_pRecordset->GetCollect("UserPwd");
		UserType = (LPCTSTR)(_bstr_t)m_pRecordset->GetCollect("UserType");
	}
	//断开与数据库的连接
	m_TransConn.ExitConnect();
}
CUsers::~CUsers()
{

}