封装游标存储过程(Prexecsql2)数据库教程

2024-05-04

封装游标存储过程(Prexecsql2)数据库教程（共4篇）

篇1：封装游标存储过程(Prexecsql2)数据库教程

12.3.1 查看存储过程

存储过程被创建以后，它的名字存储在系统表sysobjects 中；它的源代码存放在系统表syscomments 中，可以通过MS SQL Server 提供的系统存储过程来查看关于用户创建的存储过程信息。

1通过Enterprise Manager 管理工具同样可以查看存储过程的源代码

其操作如下：

（1）启动Enterprise Manager，登录到要使用的服务器。

（2）选择要创建存储过程的数据库，在左窗格中单击Stored Procedure 文件夹，此时在右窗格中显示该数据库的所有存储过程。

（3）在右窗格中，右击要查看源代码的存储过程，在弹出的菜单中选择Properties选项，此时便可看到存储过程的源代码。如图12-4 所示：

2 使用sp_helptext 存储过程查看存储过程的源代码

其语法格式如下：

sp_helptext 存储过程名称

例如要查看数据库pubs 是否是存储过程reptq1 的源代码，则执行sp_helptext reptq1。

注意：如果在创建存储过程时使用了WITH ENCRYPTION选项，那么无论是使用Enterprise Manager还是系统存储过程sp_helptext都无法查看到存储过程的源代码。

12.3.2 重新命名存储过程

修改存储过程的名字使用系统存储过程sp_rename。其命令格式为：

sp_rename 原存储过程名, 新存储过程名

例12-4 ：将存储过程reptq1 修改为newproc 其语句为：

sp_rename reptq1, newproc

另外，通过Enterprise Manager 也可修改存储过程的名字，其操作过程与WINDOWS 下修改文件名字的操作类似。即首先选中需修改名字的存储过程，然后右击鼠标，在弹出菜单中选取rename 选项，最后输入新存储过程的名字。

12.3.3 删除存储过程

删除存储过程使用drop 命令，drop 命令可将一个或多个存储过程或者存储过程组从

当前数据库中删除。其语法规则为：

DROP PROCEDURE {procedure}} [,…n]

例12-5：如将存储过程reptq1 从数据库中删除，则执行：

drop procedure reptq1

12.3.4 执行存储过程

执行已创建的存储过程使用EXECUTE 命令，其语法如下：

[EXECUTE]

