?? pg_db.cpp
字號:
#include "pg_head.h"#include "pg_db.h"extern PGSERVER_CONFIG server_config_info;extern DB_Proc DB_proc;char *commval[COL_MAX_NUM_CPP];/**************************************************************** * PG接口存取數(shù)據(jù)庫程序?qū)崿F(xiàn) * Language: C++ * OS Platform: UNIX * Authors: * Date: * Copyight (C) ****************************************************************/DB_Proc::DB_Proc(){}DB_Proc::~DB_Proc(){}int DB_Proc::db_connect(char *username,char *password,char *server){ //char *tag="Monitor"; aConn = new DBconnection(); if (aConn->connect(server,username,password) != 0) { cout << endl << "connecting failed!" << endl; return -1; } else { if (init_db_var() < 0) { return -2; } cout << "connecting succeed!" << endl; } return 0;}void DB_Proc::db_disconnect(){ if (aConn->disconnect() != 0) cout << "disconnect failed!" << endl; else cout << "disconnect succeed!" << endl; delete aConn;}int DB_Proc::init_db_var() { int i; cout <<"now execute func init_db_var ... ..." << endl; for (i=0;i<COL_MAX_NUM_CPP;i++) { commval[i] = (char *)malloc(COL_MAX_LEN_CPP); if (commval[i] == NULL) { cout << "malloc commval error!" << endl; return -1; }; }; return 0;}int DB_Proc::get_account_info(char* username,ACCOUNT_INFO *p,int usertype,int hashvalue){ char SQLStmt[100],passwd[17]; DBReadData *aDBRead = new DBReadData(); aDBRead->setConnection(aConn); memset(SQLStmt,0,100); printf("usertype = %d\thashvalue = %d\n",usertype,hashvalue); if (usertype == 1) sprintf(SQLStmt,"select username,password,status,passwordtype from b_dialup_user0%d where username = '%s'",hashvalue,username); else if(usertype == 2) sprintf(SQLStmt,"select username,password,status,passwordtype from b_broadband_user0%d where username = '%s'",hashvalue,username); else if(usertype == 4) sprintf(SQLStmt,"select username,password from b_calling_user where username = '%s'",username); else { printf("Unknown usertype of user %s\n",username); return -1; } printf("sql:%s結(jié)束\n",SQLStmt); if (aDBRead->getData(SQLStmt) != 0) { cout << "query operation failed!" << endl; return -1; } strcpy(p->username,"ssssssssssssssssssss"); if (aDBRead->GetProcStatus() == 0) while(aDBRead->readResult()) { cout << "have result in database!" << endl; if (usertype == 4) { *aDBRead >> p->username >> p->passwd; p->status = 0; p->passwdtype = 0; } else *aDBRead >> p->username >> p->passwd >> p->status >> p->passwdtype; //cout << "username:"<<p->username<<" passwd:"<<p->passwd<<"結(jié)束 status:"<<p->status << endl; } else cout << "There is no result in database!" << endl; delete aDBRead; return 1;}
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -