JSP+UseBean网上购书系统

#include "stdafx.h" #include <iostream> #include "windows.h" #include "allclass.h" #pragma comment(lib,"Shlwapi.lib") #include <String> #include <stdio.h> using namespace std; void ConnectionDB::OpenDB(){ if(S_OK!=CoInitialize(NULL)) { MessageBox(NULL,TEXT("初始化COM库错误!"),TEXT("初始化COM库错误!"),0); } HRESULT hr; try { hr=m_pConnection.CreateInstance("ADODB.Connection"); //创建Connection对象 if(SUCCEEDED(hr)) { m_pConnection->Open("Provider=SQLOLEDB;Server=(LOCAL);Database=yc;User ID=sa;pwd=NULL;Integrated Security=SSPI","","",adModeUnknown); //DSN=OBDC数据源;Provider=MSDASQL m_pRecordset.CreateInstance("ADODB.Recordset"); MessageBox(NULL,TEXT("连接数据库成功"),TEXT("连接数据库成功"),0); } } catch(_com_error e){ printf("%s",e.ErrorMessage()); string errorMsg; errorMsg="连接数据库失败!\r\n错误信息:%s" ; //MessageBox(NULL,errorMsg,"宿舍管理",MB_OK); MessageBox(NULL,TEXT("连接数据库失败!\r\n错误信息:%s"),TEXT("连接数据库失败!\r\n错误信息:%s"),0); } } _RecordsetPtr ConnectionDB::ExecuteSQL(_variant_t sql) { cout << "test!"; m_pRecordset->Open(sql,m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText); MessageBox(NULL,TEXT("连接数据库成功"),TEXT("连接数据库成功"),0); return m_pRecordset; /*cout << " test!"; m_pRecordset->Open(sql, m_pConnection.GetInterfacePtr(), adOpenDynamic, adLockOptimistic, adCmdText); //WHERE STDCODE = '" + bstrStdCode+"'"), return m_pRecordset;*/ } void ConnectionDB::CloseDB() { if(m_pConnection!=NULL) { m_pConnection->Close();//关闭连接 m_pConnection.Release();//释放对象 } } void ConnectionDB::WageSelect(_RecordsetPtr m_pRecordset){ _variant_t Emp_code,Tax,ActualWage,DueWage,HouseFund,var; /*返回结果变量 _variant_t 不能直接转换成MBCS字符串。要建立一个过渡的_bstr_t 变量，用其它提供转换Unicode到MBCS的类函数，或ATL转换宏来转换。与_bstr_t 不同，_variant_t 数据可以作为参数直接传送给COM方法。_variant_t 继承了VARIANT类型，所以在需要使用VARIANT的地方使用_variant_t 是C++语言规则允许的。*/ while(!m_pRecordset->adoEOF) { Emp_code = m_pRecordset->GetCollect(_variant_t((long)0)); //取得第1列的值,从0开始计数，你也可以直接给出列的名称，如下一行 Tax = m_pRecordset->GetCollect("Tax"); //取得姓名字段的值 ActualWage = m_pRecordset->GetCollect("ActualWage"); DueWage = m_pRecordset->GetCollect("DueWage"); HouseFund = m_pRecordset->GetCollect("HouseWage"); cout << "employeecode is ::"<<(_bstr_t)Emp_code <<" " <<"tax is ::" <<(_bstr_t)Tax << " " << "actual wage is :" <<(_bstr_t)ActualWage << " " << "due wage is :" << (_bstr_t)DueWage << " " << "housefund is :" << (_bstr_t)HouseFund <<endl; m_pRecordset->MoveNext(); }//移到下一条记录 // m_pRecordset->MoveFirst(); //移到首条记录 // m_pRecordset->Move(1); //从第一条记录往下移动一条记录,即移动到第二条记录处 // m_pRecordset->PutCollect(_variant_t("city"),_variant_t((long)45)); //修改其年龄 //m_pRecordset->MoveLast(); //移到最后 // m_pRecordset->Update(); //保存到库中 } void ConnectionDB::EmployeeSelect(_RecordsetPtr m_pRecordset) { _variant_t Emp_code,Emp_name,Phone,Department,var; /*返回结果变量 _variant_t 不能直接转换成MBCS字符串。要建立一个过渡的_bstr_t 变量，用其它提供转换Unicode到MBCS的类函数，或ATL转换宏来转换。与_bstr_t 不同，_variant_t 数据可以作为参数直接传送给COM方法。_variant_t 继承了VARIANT类型，所以在需要使用VARIANT的地方使用_variant_t 是C++语言规则允许的。*/ while(!m_pRecordset->adoEOF) { Emp_code = m_pRecordset->GetCollect(_variant_t((long)0)); //取得第1列的值,从0开始计数，你也可以直接给出列的名称，如下一行 Emp_name = m_pRecordset->GetCollect("Emp_name"); //取得姓名字段的值 Phone = m_pRecordset->GetCollect("Phone"); Department = m_pRecordset->GetCollect("Department"); //hire_date = m_pRecordset->GetCollect("hire_date"); cout <<"employee code is :"<<(_bstr_t)Emp_code <<" " <<"employee name is:" <<(_bstr_t)Emp_name << " " << "employee phone is :"<<(_bstr_t)Phone << " " << "department is :" << (_bstr_t)Department << endl; m_pRecordset->MoveNext(); }//移到下一条记录 //m_pRecordset->MoveFirst(); //移到首条记录 //m_pRecordset->Delete(adAffectCurrent); //删除当前记录 /*for(int i=0;i<3;i++) //添加三条新记录并赋值 { m_pRecordset->AddNew(); //添加新记录 m_pRecordset->PutCollect("ID",_variant_t((long)(i+10))); m_pRecordset->PutCollect("Name",_variant_t("王斌年")); m_pRecordset->PutCollect("Age",_variant_t((long)21)); m_pRecordset->PutCollect("Birthday",_variant_t("1930-3-15")); } */ //m_pRecordset->Move(1); //从第一条记录往下移动一条记录,即移动到第二条记录处 //m_pRecordset->PutCollect(_variant_t("city"),_variant_t((long)45)); //修改其年龄 //m_pRecordset->MoveLast(); //移到最后 // m_pRecordset->Update(); //保存到库中 } /*int Users::check_user() { ConnectionDB obj; obj.OpenDB(); int z; char users_code; string users_name,password; char sqlstr[1024]; cout<<"\t\t\t***进销存管理系统***"<<endl; cout<<"\t\t\t 请先登录！"<<endl; cout<<"请输入用户号："; cin>>users_code; cout<<"请输入用户名："; cin>>Users_name; cout<<"请输入用户密码：" ; cin>>Password; sprintf(sqlstr,"select Password,Users_name from Users where users_code='%s'",Users_code); _RecordsetPtr x=obj.ExecuteSQL(sqlstr); _variant_t vUsers_name,vPassword; vUsers_name=x->GetCollect("Users_name"); vPassword=x->GetCollect("Password"); if((string)(_bstr_t)vUsers_name == users_name&&(string)(_bstr_t)vPassword== Password){ z=1; cout<<"\t\t\t\t登录通过！"; } else{ z=0; cout<<"\t\t没有这个用户，请核对后再登录！"; } obj.CloseDB(); return(z); }*/ void Wage::insertWage() { cout << endl << "Please enter employee code:" << endl; cin >> Emp_code; cout<< "Please enter tax:" << endl; cin >> Tax; cout << endl << "Please enter ActualWage:" << endl; cin >> ActualWage; cout << endl << "Please enter DueWage:" << endl; cin >> DueWage; cout << endl << "Please enter HouseFund:" << endl; cin >> HouseFund; ConnectionDB con; con.OpenDB(); char mystr[1024]; sprintf(mystr,"insert into Wage values(Emp_code='%s',Tax='%f',ActualWage='%f',DueWage='%f',HouseFund='%f')",Emp_code,Tax,ActualWage,DueWage,HouseFund); cout << mystr; con.ExecuteSQL(mystr); con.CloseDB(); cout << endl << "插入成功" << endl; } void Wage::updateWage() { cout << endl << "Please enter employee code:" << endl; cin >> Emp_code; cout << endl << "Please enter tax:" << endl; cin >> Tax; cout << endl << "Please enter ActualWage:" << endl; cin >> ActualWage; cout << endl << "Please enter DueWage:" << endl; cin >> DueWage; cout << endl << "Please enter HouseFund:" << endl; cin >> HouseFund; ConnectionDB con; char mystr[1024]; char number[5]; cout << endl << "Enter Emp_code:"; cin >> number; sprintf(mystr,"update Wage set Emp_code='%s',Tax = '%f',ActualWage = '%f', DueWage = '%f',HouseFund = '%f', where Emp_code = '%s'",Emp_code,Tax,ActualWage,DueWage,HouseFund,number); con.OpenDB(); con.ExecuteSQL(mystr);