自定义函数和存储过程在.net里其实都是
方法。只是
方法上方标注[Microsoft.
sqlServer.Server.
sqlProcedure]
和[Microsoft.
sqlServer.Server.
sqlFunction]不同而已。
自定义函数又分TVF
函数和Scalar两种，最大区别在于TVF返回表后者返回Scalar（标量），这一篇我们做一下比较。
先看两段
代码
存储过程:
using
System;
using
System.Data;
using
System.Data.sqlClient;
using
System.Data.sqlTypes;
using
Microsoft.sqlServer.Server;
public
partial
class
StoredProcedures
{
//这里是告诉sqlserver，这个方法要注册成存储过程
//我感觉[Attribute]这个东西翻译成标签更形像:)
[Microsoft.sqlServer.Server.sqlProcedure]
public static void TestStoredProcedure(string name, ref string outstr)
{
// 在此处放置代码
outstr = "hello," + name;
using (sqlConnection cn = new sqlConnection())
{
//使用上下文链接也就是当前数据库链接
cn.ConnectionString = "context connection=true";
using (sqlCommand cmd = cn.CreateCommand())
{
cmd.CommandText = "Select * from userinfo";
cn.open();
//sqlContext.Pipe.Send这个方法输出结果集
//接受sqlDataReader,sqlDataRecord和string
sqlContext.Pipe.Send(cmd.ExecuteReader());
//你也可以用下边这样
//sqlContext.Pipe.ExecuteAndSend(cmd);
}
}
}
}
;
执行存储过程
DECLARE
@name
nvarchar
(
4000
)
DECLARE
@outstr
nvarchar
(
4000
)
set
@name
=
'
david fan
'
--
Todo: 在此处设置参数值。
EXECUTE
[
TestProject
]
.
[
dbo
]
.
[
TestStoredProcedure
]
@name
,
@outstr
OUTPUT
print
@outstr
结果如下
输出参数返回值
自定义函数
一，TVF
函数
示例
函数的作用是
搜索目录下的某一类型的
文件
using
System;
using
System.Data;
using
System.Data.sql;
using
System.Data.sqlTypes;
using
Microsoft.sqlServer.Server;
using
System.Collections;
using
System.IO;
using
System.Security.Principal;
public
partial
class
UserDefinedFunctions
{
//需要返回一个表时用TVF(streaming table-valued function)
//可以用select from 语句查询这个方法的返回
//TVF需要返回Ienumerable接口,例如:Array，这里返回一个数组
//FillRowMethodName为填充表行的方法
//TableDeFinition为表结构，对应FillRowMethodName方法的参数
[Microsoft.sqlServer.Server.sqlFunction(FillRowMethodName = "BuildRow",
TableDeFinition = "Name nvarchar(32), Length bigint, Modified DateTime")]
public static IEnumerable FileListCs(string directoryName, string pattern)
@H_502_715@
{
FileInfo[] files;
//模拟当前sql安全上下文
WindowsImpersonationContext OriginalContext= sqlContext.WindowsIdentity.Impersonate();
try
{
DirectoryInfo di = new DirectoryInfo(directoryName);
files = di.GetFiles(pattern);
}
finally
{
if (OriginalContext != null)
{
OriginalContext.Undo();
}
}
return files;
}
public static void BuildRow(object Obj,
ref sqlString fileName,
ref sqlInt64 fileLength,
ref sqlDateTime fileModified)
{
if (Obj != null)
{
FileInfo file = (FileInfo)Obj;
fileName = file.Name;
fileLength = file.Length;
fileModified = file.LastWriteTime;
}
else
{
fileName = sqlString.Null;
fileLength = sqlInt64.Null;
fileModified = sqlDateTime.Null;
}
}
}
因为这个
函数对于
sqlserver来讲要访问外部资源，所以需要配置一下项目和
sqlserver2005
项目右键
属性，
数据库,权限级别选
外部
打开
sqlserver2005
查询分析器执行下边语句
TestProject 为我的
数据库名，你的如果不是，当然需要
修改了。
ALTER
DATABASE
TestProject
SET
TRUSTWORTHY
ON
;
成功后，项目右键
部署。
查询分析器中执行
SELECT
*
FROM
[
TestProject
]
.
[
dbo
]
.
[
FileListCs
]
(
'
c:/
'
,
'
*.txt
'
)
结果如下
二，Scalar
函数
这类
函数返回类型如图，像
sqlString这类
sqlserver的scalar类型
下面就是这类
函数的
一个小例子。
using
System;
using
System.Data;
using
System.Data.sqlClient;
using
System.Data.sqlTypes;
using
Microsoft.sqlServer.Server;
public
partial
class
UserDefinedFunctions
{
[Microsoft.sqlServer.Server.sqlFunction]
public static sqlString ScalarFunction()
{
// 在此处放置代码
return new sqlString("Hello");
}
}
;
sqlserver
查询查询分析器中运行如下语句
SELECT
[
TestProject
]
.
[
dbo
]
.
[
ScalarFunction
]
()
结果如下
第二篇完成，谢谢大家指教！
