/*

VC++下使用ADO操作数据库简单实例

author：chenyuan

1，向User表插入一条数据

2，查询User表并输出结果集

*/

#include "stdafx.h"

//stdafx.h" 包含如下文件

//#include "targetver.h"

//#include <stdio.h>

//#include <tchar.h>

//#include <icrsint.h>

//#include <iostream>

//#include <iomanip>

//#include <string>

using namespace std;

//(1)、引入ADO类

#import "c:\program files\common files\system\ado\msado15.dll" \

    no_namespace \

rename ("EOF", "adoEOF")

#define ConStr "Driver={sql server};server=127.0.0.1,1433;uid=sa;pwd=123456;database=YLTD2;"

//"Provider=SQLOLEDB;Server=127.0.0.1,1433;Database=PBMS;uid=sa;pwd=pp471006459;";

//"Provider=SQLOLEDB.1;Password=pp471006459;Persist Security Info=True;User ID=sa;"

//"Initial Catalog=PBMS;Data Source=127.0.0.1,1433";

//以上这三条strConnect语句都可以用

//要注意修改用户名uid、密码pwd、数据库名database

#define GetValue(ptr,name) ((char*)(_bstr_t)(ptr->GetCollect(name)))

int ExcuteStr1(_bstr_t sql);

int ExcuteStr2(variant_t sql);

int main()

{

    ExcuteStr1("INSERT [dbo].[User]([Name],[DisplayName],[Password],[Status],[Sex],[Tel],[Mobile],[Email],[RoleID]) Values('C++Test','yuanker','123456',1,1,15911111111,1111111,111111,1)");

    ExcuteStr2("SELECT * FROM [dbo].[User]");

    system("pause");

    return ;

}

int ExcuteStr1(_bstr_t sql) {

    //定义ADO对象指针。初始化定义上的指针。

    _RecordsetPtr m_pRecordset = NULL;

    _ConnectionPtr m_pConnection = NULL;

    _CommandPtr m_pCommand = NULL;

    HRESULT hr = S_OK;

    if (FAILED(CoInitialize(NULL)))//CoInitialize用来初始化当前线程COM库，后面CoUninitialize与之对应，用来关闭当前线程的COM库

        return -;//如果初始化失败则返回-1

                  //初始化连接参数

    try

    {

        if (SUCCEEDED(hr)) {

            _bstr_t strConnect = ConStr;

            //创建实例

            m_pConnection.CreateInstance(__uuidof(Connection));

            /*打开连接

            ConnectionString   可选，字符串，包含连接信息。参阅 ConnectionString 属性可获得有效设置的详细信息。

            UserID   可选，字符串，包含建立连接时所使用用户名。

            Password   可选，字符串，包含建立连接时所使用密码。

            Options   可选，ConnectOptionEnum 值。决定该方法是在连接建立之后（异步）还是连接建立之前（同步）返回。adConnectUnspecified:（默认）同步打开连接。adAsyncConnect:异步打开连接。ConnectComplete 事件可以用于决定连接何时可用。

            */

            m_pConnection->Open(strConnect, "", "", adConnectUnspecified);

            m_pCommand.CreateInstance(__uuidof(Command));

            // 将库连接赋于它

            m_pCommand->ActiveConnection = m_pConnection;

            // SQL语句

            m_pCommand->CommandText = sql;

            // 执行SQL语句，返回记录集

            /*adCmdText: 表明CommandText是文本命令

            adCmdTable : 表明CommandText是一个表名

            adCmdProc : 表明CommandText是一个存储过程

            adCmdUnknown : 未知*/

            m_pRecordset = m_pCommand->Execute(NULL, NULL, adCmdText);

            if (m_pRecordset)

                if (m_pRecordset->State == adStateOpen)

                    m_pRecordset->Close();

            if (m_pConnection)

                if (m_pConnection->State == adStateOpen)

                    m_pConnection->Close();

            CoUninitialize();

        }

    }

    catch (_com_error &e)

    {

        cout << e.Description() << endl;

        return -;

    }

    return ;

}

