Visual C++中使用OLE DB读写SQL Server简明指南

    在需要对数据库进行操作时，OLE DB总是被认为是一种效率最高但最难的方法。但是以我最近使用OLE DB的经验看来，OLE DB的效率高则高矣，但却一点都不难。说它难恐怕主要是因为可参考的中文资料太少，为了帮助以后需要接触OLE DB的同行，我撰写了这篇文章。本文包含如下内容：

    1. OLE DB写数据库；
    2. OLE DB读数据库；
    3. OLE DB对二进制数据(text、ntext、image等)的处理。

    首先来看看对SQL Server进行写操作的代码，有一定VC基础的读者应该可以很顺利地看懂。OLE DB写数据库，就是这么简单！

    注:
    1.以下代码中使用的模板类EAutoReleasePtr<T>与ATL中的CComPtr<T>类似，是一个在析构时自动调用Release的类。CComPtr<T>的代码在ATLBASE.H中定义。
    2.以下代码均在UNICODE环境下编译，因为执行的SQL语句必须是UNICODE的。设置工程为UNICODE的方法是:首先在project->settings->C/C++的属性页中的Preprocessor中，删除_MBCS写入UNICODE,_UNICODE。然后在link属性页中Category中选择output，在Entry-Point symbol 中添加wWinMainCRTStartup。

    EAutoReleasePtr<IDBInitialize> pIDBInitialize;
    HRESULT hResult = ConnectDatabase( &pIDBInitialize, _T("127.0.0.1"), _T(“sa”), _T("password") );
    if( FAILED( hResult ) )
    {
        //失败，可能是因为数据库没有启动、用户名密码错等等
        return;
    }

    EAutoReleasePtr<IOpenRowset> pIOpenRowset;
    hResult = CreateSession( pIDBInitialize, &pIOpenRowset );
    if( FAILED( hResult ) )
    {
        //出错
        return;
    }

    EAutoReleasePtr<ICommand> pICommand;
    EAutoReleasePtr<ICommandText> pICommandText;
    hResult = CreateCommand( pIOpenRowset, &pICommand, &pICommandText );
    if( FAILED( hResult ) )
    {
       //出错
        return;
    }

    hResult = ExecuteSQL( pICommand, pICommandText, _T("USE PBDATA") );
    if( FAILED( hResult ) )
    {
        //如果这里失败，那就是SQL语句执行失败。在此处，就是PBDATA还未创建
        return;
    }

    // 创建表
    ExecuteSQL( pICommand, pICommandText, _T("CREATE TABLE 2005_1(Volume real NOT NULL,ID int NOT NULL IDENTITY)") );

    // 添加记录
    ExecuteSQL( pICommand, pICommandText, _T("INSERT INTO 2005_1 VALUES(100.0)") );

    //...

    其中几个函数的代码如下:

    HRESULT ConnectDatabase( IDBInitialize** ppIDBInitialize, LPCTSTR pszDataSource, LPCTSTR pszUserID, LPCTSTR pszPassword )
    {
        ASSERT( ppIDBInitialize != NULL && pszDataSource != NULL && pszUserID != NULL && pszPassword != NULL );

        UINT uTimeout ＝ 15U; // 连接数据库超时（秒）
        TCHAR szInitStr[1024];
        VERIFY( 1023 >= wsprintf( szInitStr, _T("Provider=SQLOLEDB;Data Source=%s;Initial Catalog=master;User Id=%s;Password=%s;Connect Timeout=%u"), pszDataSource, pszUserID, pszPassword, uTimeout ) );
        //Initial Catalog=master指明连接成功后，"USE master"。

        EAutoReleasePtr<IDataInitialize> pIDataInitialize;
        HRESULT hResult = ::CoCreateInstance( CLSID_MSDAINITIALIZE, NULL, CLSCTX_INPROC_SERVER,
                IID_IDataInitialize, ( void** )&pIDataInitialize );
        if( FAILED( hResult ) )
        {
            return hResult;
        }

        EAutoReleasePtr<IDBInitialize> pIDBInitialize;
        hResult = pIDataInitialize->GetDataSource( NULL, CLSCTX_INPROC_SERVER, ( LPCOLESTR )szInitStr,
                  IID_IDBInitialize, ( IUnknown** )&pIDBInitialize );
        if( FAILED( hResult ) )
        {
            return hResult;
        }
        hResult = pIDBInitialize->Initialize( );
        if( FAILED( hResult ) )
        {
            return hResult;
        }
        * ppIDBInitialize = pIDBInitialize.Detach( );
        return S_OK;
    }

    HRESULT CreateSession( IDBInitialize* pIDBInitialize, IOpenRowset** ppIOpenRowset )
    {
        ASSERT( pIDBInitialize != NULL && ppIOpenRowset != NULL );
        EAutoReleasePtr<IDBCreateSession> pSession;
        HRESULT hResult = pIDBInitialize->QueryInterface( IID_IDBCreateSession, ( void** )&pSession );
        if( FAILED( hResult ) )
        {
            return hResult;
        }
        EAutoReleasePtr<IOpenRowset> pIOpenRowset;
        hResult = pSession->CreateSession( NULL, IID_IOpenRowset, ( IUnknown** )&pIOpenRowset );
        if( FAILED( hResult ) )
        {
            return hResult;
        }
        * ppIOpenRowset = pIOpenRowset.Detach( );
        return S_OK;
    }

    HRESULT CreateCommand( IOpenRowset* pIOpenRowset, ICommand** ppICommand, ICommandText** ppICommandText )
    {
        ASSERT( pIOpenRowset != NULL && ppICommand != NULL && ppICommandText != NULL );
        HRESULT hResult;
        EAutoReleasePtr<ICommand> pICommand;
        {
            EAutoReleasePtr<IDBCreateCommand> pICreateCommand;
            hResult = pIOpenRowset->QueryInterface( IID_IDBCreateCommand, ( void** )&pICreateCommand );
            if( FAILED( hResult ) )
            {
                return hResult;
            }

            hResult = pICreateCommand->CreateCommand( NULL, IID_ICommand, (IUnknown**)&pICommand );
            if( FAILED( hResult ) )
            {
                return hResult;
            }
        }
        EAutoReleasePtr<ICommandText> pICommandText;
        hResult = pICommand->QueryInterface( &pICommandText );
        if( FAILED( hResult ) )
        {
            return hResult;
        }
        * ppICommand = pICommand.Detach( );
        * ppICommandText = pICommandText.Detach( );
        return S_OK;
    }

    HRESULT ExecuteSQL( ICommand* pICommand, ICommandText* pICommandText, LPCTSTR pszCommand, LONG* plRowsAffected )
    {
        ASSERT( pICommand != NULL && pICommandText != NULL && pszCommand != NULL && pszCommand[0] != 0 );

        HRESULT hResult = pICommandText->SetCommandText( DBGUID_DBSQL, ( LPCOLESTR )pszCommand );
        if( FAILED( hResult ) )
        {
            return hResult;
        }
        LONG lAffected;
        hResult = pICommand->Execute( NULL, IID_NULL, NULL, plRowsAffected == NULL ? &lAffected : plRowsAffected, ( IUnknown** )NULL );
        return hResult;
    }

    以上就是写数据库的全部代码了，是不是很简单呢？下面再来读的。

    // 先用与上面代码中一样的步骤获取pICommand，pICommandText。此处省略