如何解决CLR表值函数如何“流化”?
我假设您使用的是sql Server2008。正如Microsoft员工在此页上所提到的,2008要求用DataAccessKind标记方法。读取的频率比2005年要高得多。其中之一是当TVF参与事务时(当我进行测试时,情况似乎总是如此)。解决方案是enlist=false
在连接字符串中指定,但不能与结合使用context connection=true
。这意味着您的连接字符串必须采用典型的客户端格式:Data Source=.;Initial Catalog=MyDb;Integrated Security=sspi;Enlist=false
并且您的程序集必须permission_set=external_access
至少使用来创建。以下作品:
using System;
using System.Collections;
using System.Data.sqlClient;
using System.Data.sqlTypes;
using Microsoft.sqlServer.Server;
namespace sqlClrTest {
public static class Test {
[sqlFunction(
DataAccess = DataAccessKind.Read,
SystemDataAccess = SystemDataAccessKind.Read,
TableDeFinition = "RowNumber int",
FillRowMethodName = "FillRow"
)]
public static IEnumerable MyTest(sqlInt32 databaseID) {
using (var con = new sqlConnection("data source=.;initial catalog=TEST;integrated security=sspi;enlist=false")) {
con.open();
using (var cmd = new sqlCommand("select top (100) RowNumber from ssp1 where DatabaseID = @DatabaseID", con)) {
cmd.Parameters.AddWithValue("@DatabaseID", databaseID.IsNull ? (object)dbnull.Value : databaseID.Value);
using (var reader = cmd.ExecuteReader()) {
while (reader.Read())
yield return reader.GetInt32(0);
}
}
}
}
public static void FillRow(object obj, out sqlInt32 rowNumber) {
rowNumber = (int)obj;
}
}
}
这是F#中的同一件事:
namespace sqlClrTest
module Test =
open System
open System.Data
open System.Data.sqlClient
open System.Data.sqlTypes
open Microsoft.sqlServer.Server
[<sqlFunction(
DataAccess = DataAccessKind.Read,
SystemDataAccess = SystemDataAccessKind.Read,
TableDeFinition = "RowNumber int",
FillRowMethodName = "FillRow"
)>]
let MyTest (databaseID:sqlInt32) =
seq {
use con = new sqlConnection("data source=.;initial catalog=TEST;integrated security=sspi;enlist=false")
con.open()
use cmd = new sqlCommand("select top (100) RowNumber from ssp1 where DatabaseID = @DatabaseID", con)
cmd.Parameters.AddWithValue("@DatabaseID", if databaseID.IsNull then Box dbnull.Value else Box databaseID.Value) |> ignore
use reader = cmd.ExecuteReader()
while reader.Read() do
yield reader.GetInt32(0)
} :> System.Collections.IEnumerable
let FillRow (obj:obj) (rowNumber:sqlInt32 byref) =
rowNumber <- sqlInt32(unBox obj)
解决方法
表值Sql Clr函数上的MSDN文档指出:
Transact-SQL表值函数实现了将该函数调用到中间表中的结果。…相比之下,CLR表值函数代表流式传输的替代方案。无需在单个表中实现整个结果集。由托管函数返回的IEnumerable对象由调用表值函数的查询的执行计划直接调用,并且结果以增量方式使用。…如果您返回的行数非常大,这也是一个更好的选择,因为不必将它们作为整体存储在内存中。
然后,我发现“填充行”方法中不允许数据访问。这意味着您仍然必须在init方法中进行所有数据访问并将其保存在内存中,等待调用“填充行”。我误会了吗?如果不将结果强行放入数组或列表中,则会收到错误消息:“ ExecuteReader需要打开且可用的Connection。连接的当前状态为关闭。”
代码示例:
[<SqlFunction(DataAccess = DataAccessKind.Read,FillRowMethodName = "Example8Row")>]
static member InitExample8() : System.Collections.IEnumerable =
let c = cn() // opens a context connection
// I'd like to avoid forcing enumeration here:
let data = getData c |> Array.ofSeq
data :> System.Collections.IEnumerable
static member Example8Row ((obj : Object),(ssn: SqlChars byref)) =
do ssn <- new SqlChars(new SqlString(obj :?> string))
()
我在这里处理几百万行。有什么办法可以偷懒地做到这一点吗?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。