int ExcuteStr2(variant_t sql) {

    //定义ADO对象指针。初始化定义上的指针。

    _RecordsetPtr m_pRecordset = NULL;

    _ConnectionPtr m_pConnection = NULL;

    HRESULT hr = S_OK;

    if (FAILED(CoInitialize(NULL)))//CoInitialize用来初始化当前线程COM库，后面CoUninitialize与之对应，用来关闭当前线程的COM库

        return -;//如果初始化失败则返回-1

    //初始化连接参数

    try

    {

        if (SUCCEEDED(hr)) {

            _bstr_t strConnect = ConStr;

            m_pConnection.CreateInstance(__uuidof(Connection));

            /*打开连接

            ConnectionString   可选，字符串，包含连接信息。参阅 ConnectionString 属性可获得有效设置的详细信息。

            UserID   可选，字符串，包含建立连接时所使用用户名。

            Password   可选，字符串，包含建立连接时所使用密码。

            Options   可选，ConnectOptionEnum 值。决定该方法是在连接建立之后（异步）还是连接建立之前（同步）返回。adConnectUnspecified:（默认）同步打开连接。adAsyncConnect:异步打开连接。ConnectComplete 事件可以用于决定连接何时可用。

            */

            m_pConnection->Open(strConnect, "", "", adConnectUnspecified);

            m_pRecordset.CreateInstance(__uuidof(Recordset));

            /*

            ①Source是数据查询字符串

            ②ActiveConnection是已经建立好的连接（我们需要用Connection对象指针来构造一个_variant_t对象)

            ③CursorType光标类型，它可以是以下值之一, 请看这个枚举结构:

            enum CursorTypeEnum

            {

            adOpenUnspecified = -1,///不作特别指定

            adOpenForwardOnly = 0,///前滚静态光标。这种光标只能向前浏览记录集，比如用MoveNext向前滚动,这

            种方式可以提高浏览速度。但诸如BookMark, RecordCount, AbsolutePosition, AbsolutePage都不能使用

            adOpenKeyset = 1,///采用这种光标的记录集看不到其它用户的新增、删除操作，但对于更新原有记录的

            操作对你是可见的。

            adOpenDynamic = 2,///动态光标。所有数据库的操作都会立即在各用户记录集上反应出来。

            adOpenStatic = 3///静态光标。它为你的记录集产生一个静态备份，但其它用户的新增、删除、更新操

            作对你的记录集来说是不可见的。

            };

            ④LockType锁定类型，它可以是以下值之一，请看如下枚举结构：

            enum LockTypeEnum

            {

            adLockUnspecified = -1,///未指定

            adLockReadOnly = 1,///只读记录集

            adLockPessimistic = 2, 悲观锁定方式。数据在更新时锁定其它所有动作，这是最安全的锁定机制

            adLockOptimistic = 3, 乐观锁定方式。只有在你调用Update方法时才锁定记录。在此之前仍然可以做数

            据的更新、插入、删除等动作

            adLockBatchOptimistic = 4，乐观分批更新。编辑时记录不会锁定，更改、插入及删除是在批处理模式下完成。

            };

            5.option可以取以下值

            adCmdText : 表明CommandText是文本命令

            adCmdTable : 表明CommandText是一个表名

            adCmdProc : 表明CommandText是一个存储过程

            adCmdUnknown : 未知

            */

            m_pRecordset->Open(sql, (IDispatch *)m_pConnection, adOpenDynamic, adLockOptimistic, adCmdText);

            m_pRecordset->MoveFirst();

            while (!m_pRecordset->adoEOF)//此处adoEOF为上面的 rename("EOF","adoEOF")

            {

                /*string Name = (char*)(_bstr_t)(m_pRecordset->Fields->GetItem(_variant_t("Name"))->Value);

                string Password = (char*)(_bstr_t)(m_pRecordset->Fields->GetItem(_variant_t("Password"))->Value);*/

                string ID = GetValue(m_pRecordset, "ID");

                string Name = GetValue(m_pRecordset,"Name");

                string Password = GetValue(m_pRecordset, "Password");

                string Sex = GetValue(m_pRecordset, "Sex");

                cout << "编号：" << ID << "  姓名：" << Name << "  密码：" << Password << "  性别：" << Sex << endl;

                m_pRecordset->MoveNext();

            }

            //关闭结果集

            if (m_pRecordset)

                if (m_pRecordset->State == adStateOpen)

                    m_pRecordset->Close();

            if (m_pConnection)

                if (m_pConnection->State == adStateOpen)

                    m_pConnection->Close();

            CoUninitialize();

        }

    }

    catch (_com_error &e)

    {

        cout << e.Description() << endl;

        return -;

    }

    return ;

}