OLEDB 调用存储过程

除了常规调用sql语句和进行简单的插入删除操作外,OLEDB还提供了调用存储过程的功能,存储过程就好像是用SQL语句写成的一个函数,可以有参数,有返回值。 存储过程除了像普通函数那样返回一般的值以外,还可以返回结果集,对于返回的内容可以使用输出参数的方式获取,但是如果返回的是结果集,一般不推荐使用输出参数来获取,一般采用的是使用多结果集来接收。另外对于输入参数一般采用参数化查询的方式进行,因此它的使用与参数化查询类似,但是相比于参数化查询来说要复杂一些。

存储过程的使用

对于输出参数,在绑定DBBINDING 结构的时候,将结构的eParamIO指定为DBPARAMIO_OUTPUT,调用存储过程可以使用类似下面的格式

{? = call myProc(?, ?)}

这个样式中两个大括号是必须的,其中?代表的输入输出参数,call表示调用存储过程,也是必须的。 一般来说,存储过程的参数位置只接受输入,不作为输出参数,而存储过程的返回值位置只作为输出,不作为输入。另外最需要注意的一点是:当存储过程返回结果集的时候,返回的结果集指针如果没有被释放的话,输出参数的缓冲是不会被刷新的,也就是接收不到输出参数。这是由于数据提供者在返回这些数据的时候是按照流的方式。而结果集的流在输出参数和返回值的流之前,所以在结果集未被释放之前,应用程序是接收不到输出参数的。 针对他的这个特性,我们一般是先使用存储过程返回的结果集,然后释放结果集的相关指针,接着从输出参数的缓冲中取出数据,最后释放这些缓冲。

存储过程使用的例子

BOOL ExecUsp(IOpenRowset *pIOpenRowset)
{
    IAccessor *pParamAccessor = NULL;

    LPOLESTR pSQL = OLESTR("{? = call Usp_InputOutput(?,?)}");
    DB_UPARAMS cParams = 0;
    DBPARAMINFO* rgParamInfo = NULL;
    DBBINDING* rgParamBind = NULL;
    LPOLESTR pParamNames = NULL;
    DWORD dwOffset = 0;
    HACCESSOR hAccessor = NULL;
    TCHAR szInputBuffer[11] = _T("");
    DBPARAMS dbParams = {0};
    BOOL bRet = FALSE;

    HRESULT hRes = pIOpenRowset->QueryInterface(IID_IDBCreateCommand, (void**)&pIDBCreateCommand);
    hRes = pIDBCreateCommand->CreateCommand(NULL, IID_ICommandText, (IUnknown**)&pICommandText);

    hRes = pICommandText->SetCommandText(DBGUID_DEFAULT, pSQL);
    hRes = pICommandText->QueryInterface(IID_ICommandPrepare, (void**)&pICommandPrepare);
    hRes = pICommandPrepare->Prepare(0);

    hRes = pICommandText->QueryInterface(IID_ICommandWithParameters, (void**)&pICommandWithParameters);
    hRes = pICommandWithParameters->GetParameterInfo(&cParams, &rgParamInfo, &pParamNames);

    //参数绑定
    rgParamBind = (DBBINDING*)MALLOC(sizeof(DBBINDING) * cParams);
    for (int i = 0; i < cParams; i++)
    {
        rgParamBind[i].bPrecision = 11;
        rgParamBind[i].bScale = rgParamInfo[i].bScale;
        rgParamBind[i].cbMaxLen = rgParamInfo[i].ulParamSize; //由于都是int型,所以这里就不需要指定多余的缓冲
        rgParamBind[i].iOrdinal = rgParamInfo[i].iOrdinal;
        rgParamBind[i].dwPart = DBPART_VALUE;
    //当发现参数是输入参数的时候,在eParamIO中加一个输入参数的性质,
        if (rgParamInfo[i].dwFlags & DBPARAMFLAGS_ISINPUT)
        {
            rgParamBind[i].eParamIO |= DBPARAMIO_INPUT;
        }

    //同上
        if (rgParamInfo[i].dwFlags & DBPARAMFLAGS_ISOUTPUT)
        {
            rgParamBind[i].eParamIO |= DBPARAMIO_OUTPUT;
        }

        rgParamBind[i].dwMemOwner = DBMEMOWNER_CLIENTOWNED;
        rgParamBind[i].obLength = 0;
        rgParamBind[i].obStatus = 0;
        rgParamBind[i].obValue = dwOffset;
        dwOffset = rgParamBind[i].obValue + rgParamBind[i].cbMaxLen;
        rgParamBind[i].wType = rgParamInfo[i].wType; //其实他们都是int型
    }

    //创建参数的访问器
    hRes = pICommandText->QueryInterface(IID_IAccessor, (void**)&pParamAccessor);
    COM_SUCCESS(hRes, _T("查询接口pParamAccessor失败,错误码为:%08x\n"), hRes);
    hRes = pParamAccessor->CreateAccessor(DBACCESSOR_PARAMETERDATA, cParams, rgParamBind, dwOffset, &hAccessor, NULL);
    COM_SUCCESS(hRes, _T("创建访问器失败,错误码为:%08x\n"), hRes);

    //设置参数值
    dbParams.pData = MALLOC(dwOffset);
    ZeroMemory(dbParams.pData , dwOffset);
    dbParams.cParamSets = cParams;
    dbParams.hAccessor = hAccessor;
    for (int i = 0; i < cParams; i++)
    {
        if (rgParamBind[i].eParamIO & DBPARAMIO_INPUT)
        {
            COM_PRINT(_T("请输入第%d个参数的值[%s]:"), i + 1, rgParamInfo[i].pwszName);
            while (S_OK != StringCchGets(szInputBuffer, 11));

            *(int*)((BYTE*)dbParams.pData + rgParamBind[i].obValue) = _ttoi(szInputBuffer);
            ZeroMemory(szInputBuffer, 11 * sizeof(TCHAR));
        }
    }

    hRes = pICommandText->Execute(NULL, IID_IMultipleResults, &dbParams, NULL, (IUnknown**)&pIMultipleResults);

    //读取结果集
    ReadRowset(pIMultipleResults);
    COM_PRINT(_T("返回值为:%d\n"), *(int*)dbParams.pData)
    bRet = TRUE;

__CLEAR_UP:
    CoTaskMemFree(rgParamInfo);
    FREE(rgParamBind);
    CoTaskMemFree(pParamNames);
    FREE(dbParams.pData);

    SAFE_RELEASE(pIDBCreateCommand);
    SAFE_RELEASE(pICommandText);
    SAFE_RELEASE(pICommandPrepare);
    SAFE_RELEASE(pICommandWithParameters);
    SAFE_RELEASE(pParamAccessor);
    SAFE_RELEASE(pIMultipleResults);

    return bRet;
}

