在存储过程中调用外部的动态连接库

在存储过程中调用外部的动态连接库2002-03-28 ac952_z_cn vckbase 问题的提出：一般我们要根据数据库的纪录变化时，进行某种操作。我们习惯的操作方式是在程序中不停的查询表，判断是否有新纪录。这样耗费的资源就很高，如何提高这种效率，我想在表中创建触发器，在触发器中调用外部动态连接库通过消息或事件通知应用程序就可实现。而master的存储过程中最好能调用外部的动态连接库，我们在触发器中调用master的存储过程即可。说明:VC6需要安装较新的Platform SDK才能顺利编译本代码，VC.Net可以直接编译本代码。另外还需要连接Opends60.lib为了使没有较新Platform SDK的朋友也能编译本例子，已经将VC.Net中的Srv.h和Opends60.lib放到压缩包中程序实现：我们来实现一个存储过程中调用外部的dll（storeproc.dll）的函数SetFileName和addLine。存储过程如下（需放到master库中）： CREATE PROCEDURE sp_testdll ASexec sp_addextendedproc SetFileName, storeproc.dll -声明函数exec sp_addextendedproc addLine, storeproc.dll declare szFileName varchar（200） declare szText varchar（200）declare rt intSelect szFileName = c:welcome.txtEXEC rt = SetFileName szFileName -调用SetFileName函数，参数为-szFileName;if rt = 0beginselect szText = welcome 01Exec rt = addLine szText -调用addLineselect szText = welcome 02Exec rt = addLine szTextendexec sp_dropextendedproc SetFileNameexec sp_dropextendedproc addLinedbcc SetFileName（free）dbcc addLine（free）动态连接库的实现：这种动态连接库和普通的有所不同。该动态连接库要放入SQL的执行目录下，或直接放到Window的System32目录下,并重起SQL-Server #include #include/要加入这个.h文件#define XP_NOERROR0#define XP_ERROR1#ifndef _DEBUG#define _DEBUG#endifchar szFileNameMAX_PATH+1;void WriteInfo（const char * str）;extern C SRVRETCODE WINAPI SetFileName（SRV_PROC* pSrvProc）WriteInfo（SetFileName start）;int paramCount = srv_rpcparams（pSrvProc）;if （paramCount != 1）WriteInfo（Param Err start）;return XP_ERROR;BYTEbType;unsigned long cbMaxLen;unsigned long cbActualLen;BOOLfNull;int ret = srv_paraminfo（pSrvProc, 1, &bType, &cbMaxLen, &cbActualLen,NULL, &fNull）;if （cbActualLen）ZeroMemory（szFileName, MAX_PATH+1）;memcpy（szFileName, srv_paramdata（pSrvProc, 1）, cbActualLen）;WriteInfo（Set filename ok）;return （XP_NOERROR）;else WriteInfo（Set filename param failed）;return XP_ERROR;extern C SRVRETCODE WINAPI addLine（SRV_PROC* pSrvProc）WriteInfo（addline start）;int paramCount = srv_rpcparams（pSrvProc）;if （paramCount != 1）WriteInfo（addline param err）;return XP_ERROR;BYTEbType;unsigned longcbMaxLen;unsigned longcbActualLen;BOOLfNull;boolrt = false;int ret = srv_paraminfo（pSrvProc, 1, &bType, &cbMaxLen, &cbActualLen,NULL, &fNull）;if （cbActualLen）int n;char srt3 = 0x0d, 0x0a, 0;char * c = new charcbActualLen + 3;if （!c）return XP_ERROR;ZeroMemory（c, cbActualLen + 3）;memcpy（c, srv_paramdata（pSrvProc, 1）, cbActualLen）;memcpy（c+cbActualLen, srt, 3）;HANDLE hf = CreateFile（szFileName, GENERIC_WRITE, FILE_SHARE_WRITE|FILE_SHARE_READ, NULL, OPEN_ALWAYS, 0, NULL）;if （hf = INVALID_HANDLE_VALUE）WriteInfo（addline create file err ）;delete c;return XP_ERROR;WriteInfo（addline create file ok ）;DWORD dwWt;n = strlen（c）;SetFilePointer（hf, 0, NULL, FILE_END）;if （WriteFile（hf, c, n, &dwWt, NULL） & dwWt = n）WriteInfo（addline write file ok ）;rt = true;delete c;CloseHandle（hf）;return rt ? XP_NOERROR:XP_ERROR;inline void WriteInfo（const char * str）#ifdef _DEBUGchar srt3 = 0x0d, 0x0a, 0;HANDLE hf = CreateFile（c:storeproc.log, GENERIC_WRITE, FILE_SHARE_WRITE|FILE_SHARE_READ, NULL, OPEN_ALWAYS, 0, NULL）;if （hf != INVALID_HANDLE_VALUE）SetFilePointer（hf, 0, NULL, FILE_END）;DWORD dwWt;WriteFile（hf, str, strlen（str）, &dwWt, NULL）;WriteFile（hf, srt, strlen（srt）, &dwWt, NULL）;CloseHandle（hf）;else MessageBox（NULL, Write info err, Message, MB_OK|MB_ICONINFORMATION）;#endifBOOL WINAPI DllMain（HINSTANCE hinstDLL,DWORD fdwReason,LPVOID lpReserved）return TRUE;编译完成后，把动态链接库放到WINNT/System32目录下,启动SQL Server。我们可以打开SQL Server Query Analyzer调用存储过程