{[@return_statur=]

{procedure_name[;number] | @procedure_name_var}

[[@parameter=] {value | @variable [OUTPUT] | [DEFAULT] [,…n]

[WITH RECOMPILE]

各参数的含义如下：

@return_status

是可选的整型变量，用来存储存储过程向调用者返回的值，

@procedure_name_var

是一变量名用来代表存储过程的名字。

其它参数据和保留字的含义与CREATE PROCEDURE 中介绍的一样。

例12-6：该存储过程被用来将两个字符串连接成一个字符串，并将结果返回。创建存储过程：

12.3.5 修改存储过程

修改以前用CREATE PROCEDURE 命令创建的存储过程，并且不改变权限的授予情况以及不影响任何其它的独立的存储过程或触发器常使用ALTER PROCEDURE 命令。其语法规则是：

ALTER PROC[EDURE] procedure_name [;number]

[ {@parameter data_type } [VARYING] [= default] [OUTPUT]] [,...n]

[WITH

{RECOMPILE | ENCRYPTION | RECOMPILE , ENCRYPTION}]

[FOR REPLICATION]

sql_statement [...n]

其中各参数和保留字的具体含义请参看CREATE PROCEDURE 命令。

下面将举一个例子使读者对该命令有更为深刻的理解。

将该段代码输入到SQL Server Query Analyzer 窗口中运行后结果为：

注意：由于在ALERT PROCEDURE中使用了WITH ENCTYPTION保留字，所以在查看修改后的存储过程源代码时看到是一些代码。

篇2：封装游标存储过程(Prexecsql2)数据库教程

从来没有接触过存储过程，为了这个项目写了几个存储过程，就当是学习了，呵呵，这个购物车的存储过程中使用了Table(表)，Cursor(游标）变量。

要求如下：

一个商品表[Ware]，里面包含有的字段有ID,MarketPrice,MemberPrice,VipPrice等等，还一个会员购物车[MemberCar]数据表。包括的有ID,MemberID,WareID,WareNum等等。现要求是能取得购物车表里的所有数据和MarketPrice*WareNum（所有商品和）的总价钱，即有N件商品就获取这N件商品的总价钱而不是单一的价钱。本来在客户端里直接根据购物车[MemberCar]表的数据读取商品表[Ware]里的数据，再用变量累加即可的。但问题却是，购物车里的所有商品显示使用了分页显示。所以累加时就出问题，如果为了累加这些价钱而在分页循环显示后再加一个循环所有记录来累加价钱数据，这样不是不行，但效率就可想而知了！！！

现一个解决方法就是，重新构造一个购物车表的镜像，但却多了商品的几个价钱总数字段。即MarketPrice*WareNum(单一商品)。从而读取购物车时不是读取原来购物车数据表，而是读取这个镜像数据表，并在读取时累加这些总价钱。

存储过程代码如下：

----#####################################################################################

----# 过程作用：返回用户购物车里的所有数据，并包含统计了商品的价钱 (价钱=商品表的价格*购物车表里的数量)

----# 作者：死在水中的鱼

----# 日期：10月15日

----#####################################################################################

CREATE PROCEDURE MemberCar_Info @MemberID INT AS

--使用此句才能保持客户端的数据

SET NOCOUNT ON

DECLARE @Car_ID int,@Car_WareID int,@Car_WareNum smallINt

DECLARE @Car_TotalMemberPrice Numeric(8,2),@Car_TotalMarketPrice Numeric(8,2),@Car_TotalVipPrice Numeric(8,2)

--定义一个查询MemberCar表的游标变量，

获取数据

DECLARE Car_Cursor Cursor For

Select ID,WareID,WareNum From [MemberCar] Where MemberID=@MemberID And IsPay=0

--建立一个临时表变量

DECLARE @Car_Table Table (ID INT,

WareID INT,WareNum SmallINT,MarketPrice Numeric(8,2),MemberPrice Numeric(8,2),VipPrice Numeric(8,2))

--打开MemberCar表提取数据到临时变量

OPEN Car_Cursor

FETCH NEXT FROM Car_Cursor INTO @Car_ID,@Car_WareID,@Car_WareNum

WHILE @@FETCH_STATUS = 0

BEGIN

--取得商品的总市场价、总会员价和总VIP价

Select @Car_TotalMarketPrice=MarketPrice*@Car_WareNum,@Car_TotalMemberPrice=MemberPrice*@Car_WareNum,@Car_TotalVipPrice=VipPrice*@Car_WareNum From [Ware] Where ID=@Car_WareID

--添加进临时变量表

INSERT INTO @Car_Table (ID,WareID,WareNum,MarketPrice,MemberPrice,VipPrice) Values (@Car_ID,@Car_WareID,@Car_WareNum,@Car_TotalMarketPrice,@Car_TotalMemberPrice,@Car_TotalVipPrice)

-- 没有到表尾，继续提取数据到临时变量

FETCH NEXT FROM Car_Cursor INTO @Car_ID,@Car_WareID,@Car_WareNum

END

--关闭MemberCar数据库的游标

CLOSE Car_Cursor

DEALLOCATE Car_Cursor

--返回最终数据表

SELECT * FROM @Car_Table

篇3：封装游标存储过程(Prexecsql2)数据库教程

SQL Server 的扩展存储过程，其实就是一个普通的 Windows DLL,只不过按照某种规则实现了某些函数而已，

编写安全的SQL Server扩展存储过程数据库教程

。

近日在写一个扩展存储过程时，发现再写这类动态库时，还是有一些需要特别注意的地方。之所以会特别注意，是因为DLL运行于SQL Server的地址空间，而SQL Server到底是怎么进行线程调度的，却不是我们能了解的，即便了解也无法控制。

我们写动态库一般是自己用，即便给别人用，也很少像SQL Server这样，一个动态库很有可能加载多次，并且都是加载到一个进程的地址空间中。我们知道，当一个动态库加载到进程的地址空间时，DLL所有全局与局部变量初始化且仅初始化一次，以后再次调用 LoadLibrary函数时，仅仅增加其引用计数而已，那么很显然，假如有一全局 int ,初始化为0，调用一个函数另其自加，此时其值为1,然后再调用LoadLibray,并利用返回的句柄调用输出函数输出该值，虽然调用者觉得自己加载后立即输出，然后该值确实1而不是0。windows是进程独立的，而在线程方面，假如不注意，上面的情况很可能会程序员带来麻烦。

介绍一下我的扩展存储过程，该动态库导出了三个函数: Init,work,Final,Init读文件，存储信息于内存，work简单的只是向该内存检索信息,Final回收内存。如上所说，假如不考虑同一进程空间多次加载问题，两次调用Init将造成无谓的浪费，因为我第一次已经读进了内存，要是通过堆分配内存，还会造成内存泄露。

我使用的引用计数解决的该问题，代码很短，直接贴上来：

#include “stdafx.h”

#include

using namespace std;

extern “C” {

RETCODE __declspec(dllexport) xp_part_init(SRV_PROC *srvproc);

RETCODE __declspec(dllexport) xp_part_process(SRV_PROC *srvproc);

RETCODE __declspec(dllexport) xp_part_finalize(SRV_PROC *srvproc);

}

#define XP_NOERROR 0

#define XP_ERROR 1

HINSTANCE hInst = NULL;

int nRef = 0;

void printError (SRV_PROC *pSrvProc, CHAR* szErrorMsg);

ULONG __GetXpVersion{ return ODS_VERSION;}

SRVRETCODE xp_part_init(SRV_PROC* pSrvProc){

typedef bool (*Func)();

if(nRef == 0){

hInst = ::LoadLibrary(“part.dll”);

if(hInst == NULL){

printError(pSrvProc,“不能加载part.dll”);

return XP_ERROR;

}

Func theFunc = (Func)::GetProcAddress(hInst,“Init”);

if(!theFunc()){

::FreeLibrary(hInst);

printError(pSrvProc,“不能获得分类号与专辑的对应表”);

return XP_ERROR;

}

++ nRef;

return (XP_NOERROR);

}

SRVRETCODE xp_part_process(SRV_PROC* pSrvProc){

typedef bool (*Func)(char*);

if(nRef == 0){

printError(pSrvProc,“函数尚未初始化,请首先调用xp_part_init”);

return XP_ERROR;

}

Func theFunc = (Func)::GetProcAddress(hInst,“Get”);

BYTE bType;

ULONG cbMaxLen,cbActualLen;

BOOL fNull;

char szInput[256] = {0};

if (srv_paraminfo(pSrvProc, 1, &bType, (ULONG*)&cbMaxLen, (ULONG*)&cbActualLen, (BYTE*)szInput, &fNull) == FAIL){

printError(pSrvProc,“srv_paraminfo 返回 FAIL”);

return XP_ERROR;

}

szInput[cbActualLen] = 0;

string strInput = szInput;

string strOutput = “;”;

int cur,old = 0;

while(string::npos != (cur = strInput.find(’;’,old)) ){

strncpy(szInput,strInput.c_str() + old,cur - old);

szInput[cur - old] = 0;

ld = cur + 1;

theFunc(szInput);

if(string::npos ==strOutput.find((string)“;” + szInput))

strOutput += szInput;

}

strcpy(szInput,strOutput.c_str());

if (FAIL == srv_paramsetoutput(pSrvProc, 1, (BYTE*)(szInput + 1), strlen(szInput) - 1,FALSE)){

printError (pSrvProc, “srv_paramsetoutput 调用失败”);

return XP_ERROR;

}

srv_senddone(pSrvProc, (SRV_DONE_COUNT | SRV_DONE_MORE), 0, 0);

return XP_NOERROR;

}

SRVRETCODE xp_part_finalize(SRV_PROC* pSrvProc){

typedef void (*Func)();

if(nRef == 0)

return XP_NOERROR;

Func theFunc = (Func)::GetProcAddress(hInst,“Fin”);

if((--nRef) == 0){

theFunc();

::FreeLibrary(hInst);

hInst = NULL;

}

return (XP_NOERROR);

}

我想虽然看上去不是很高明，然而问题应该是解决了的，

还有一点说明，为什么不使用Tls，老实说，我考虑过使用的，因为其实代码是有一点问题的，假如一个用户调用xp_part_init,然后另一个用户也调用xp_part_init，注意我们的存储过程可是服务器端的，然后第一个用户调用xp_part_finalize，那么会怎样，他仍然可以正常使用xp_part_process，这倒无所谓，然而第一个用户调用两次xp_part_finalize，就能够影响第二个用户了，他的xp_part_process将返回错误。

使用Tls 似乎可以解决这问题，例如再添加一个tls_index变量，调用 TlsSetValue保存用户私人数据，TlsGetValue检索私人数据，当xp_part_init时，假如该私人数据为0，执行正常的初始化过程，(即上面的xp_part_init)执行成功后存储私人数据为1，假如是1，直接返回，xp_part_finalize时，假如私人数据为1，则执行正常的xp_part_finalize，然后设私人数据为0，假如是0，直接返回。