【崩溃】求一个VC ADO连接SQL的实例 在网上搜了好多，但是一放在VC中运行总出错。要可行的。。 解决方案 » 免费领取超大流量手机卡，每月29元包185G流量+100分钟通话, 中国电信官方发货 C#连接SQL数据库 中国制造交易网连接数据库的步骤: 1、建立SqlConnection对象； 2、指定SqlConnection对象的ConnectionString 属性； 3、打开数据库连接； 4、指定SQL语句； 5、建立SqlDataAdapter对象和DataSet对象（myDataAdapter = new SqlDataAdapter(strCmd,conn);）； 6、添冲DataSet; 7、给DataGrid指定数据源SqlConnection conn = new SqlConnection(); conn.ConnectionString = "data source = (local);initial catalog = test; user id = sa;password = sa"; conn.Open(); string strCmd; strCmd = "select * from test"; SqlDataAdapter myDataAdapter; DataSet myDataSet = new DataSet(); myDataAdapter = new SqlDataAdapter(strCmd,conn); myDataAdapter.Fill(myDataSet,"test"); myTestDataGrid.DataSource = myDataSet.Tables["test"];说明: 数据库安装在本地(local);数据库名称为test;用户名为sa;密码为sa;数据库中的表为test; 0 0 0 (请您对文章做出评价)C#连接Access、SQL Server、Oracle、MySQL、DB2和SyBase六种不同数据库的程序源码2009-08-15 01:19本文列出了C#连接Access、SQL Server、Oracle、MySQL、DB2和SyBase六种不同数据库的程序源码和需要注意的点。 1.C#连接Access 程序代码： using System.Data; using System.Data.OleDb; string strConnection="Provider=Microsoft.Jet.OleDb.4.0;"; strConnection+=@"DataSource=C:\BegASPNET\Northwind.mdb"; OleDbConnection objConnection=new OleDbConnection(strConnection); objConnection.Open(); objConnection.Close(); 解释： 连接Access数据库需要导入额外的命名空间，所以有了最前面的两条using命令，这是必不可少的! strConnection这个变量里存放的是连接数据库所需要的连接字符串，他指定了要使用的数据提供者和要使用的数据源。 “Provider=Microsoft.Jet.OleDb.4.0;”是指数据提供者，这里使用的是Microsoft Jet引擎，也就是Access中的数据引擎，asp.net就是靠这个和Access的数据库连接的。 “Data Source=C:\BegASPNET\Northwind.mdb”是指明数据源的位置，他的标准形式是“Data Source=MyDrive:MyPath\MyFile.MDB”。 PS： 1.“+=”后面的“@”符号是防止将后面字符串中的“\”解析为转义字符。 2.如果要连接的数据库文件和当前文件在同一个目录下，还可以使用如下的方法连接： strConnection+="Data Source=";strConnection+=MapPath("Northwind.mdb"); 3.要注意连接字符串中的参数之间要用分号来分隔。 “OleDbConnection objConnection=new OleDbConnection(strConnection);”这一句是利用定义好的连接字符串来建立了一个链接对象，以后对数据库的操作我们都要和这个对象打交道。 “objConnection.Open();”这用来打开连接。至此，与Access数据库的连接完成。 2.C#连接SQL Server 程序代码： using System.Data; using System.Data.SqlClient;.. string strConnection="user id=sa;password=;"; strConnection+="initial catalog=Northwind;Server=YourSQLServer;"; strConnection+="Connect Timeout=30"; SqlConnection objConnection=new SqlConnection(strConnection);.. objConnection.Open(); objConnection.Close(); 解释： 连接SQL Server数据库的机制与连接Access的机制没有什么太大的区别，只是改变了Connection对象和连接字符串中的不同参数。 首先，连接SQL Server使用的命名空间不是“System.Data.OleDb”，而是“System.Data.SqlClient”。 其次就是他的连接字符串了，我们一个一个参数来介绍(注意：参数间用分号分隔)： “user id=sa”：连接数据库的验证用户名为sa。他还有一个别名“uid”，所以这句我们还可以写成“uid=sa”。 “password=”：连接数据库的验证密码为空。他的别名为“pwd”，所以我们可以写为“pwd=”。 这里注意，你的SQL Server必须已经设置了需要用户名和密码来登录，否则不能用这样的方式来登录。如果你的SQL Server设置为Windows登录，那么在这里就不需要使用“user id”和“password”这样的方式来登录，而需要使用“Trusted_Connection=SSPI”来进行登录。 “initial catalog=Northwind”：使用的数据源为“Northwind”这个数据库。他的别名为“Database”，本句可以写成“Database=Northwind”。 “Server=YourSQLServer”：使用名为“YourSQLServer”的服务器。他的别名为“Data Source”，“Address”，“Addr”。如果使用的是本地数据库且定义了实例名，则可以写为“Server=(local)\实例名”;如果是远程服务器，则将“(local)”替换为远程服务器的名称或IP地址。 “Connect Timeout=30”：连接超时时间为30秒。 在这里，建立连接对象用的构造函数为：SqlConnection。 3.C#连接Oracle 程序代码： using System.Data.OracleClient;using System.Data;//在窗体上添加一个按钮，叫Button1，双击Button1，输入以下代码private void Button1_Click(object sender, System.EventArgs e){string ConnectionString="Data Source=sky;user=system;password=manager;";//写连接串OracleConnection conn=new OracleConnection(ConnectionString);//创建一个新连接try{conn.Open();OracleCommand cmd=conn.CreateCommand();cmd.CommandText="select * from MyTable";//在这儿写sql语句OracleDataReader odr=cmd.ExecuteReader();//创建一个OracleDateReader对象while(odr.Read())//读取数据，如果odr.Read()返回为false的话，就说明到记录集的尾部了 {Response.Write(odr.GetOracleString(1).ToString());//输出字段1，这个数是字段索引，具体怎么使用字段名还有待研究}odr.Close();}catch(Exception ee){Response.Write(ee.Message); //如果有错误，输出错误信息}finally{conn.Close(); //关闭连接}} 4.C#连接MySQL 程序代码： using MySQLDriverCS; // 建立数据库连接MySQLConnection DBConn;DBConn = new MySQLConnection(new MySQLConnectionString("localhost","mysql","root","",3306).AsString);DBConn.Open(); // 执行查询语句MySQLCommand DBComm;DBComm = new MySQLCommand("select Host,User from user",DBConn); // 读取数据MySQLDataReader DBReader = DBComm.ExecuteReaderEx(); // 显示数据try{while (DBReader.Read()){Console.WriteLine("Host = {0} and User = {1}", DBReader.GetString(0),DBReader.GetString(1));}}finally{DBReader.Close();DBConn.Close();} //关闭数据库连接DBConn.Close(); 5.C#连接IBM DB2 程序代码： OleDbConnection1.Open();//打开数据库连接OleDbDataAdapter1.Fill(dataSet1,"Address");//将得来的数据填入dataSetDataGrid1.DataBind();//绑定数据OleDbConnection1.Close();//关闭连接 //增加数据库数据在Web Form上新增对应字段数量个数的TextBox，及一个button，为该按键增加Click响应事件代码如下：this.OleDbInsertCommand1.CommandText = "INSERTsintosADDRESS(NAME,EMAIL, AGE, ADDRESS) VALUES('"+TextBox1.Text+"','"+TextBox2.Text+"','"+TextBox3.Text+"','"+TextBox4.Text+"')";OleDbInsertCommand1.Connection.Open();//打开连接OleDbInsertCommand1.ExecuteNonQuery();//执行该SQL语句OleDbInsertCommand1.Connection.Close();//关闭连接 6.C#连接SyBase 程序代码： Provider=Sybase.ASEOLEDBProvider.2;Initial Catalog=数据库名;User ID=用户名;Data Source=数据源;Extended Properties="";Server Name=ip地址;Network Protocol=Winsock;Server Port Address=5000; 首先感谢SQL77。但是要VC版的不是C#版的 个人觉得下面这个还不错，比较清晰,代码集中在一起不乱。。来源：http://zhfa62560.blog.163.com/blog/static/107702454200911604946220/基本步骤：1.创建一个基于对话框的应用程序ADODatabase。2.创建一个用来连接的ADO类库。系统菜单中Insert->New Class项，class type选择Generic Class; 在Name后输入类名“ADOConn”，点OK。这样，在工程上自动生成ADOConn.h和ADOConn.cpp两个文件。3.在ADOConn.h中导入一个ADO动态链接库msado15.dll，添加代码：#import "c:\Program Files\Common Files\System\ado\msado15.dll" no_namespace rename("EOF","adoEOF") rename("BOF","adoBOF")，同时在ADOConn.h中定义 public：//添加一个指向Connection对象的指针: _ConnectionPtr m_pConnection; //添加一个指向Recordset对象的指针: _RecordsetPtr m_pRecordset。4.m_pConnection->Open(_bstr_t ConnectionString, _bstr_t UserID, _bstr_t Password, long Options) 操作。ConnectionString为VC++中对SQL SERVER中ADO设置。如，Provider=SQLOLEDB;Integrated Security=SSPI;Persist Security Info=False;Initial Catalog=suntest;Data Source=WWW-ED1F301E78B ;User Id=sa;Password=;其中Data Source为服务器名称，可以用Server代替，本机表示为.或者(local)；Initial Catalog为你要使用的数据库名称 可以用Database代替；Integrated Security=SSPI表示用集成模式，此时uid 和pwd 设置不起作用；只有当Integrated Security=FALSE表示用混合模式，uid 和pwd 设置才起作用参数Options表示CommandText的类型：adCmdText-文本命令；adCmdTable-表名 adCmdProc-存储过程；adCmdUnknown-未知5.添加两个成员函数：(1)执行查询函数 _RecordsetPtr& GetRecordSet(_bstr_t bstrSQL);(2)执行SQL语句 BOOL ExecuteSQL(_bstr_t bstrSQL)。给出两个文件的完整代码：/*------------------ADOConn.h File-------------------------------------------------*/// ADOConn.h: interface for the ADOConn class.#import "c:\Program Files\Common Files\System\ado\msado15.dll" no_namespace rename("EOF","adoEOF") rename("BOF","adoBOF")#if !defined(AFX_ADOCONN_H__AC448F02_AF26_45E4_9B2D_D7ECB8FFCFB9__INCLUDED_)#define AFX_ADOCONN_H__AC448F02_AF26_45E4_9B2D_D7ECB8FFCFB9__INCLUDED_#if _MSC_VER > 1000#pragma once#endif // _MSC_VER > 1000class ADOConn {// 定义变量public://添加一个指向Connection对象的指针:_ConnectionPtr m_pConnection;//添加一个指向Recordset对象的指针:_RecordsetPtr m_pRecordset;// 定义方法public:ADOConn();virtual ~ADOConn();// 初始化—连接数据库void OnInitADOConn();// 执行查询_RecordsetPtr& GetRecordSet(_bstr_t bstrSQL);// 执行SQL语句，Insert Update _variant_tBOOL ExecuteSQL(_bstr_t bstrSQL);void ExitConnect();};#endif // !defined(AFX_ADOCONN_H__AC448F02_AF26_45E4_9B2D_D7ECB8FFCFB9__INCLUDED_)/*--------------------------------------------------------------------------------*//*---------------------ADOConn.cpp File---------------------------*/#include "stdafx.h"#include "ADOConn.h"#ifdef _DEBUG#undef THIS_FILEstatic char THIS_FILE[]=__FILE__;#define new DEBUG_NEW#endifADOConn::ADOConn(){}ADOConn::~ADOConn(){}// 初始化—连接数据库void ADOConn::OnInitADOConn(){// 初始化OLE/COM库环境::CoInitialize(NULL);try{// 创建Connection对象m_pConnection.CreateInstance("ADODB.Connection");// 设置连接字符串，必须是BSTR型或者_bstr_t类型_bstr_t strConnect = "Provider=SQLOLEDB; Server=CZ;Database=HrSys; uid=sa; pwd=sa;";m_pConnection->Open(strConnect,"","",adModeUnknown);}// 捕捉异常catch(_com_error e){// 显示错误信息AfxMessageBox(e.Description());}}// 执行查询_RecordsetPtr& ADOConn::GetRecordSet(_bstr_t bstrSQL){try{// 连接数据库，如果Connection对象为空，则重新连接数据库if(m_pConnection==NULL) OnInitADOConn();// 创建记录集对象m_pRecordset.CreateInstance(__uuidof(Recordset));// 取得表中的记录m_pRecordset->Open(bstrSQL,m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);}// 捕捉异常catch(_com_error e){// 显示错误信息AfxMessageBox(e.Description());}// 返回记录集return m_pRecordset;}// 执行SQL语句，Insert Update _variant_tBOOL ADOConn::ExecuteSQL(_bstr_t bstrSQL){// _variant_t RecordsAffected;try{// 是否已经连接数据库if(m_pConnection == NULL) OnInitADOConn();// Connection对象的Execute方法:(_bstr_t CommandText,// VARIANT * RecordsAffected, long Options )// 其中CommandText是命令字串，通常是SQL命令。// 参数RecordsAffected是操作完成后所影响的行数,// 参数Options表示CommandText的类型：adCmdText-文本命令；adCmdTable-表名// adCmdProc-存储过程；adCmdUnknown-未知m_pConnection->Execute(bstrSQL,NULL,adCmdText);return true;}catch(_com_error e){AfxMessageBox(e.Description());return false;}}void ADOConn::ExitConnect(){// 关闭记录集和连接if (m_pRecordset != NULL)m_pRecordset->Close();m_pConnection->Close();// 释放环境::CoUninitialize();} 虚心请教：将ORACLE9.2存储过程转换为sqlserver2000存储过程 sql语句中的单引号如果想放在一个字符串里该怎么办？ 在mssql2000中如何实现像Access中的自动ID,让某个表的ID号自动递增 access 升级到mssql问题 用SQL语名删除数据表中的前几个字符? 高手help！一个触发器的问题 我不知道sql server 2000是用来干什么的？是做来表吗？ 行转换成列（补充提问） 有关列表问题 多表链接查询最优方案请教 -----------我的一些笔记(基于SQL 2005)---- 几道理论题~~拜托啦~
中国制造交易网
连接数据库的步骤:
1、建立SqlConnection对象；
2、指定SqlConnection对象的ConnectionString 属性；
3、打开数据库连接；
4、指定SQL语句；
5、建立SqlDataAdapter对象和DataSet对象（myDataAdapter = new SqlDataAdapter(strCmd,conn);
）；
6、添冲DataSet;
7、给DataGrid指定数据源SqlConnection conn = new SqlConnection();
conn.ConnectionString = "data source = (local);initial catalog = test; user id = sa;password = sa";
conn.Open();
string strCmd;
strCmd = "select * from test";
SqlDataAdapter myDataAdapter;
DataSet myDataSet = new DataSet();
myDataAdapter = new SqlDataAdapter(strCmd,conn);
myDataAdapter.Fill(myDataSet,"test");
myTestDataGrid.DataSource = myDataSet.Tables["test"];说明: 数据库安装在本地(local);数据库名称为test;用户名为sa;密码为sa;
数据库中的表为test; 0 0 0
(请您对文章做出评价)
C#连接Access、SQL Server、Oracle、MySQL、DB2和SyBase六种不同数据库的程序源码2009-08-15 01:19本文列出了C#连接Access、SQL Server、Oracle、MySQL、DB2和SyBase六种不同数据库的程序源码和需要注意的点。
1.C#连接Access 程序代码： using System.Data; using System.Data.OleDb; string strConnection="Provider=Microsoft.Jet.OleDb.4.0;"; strConnection+=@"DataSource=C:\BegASPNET\Northwind.mdb"; OleDbConnection objConnection=new OleDbConnection(strConnection);
objConnection.Open();
objConnection.Close(); 解释： 连接Access数据库需要导入额外的命名空间，所以有了最前面的两条using命令，这是必不可少的! strConnection这个变量里存放的是连接数据库所需要的连接字符串，他指定了要使用的数据提供者和要使用的数据源。 “Provider=Microsoft.Jet.OleDb.4.0;”是指数据提供者，这里使用的是Microsoft Jet引擎，也就是Access中的数据引擎，asp.net就是靠这个和Access的数据库连接的。
“Data Source=C:\BegASPNET\Northwind.mdb”是指明数据源的位置，他的标准形式是“Data Source=MyDrive:MyPath\MyFile.MDB”。 PS： 1.“+=”后面的“@”符号是防止将后面字符串中的“\”解析为转义字符。 2.如果要连接的数据库文件和当前文件在同一个目录下，还可以使用如下的方法连接： strConnection+="Data Source=";strConnection+=MapPath("Northwind.mdb"); 3.要注意连接字符串中的参数之间要用分号来分隔。 “OleDbConnection objConnection=new OleDbConnection(strConnection);”这一句是利用定义好的连接字符串来建立了一个链接对象，以后对数据库的操作我们都要和这个对象打交道。 “objConnection.Open();”这用来打开连接。至此，与Access数据库的连接完成。 2.C#连接SQL Server
程序代码： using System.Data; using System.Data.SqlClient;.. string strConnection="user id=sa;password=;"; strConnection+="initial catalog=Northwind;Server=YourSQLServer;"; strConnection+="Connect Timeout=30";
SqlConnection objConnection=new SqlConnection(strConnection);.. objConnection.Open(); objConnection.Close(); 解释： 连接SQL Server数据库的机制与连接Access的机制没有什么太大的区别，只是改变了Connection对象和连接字符串中的不同参数。 首先，连接SQL Server使用的命名空间不是“System.Data.OleDb”，而是“System.Data.SqlClient”。 其次就是他的连接字符串了，我们一个一个参数来介绍(注意：参数间用分号分隔)： “user id=sa”：连接数据库的验证用户名为sa。他还有一个别名“uid”，所以这句我们还可以写成“uid=sa”。 “password=”：连接数据库的验证密码为空。他的别名为“pwd”，所以我们可以写为“pwd=”。 这里注意，你的SQL Server必须已经设置了需要用户名和密码来登录，否则不能用这样的方式来登录。如果你的SQL Server设置为Windows登录，那么在这里就不需要使用“user id”和“password”这样的方式来登录，而需要使用“Trusted_Connection=SSPI”来进行登录。 “initial catalog=Northwind”：使用的数据源为“Northwind”这个数据库。他的别名为“Database”，本句可以写成“Database=Northwind”。 “Server=YourSQLServer”：使用名为“YourSQLServer”的服务器。他的别名为“Data Source”，“Address”，“Addr”。如果使用的是本地数据库且定义了实例名，则可以写为“Server=(local)\实例名”;如果是远程服务器，则将“(local)”替换为远程服务器的名称或IP地址。
“Connect Timeout=30”：连接超时时间为30秒。
在这里，建立连接对象用的构造函数为：SqlConnection。 3.C#连接Oracle
程序代码： using System.Data.OracleClient;using System.Data;//在窗体上添加一个按钮，叫Button1，双击Button1，输入以下代码private void Button1_Click(object sender, System.EventArgs e){string ConnectionString="Data Source=sky;user=system;password=manager;";//写连接串OracleConnection conn=new OracleConnection(ConnectionString);//创建一个新连接try{conn.Open();OracleCommand cmd=conn.CreateCommand();cmd.CommandText="select * from MyTable";//在这儿写sql语句OracleDataReader odr=cmd.ExecuteReader();//创建一个OracleDateReader对象while(odr.Read())//读取数据，如果odr.Read()返回为false的话，就说明到记录集的尾部了 {Response.Write(odr.GetOracleString(1).ToString());//输出字段1，这个数是字段索引，具体怎么使用字段名还有待研究}odr.Close();}catch(Exception ee){Response.Write(ee.Message); //如果有错误，输出错误信息}finally{conn.Close(); //关闭连接}} 4.C#连接MySQL 程序代码： using MySQLDriverCS; // 建立数据库连接MySQLConnection DBConn;DBConn = new MySQLConnection(new MySQLConnectionString("localhost","mysql","root","",3306).AsString);DBConn.Open(); // 执行查询语句MySQLCommand DBComm;DBComm = new MySQLCommand("select Host,User from user",DBConn); // 读取数据MySQLDataReader DBReader = DBComm.ExecuteReaderEx(); // 显示数据try{while (DBReader.Read()){Console.WriteLine("Host = {0} and User = {1}", DBReader.GetString(0),DBReader.GetString(1));}}finally{DBReader.Close();DBConn.Close();} //关闭数据库连接DBConn.Close(); 5.C#连接IBM DB2 程序代码： OleDbConnection1.Open();//打开数据库连接OleDbDataAdapter1.Fill(dataSet1,"Address");//将得来的数据填入dataSetDataGrid1.DataBind();//绑定数据OleDbConnection1.Close();//关闭连接 //增加数据库数据在Web Form上新增对应字段数量个数的TextBox，及一个button，为该按键增加Click响应事件代码如下：this.OleDbInsertCommand1.CommandText = "INSERTsintosADDRESS(NAME,EMAIL, AGE, ADDRESS) VALUES('"+TextBox1.Text+"','"+TextBox2.Text+"','"+TextBox3.Text+"','"+TextBox4.Text+"')";OleDbInsertCommand1.Connection.Open();//打开连接OleDbInsertCommand1.ExecuteNonQuery();//执行该SQL语句OleDbInsertCommand1.Connection.Close();//关闭连接 6.C#连接SyBase
程序代码： Provider=Sybase.ASEOLEDBProvider.2;Initial Catalog=数据库名;User ID=用户名;Data Source=数据源;Extended Properties="";Server Name=ip地址;Network Protocol=Winsock;Server Port Address=5000;
但是要VC版的不是C#版的
来源：http://zhfa62560.blog.163.com/blog/static/107702454200911604946220/
基本步骤：1.创建一个基于对话框的应用程序ADODatabase。2.创建一个用来连接的ADO类库。系统菜单中Insert->New Class项，class type选择Generic Class; 在Name后输入类名“ADOConn”，点OK。这样，在工程上自动生成ADOConn.h和ADOConn.cpp两个文件。3.在ADOConn.h中导入一个ADO动态链接库msado15.dll，添加代码：#import "c:\Program Files\Common Files\System\ado\msado15.dll" no_namespace rename("EOF","adoEOF") rename("BOF","adoBOF")，同时在ADOConn.h中定义 public：//添加一个指向Connection对象的指针: _ConnectionPtr m_pConnection; //添加一个指向Recordset对象的指针: _RecordsetPtr m_pRecordset。4.m_pConnection->Open(_bstr_t ConnectionString, _bstr_t UserID, _bstr_t Password, long Options) 操作。ConnectionString为VC++中对SQL SERVER中ADO设置。如，Provider=SQLOLEDB;Integrated Security=SSPI;Persist Security Info=False;Initial Catalog=suntest;Data Source=WWW-ED1F301E78B ;User Id=sa;Password=;其中Data Source为服务器名称，可以用Server代替，本机表示为.或者(local)；Initial Catalog为你要使用的数据库名称 可以用Database代替；Integrated Security=SSPI表示用集成模式，此时uid 和pwd 设置不起作用；只有当Integrated Security=FALSE表示用混合模式，uid 和pwd 设置才起作用参数Options表示CommandText的类型：adCmdText-文本命令；adCmdTable-表名 adCmdProc-存储过程；adCmdUnknown-未知5.添加两个成员函数：(1)执行查询函数 _RecordsetPtr& GetRecordSet(_bstr_t bstrSQL);(2)执行SQL语句 BOOL ExecuteSQL(_bstr_t bstrSQL)。给出两个文件的完整代码：/*------------------ADOConn.h File-------------------------------------------------*/// ADOConn.h: interface for the ADOConn class.#import "c:\Program Files\Common Files\System\ado\msado15.dll" no_namespace rename("EOF","adoEOF") rename("BOF","adoBOF")#if !defined(AFX_ADOCONN_H__AC448F02_AF26_45E4_9B2D_D7ECB8FFCFB9__INCLUDED_)#define AFX_ADOCONN_H__AC448F02_AF26_45E4_9B2D_D7ECB8FFCFB9__INCLUDED_#if _MSC_VER > 1000#pragma once#endif // _MSC_VER > 1000class ADOConn {// 定义变量public://添加一个指向Connection对象的指针:_ConnectionPtr m_pConnection;//添加一个指向Recordset对象的指针:_RecordsetPtr m_pRecordset;// 定义方法public:ADOConn();virtual ~ADOConn();// 初始化—连接数据库void OnInitADOConn();// 执行查询_RecordsetPtr& GetRecordSet(_bstr_t bstrSQL);// 执行SQL语句，Insert Update _variant_tBOOL ExecuteSQL(_bstr_t bstrSQL);void ExitConnect();};#endif // !defined(AFX_ADOCONN_H__AC448F02_AF26_45E4_9B2D_D7ECB8FFCFB9__INCLUDED_)/*--------------------------------------------------------------------------------*/
/*---------------------ADOConn.cpp File---------------------------*/#include "stdafx.h"#include "ADOConn.h"#ifdef _DEBUG#undef THIS_FILEstatic char THIS_FILE[]=__FILE__;#define new DEBUG_NEW#endifADOConn::ADOConn(){}ADOConn::~ADOConn(){}// 初始化—连接数据库void ADOConn::OnInitADOConn(){// 初始化OLE/COM库环境::CoInitialize(NULL);try{// 创建Connection对象m_pConnection.CreateInstance("ADODB.Connection");// 设置连接字符串，必须是BSTR型或者_bstr_t类型_bstr_t strConnect = "Provider=SQLOLEDB; Server=CZ;Database=HrSys; uid=sa; pwd=sa;";m_pConnection->Open(strConnect,"","",adModeUnknown);}// 捕捉异常catch(_com_error e){// 显示错误信息AfxMessageBox(e.Description());}}// 执行查询_RecordsetPtr& ADOConn::GetRecordSet(_bstr_t bstrSQL){try{// 连接数据库，如果Connection对象为空，则重新连接数据库if(m_pConnection==NULL) OnInitADOConn();// 创建记录集对象m_pRecordset.CreateInstance(__uuidof(Recordset));// 取得表中的记录m_pRecordset->Open(bstrSQL,m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);}// 捕捉异常catch(_com_error e){// 显示错误信息AfxMessageBox(e.Description());}// 返回记录集return m_pRecordset;}// 执行SQL语句，Insert Update _variant_tBOOL ADOConn::ExecuteSQL(_bstr_t bstrSQL){// _variant_t RecordsAffected;try{// 是否已经连接数据库if(m_pConnection == NULL) OnInitADOConn();// Connection对象的Execute方法:(_bstr_t CommandText,// VARIANT * RecordsAffected, long Options )// 其中CommandText是命令字串，通常是SQL命令。// 参数RecordsAffected是操作完成后所影响的行数,// 参数Options表示CommandText的类型：adCmdText-文本命令；adCmdTable-表名// adCmdProc-存储过程；adCmdUnknown-未知m_pConnection->Execute(bstrSQL,NULL,adCmdText);return true;}catch(_com_error e){AfxMessageBox(e.Description());return false;}}void ADOConn::ExitConnect(){// 关闭记录集和连接if (m_pRecordset != NULL)m_pRecordset->Close();m_pConnection->Close();// 释放环境::CoUninitialize();}