上述代码中调用的存储过程如下:

ALTER PROCEDURE [dbo].[Usp_InputOutput]
    @input int,
    @output int Output

AS
BEGIN
    select @input, @output
    set @output = 2
    return 7
END

该存储过程输入两个参数,并通过select返回有这两个参数组成的结果集。存储过程的输出参数为7. 在上述代码中,先定义了一个调用存储过程的sql语句,接着在ICommandText对象中设置该存储过程,然后获取参数的相关信息,然后绑定参数,提供输出、输出参数的缓冲,然后执行存储过程获取结果集。接着读取结果集。最后读取返回值。 上面我们说过如果不释放返回的结果集的指针的话,是接收不到返回值的,但是在这段代码中好像在读取返回值之前没有释放返回的IMultipleResults指针的操作,但是还是可以取到结果集的,这是为什么呢?其实之前说的是返回的结果集,但是并没有说是多行结果集,这里释放的主要是结果集。针对多行结果集,我们只要释放它里面包含的所有结果集对象就可以了。释放结果集的代码在函数ReadRowset中,这里并没有列举出来。

最后:完整的代码:请点击这里查看


本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Java 源码分析

JavaWeb基础

1. XML xml一般就用来存放少量的数据,或者是作为配置文件。 xml的声明<?xml version=”1.0” encoding=”utf-8”?> ...

36550
来自专栏技术博文

PHP编程风格规范

本规范由 EasyChen 借鉴 SINA网络应用开发部《C++开发规范》和互动技术部《PHP4开发规范》,以及phpDocument规范 整理出的开发规范。我...

41870
来自专栏kangvcar

AWK 入门简明教程

15430
来自专栏blackpiglet

Go 语言反射和范型在 API 服务中的应用

  API 接口自然是要获取传过来的数据,不同接口要获取的数据自然也不一样,如果不做特殊处理,必然是每个接口都有一堆功能重复的从 request 里获取参数的代...

8320
来自专栏hbbliyong

c++/c 获取cpp文件行号跟文件名

编译器内置宏: 先介绍几个编译器内置的宏定义,这些宏定义不仅可以帮助我们完成跨平台的源码编写,灵活使用也可以巧妙地帮我们输出非常有用的调试信息。 ANSI C标...

30270
来自专栏Java后端生活

JDBC(四)JDBC元数据和反射的利用

Java 通过JDBC获得连接以后,得到一个Connection 对象,可以从这个对象获得有关数据库管理系统的各种信息,包括数据库中的各个表,表中的各个列,数据...

7620
来自专栏木木玲

Netty 源码解析 ——— ChannelConfig 和 Attribute

30320
来自专栏余林丰

单例模式

单例模式,顾名思义,在程序运行时有且仅有一个实例存在。最常见的一个应用场景就是网站访问量的计数器,试想如果允许创建多个实例,那还怎么计数,这个时候就得创建有且仅...

21550
来自专栏古时的风筝

SharePoint—用REST方式访问列表

REST的定义与作用                                                                      ...

22550
来自专栏大学生计算机视觉学习DeepLearning

c++ 常用的遍历,删除,分割等等文件处理函数代码实现

原文链接:https://www.cnblogs.com/DOMLX/p/9622851.html

16820

扫码关注云+社区

领取腾讯云代金券