用C# 开发SQL Server 2005的自定义聚合函数

我们想得到

[Serializable]
[Microsoft.SqlServer.Server.SqlUserDefinedAggregate(Format.UserDefined,
IsInvariantToDuplicates=false,
IsInvariantToNulls=true,
IsInvariantToOrder=false,
IsNullIfEmpty=true,
MaxByteSize=8000
)]
public struct StrJoin: IBinarySerialize {
private StringBuilder _result;

public void Init() {
_result = new StringBuilder();
}

public void Accumulate(SqlString Value) {
if (Value.IsNull) {
return;
} else {
if (_result.Length > 0)
_result.Append(",");
_result.Append(Value.Value);
}
}

public void Merge(StrJoin Group) {
_result.Append(Group._result);
}

public SqlString Terminate() {
if (_result.Length > 0) {
return new SqlString(_result.ToString());
}
return new SqlString("");
}

#region IBinarySerialize Members

public void Read(System.IO.BinaryReader r) {
_result = new StringBuilder(r.ReadString());
}

public void Write(System.IO.BinaryWriter w) {
w.Write(_result.ToString());
}

#endregion
}

这里不叙述具体的操作步骤，网上应该可以搜到很多。
其原理是该类中提供了几个模版方法：Init(), Accumulate(), Merge(), Terminate().
我们需要做的是在其中写自己的聚合逻辑即可。这几个方法的含义分别是初始化，扫描到一条记录时，合并，终止扫描。

需要注重以下几点：

1. 自定义聚集函数中，我们返回的数据会被序列化然后转换到 SQL Server 中，对一些数值类型 Framework 提供了默认的序列化机制，但其他一些 CLR 的类型比如 string 就必须自己实现序列化机制，也就是实现 IBinarySerialize 接口。
共2页: 上一页 1 [2] 下一页