SQL Server CLR 使用 C# 自定义函数

时间  2019-12-09
标签 sql server clr 使用 c# 自定义 函数 栏目 SQL 繁體版
原文   原文链接

1、简介sql

Microsoft SQL Server 2005以后，实现了对 Microsoft .NET Framework 的公共语言运行时(CLR)的集成。
CLR 集成使得如今可使用 .NET Framework 语言编写代码，从而可以在 SQL Server 上运行，如今就能够经过 C# 来编写 SQL Server 自定义函数、存储过程、触发器等。
我最初的目的是由于在 SQL Server 数据库中遇到数字的十进制与十六进制的互相转换问题，也看过一些方法吧，可是最后我却选择了用 CLR 来作，毕竟在 C# 中两三行代码就能搞定的问题。。。数据库

 

2、配置 SQL Server CLR服务器

开启 CLR：ide

--开启全部服务器配置
sp_configure 'show advanced options', 1; 
RECONFIGURE WITH override 
GO 
--开启 CLR
sp_configure 'clr enabled', 1; 
RECONFIGURE WITH override 
GO

关闭 CLR：函数

--关闭全部服务器配置
sp_configure 'show advanced options', 0; 
RECONFIGURE WITH override 
GO 
--关闭 CLR
sp_configure 'clr enabled', 0; 
RECONFIGURE WITH override 
GO

在后面注册 CLR 程序集时，发生因操做权限问题而致使的失败时，能够尝试执行下面的 SQL 语句，这里我把 SQL 一并贴出来。测试

--权限不够时，设置目标数据库为可信赖的，例如：Test
ALTER DATABASE [Test] SET TRUSTWORTHY ON 

--修改数据库全部者为当前登陆的用户，也能够为其余用户，例如：sa
EXEC sp_changedbowner 'sa'

 

3、CLR Functionui

打开 Visual Studio 新建一个 SQL Server 数据库项目，这里须要注意 .NET Framework 的版本。
由于个人目标数据库为 SQL Server 2008，因此这里我选择的是 .NET Framework 3.5 的版本。
而后添加新建项，选择 SQL CLR C# 用户自定义函数，先从标量函数开始。spa

 

一、标量函数.net

public partial class UserDefinedFunctions
{
    /// <summary>
    /// 10进制转16进制
    /// </summary>
    /// <param name="strNumber"></param>
    /// <returns></returns>
    [Microsoft.SqlServer.Server.SqlFunction(DataAccess = DataAccessKind.Read, IsDeterministic = true, Name = "ConvertToHexadecimal")]
    public static SqlString ConvertToHexadecimal(SqlString strNumber)
    {
        SqlString result = string.Empty;
        string str = strNumber.ToString();
        int number = 0;
        if (int.TryParse(str, out number))
        {
            result = number.ToString("X");
        }
        return result;
    }

    /// <summary>
    /// 16进制转10进制
    /// </summary>
    /// <param name="strNumber"></param>
    /// <returns></returns>
    [Microsoft.SqlServer.Server.SqlFunction(DataAccess = DataAccessKind.Read, IsDeterministic = true, Name = "ConvertToDecimal")]
    public static SqlString ConvertToDecimal(SqlString strNumber)
    {
        SqlString result = string.Empty;
        string str = strNumber.ToString();
        int number = 0;
        try
        {
            number = int.Parse(str, System.Globalization.NumberStyles.HexNumber);
            result = Convert.ToString(number, 10);
        }
        catch
        {
        }
        return result;
    }
}

 

二、表值函数code

public partial class UserDefinedFunctions
{
    /// <summary>
    /// SQL Server 字符串分割方法
    /// </summary>
    /// <param name="separator"></param>
    /// <param name="pendingString"></param>
    /// <returns></returns>
    [Microsoft.SqlServer.Server.SqlFunction(
        DataAccess = DataAccessKind.Read,
        IsDeterministic = true,
        Name = "SqlSplit",
        FillRowMethodName = "SqlSplit_FillRow",
        TableDefinition = "SerialNumber int,StringValue nvarchar(1024)")]
    public static IEnumerable SqlSplit(SqlString separator, SqlString pendingString)
    {
        string _separator = string.Empty;
        string _pendingString = string.Empty;
        if (separator.IsNull)
        {
            _separator = ",";
        }
        else
        {
            _separator = separator.ToString();
            if (string.IsNullOrEmpty(_separator))
            {
                _separator = ",";
            }
        }

        if (pendingString.IsNull)
        {
            return null;
        }
        else
        {
            _pendingString = pendingString.ToString();
            if (string.IsNullOrEmpty(_pendingString))
            {
                return null;
            }
        }

        string[] strs = _pendingString.Split(new string[] { _separator }, StringSplitOptions.RemoveEmptyEntries);
        if (strs.Length <= 0)
        {
            return null;
        }

        List<ResultData> resultDataList = new List<ResultData>();
        for (int i = 0; i < strs.Length; i++)
        {
            resultDataList.Add(new ResultData(i + 1, strs[i]));
        }
        return resultDataList;
    }

    /// <summary>
    /// 填充数据方法
    /// </summary>
    /// <param name="obj"></param>
    /// <param name="serialNumber"></param>
    /// <param name="stringValue"></param>
    public static void SqlSplit_FillRow(Object obj, out SqlInt32 SerialNumber, out SqlString StringValue)
    {
        ResultData resultData = (ResultData)obj;
        SerialNumber = resultData.SerialNumber;
        StringValue = resultData.StringValue;
    }

    /// <summary>
    /// 定义返回类型
    /// </summary>
    public class ResultData
    {
        /// <summary>
        /// 序号，即行号
        /// </summary>
        public SqlInt32 SerialNumber { get; set; }

        /// <summary>
        /// 分割后的每一个子字符串
        /// </summary>
        public SqlString StringValue { get; set; }

        public ResultData(SqlInt32 serialNumber, SqlString stringValue)
        {
            SerialNumber = serialNumber;
            StringValue = stringValue;
        }
    }
}

SqlFunctionAttribute 的属性及介绍：

--属性                    --说明
--DataAccess            --指示该函数是否涉及访问存储在SQL Server的数据
--FillRowMethodName        --在同一个类的方法的名称做为表值函数(TVF)，这个参数在表值函数中才会用到，用于指定表值函数的数据填充方法
--IsDeterministic        --指示用户定义的函数是不是肯定性的
--IsPrecise                --指示函数是否涉及不精确计算，如浮点运算
--Name                    --函数在SQL Server中注册时使用的函数的名称
--SystemDataAccess        --指示该函数是否须要访问存储在系统目录或SQL Server虚拟系统表中的数据
--TableDefinition        --若是方法做为表值函数(TVF)，则为一个字符串，该字符串表示表结构的定义

标量函数与表值函数能够写在同一个类文件里面，而且能够包含多个，可是聚合函数就不行了，如今须要添加一个新项，选择 SQL CLR C# 聚合。

 

三、聚合函数

我这里写的这个聚合函数的做用是把多个字符串拼为一个字符串，我以前还真有遇到这种状况须要的。

[Serializable]
[Microsoft.SqlServer.Server.SqlUserDefinedAggregate(
    Format.UserDefined, 
    IsInvariantToDuplicates = false, 
    IsInvariantToNulls = true, 
    IsInvariantToOrder = false, 
    MaxByteSize = 8000, 
    Name = "SumString")]
public struct UserDefinedSqlAggregate : IBinarySerialize
{
    private StringBuilder stringBuilder;

    /// <summary>
    /// 查询处理器使用此方法初始化聚合的计算
    /// </summary>
    public void Init()
    {
        stringBuilder = new StringBuilder();
    }

    /// <summary>
    /// 查询处理器使用此方法累计聚合值
    /// </summary>
    /// <param name="Value"></param>
    public void Accumulate(SqlString Value)
    {
        stringBuilder.Append(string.Format("{0},", Value));
    }

    /// <summary>
    /// 查询处理器使用此方法合并聚合的多个部分计算的值
    /// </summary>
    /// <param name="Group"></param>
    public void Merge(UserDefinedSqlAggregate Group)
    {
        stringBuilder.Append(Group.stringBuilder);
    }

    /// <summary>
    /// 此方法用于返回完成聚合计算的结果
    /// </summary>
    /// <returns></returns>
    public SqlString Terminate()
    {
        return new SqlString(stringBuilder.ToString());
    }

    #region Implement interface IBinarySerialize
    /// <summary>
    /// 读
    /// </summary>
    /// <param name="r"></param>
    public void Read(System.IO.BinaryReader r)
    {
        stringBuilder = new StringBuilder(r.ReadString());
    }

    /// <summary>
    /// 写
    /// </summary>
    /// <param name="w"></param>
    public void Write(System.IO.BinaryWriter w)
    {
        w.Write(stringBuilder.ToString());
    }
    #endregion
}

SqlUserDefinedAggregateAttribute 的属性及介绍：

--属性                        --说明
--Format                    --选择序列化的 Format 格式，默认选择 Native，表示使用本地序列化格式。若是选择 UserDefined，则聚合类须要实现 IBinarySerialize 接口
--IsInvariantToDuplicates    --指示聚合是否与重复的值相计算保持不变
--IsInvariantToNulls        --指示聚合是否与空值相计算保持不变
--IsInvariantToOrder        --指示聚合最后计算的结果是否与顺序无关
--IsNullIfEmpty                --指示在没有对任何值进行累计时，聚合返回值是否为 null 
--MaxByteSize                 --聚合实例的最大大小(以字节为单位)
--Name                        --聚合函数的名称

而后生成项目，接下来注册程序集和注册函数就可使用了。

 

四、注册 CLR 程序集

注册程序集的方式有如下两种：

第一种，这种方式注册程序集比较简单，可是缺点就是程序集不能移动或删除。

--注册CLR程序集方式一，指定程序集DLL的路径
USE Test 
GO 
CREATE ASSEMBLY UserDefinedClrAssembly 
--AUTHORIZATION sa        --指定数据库全部者，默认为当前用户
FROM 'C:\Users\Administrator\Desktop\CLR Assembly\UserDefinedSqlClr.dll'        --指定文件路径
WITH PERMISSION_SET = UNSAFE;        --指定程序集的权限
                                --SAFE：没法访问外部系统资源；
                                --EXTERNAL_ACCESS：能够访问某些外部系统资源；
                                --UNSAFE：能够不受限制的访问外部系统资源
GO

这里若是发生由于程序集拒绝访问的错误，那就把计算机用户 Everyone 的权限改成彻底控制就能够了。

第二种，这种方式注册程序集稍微复杂一些，可是好处就是注册成功以后，能够移动甚至删除DLL文件，只要不是变动迁移数据库，都不用从新注册。

--注册CLR程序集方式二，指定程序集DLL的16进制文件流
USE Test 
GO 
CREATE ASSEMBLY UserDefinedClrAssembly 
--AUTHORIZATION sa        --指定数据库全部者，默认为当前用户
FROM 0x4D5A90000300000004000000FFFF0000B8000000000000004000000000    --指定DLL的16进制文件流(固然没这么少，我删掉了)
WITH PERMISSION_SET = UNSAFE;        --指定程序集的权限
                                --SAFE：没法访问外部系统资源；
                                --EXTERNAL_ACCESS：能够访问某些外部系统资源；
                                --UNSAFE：能够不受限制的访问外部系统资源
GO

获取DLL的16进制文件流，可使用 UltraEdit 这个软件，具体操做方法这里就很少说了。

注册成功以后，可使用下面的 SQL 语句查看程序集的信息，还包括查询自定义的函数、存储过程等的SQL语句，这个下面注册函数以后能够用到。

--查看程序集信息
SELECT * FROM sys.assemblies 

--查看模块信息，即自定义函数、视图、存储过程、触发器等等
SELECT * FROM sys.sql_modules
GO

 

五、注册函数

下面是三种函数的注册方式的 SQL 语句。

USE Test 
GO 

--注册标量函数 ConvertToHexadecimal 
CREATE FUNCTION [dbo].[ConvertToHexadecimal](@strNumber NVARCHAR(128))
RETURNS NVARCHAR(128) 
WITH EXECUTE AS CALLER        --用于在用户在执行函数的时候对引用的对象进行权限检查
AS 
EXTERNAL NAME [UserDefinedClrAssembly].[UserDefinedFunctions].[ConvertToHexadecimal]    --EXTERNAL NAME 程序集名.类名.方法名
GO 

--注册标量函数 ConvertToDecimal 
CREATE FUNCTION [dbo].[ConvertToDecimal](@strNumber NVARCHAR(128))
RETURNS NVARCHAR(128) 
WITH EXECUTE AS CALLER        --用于在用户在执行函数的时候对引用的对象进行权限检查
AS 
EXTERNAL NAME [UserDefinedClrAssembly].[UserDefinedFunctions].[ConvertToDecimal]    --EXTERNAL NAME 程序集名.类名.方法名
GO 

--注册表值函数 SqlSplit 
CREATE FUNCTION [dbo].[SqlSplit](@separator NVARCHAR(32),@string NVARCHAR(MAX))
RETURNS TABLE 
(
    SerialNumber INT,
    StringValue NVARCHAR(1024)
)
WITH EXECUTE AS CALLER        --用于在用户在执行函数的时候对引用的对象进行权限检查
AS 
EXTERNAL NAME [UserDefinedClrAssembly].[UserDefinedFunctions].[SqlSplit]    --EXTERNAL NAME 程序集名.类名.方法名
GO 

--注册聚合函数 SumString 
CREATE AGGREGATE [dbo].[SumString](@params NVARCHAR(128))
RETURNS NVARCHAR(MAX) 
EXTERNAL NAME [UserDefinedClrAssembly].[UserDefinedSqlAggregate]    --EXTERNAL NAME 程序集名.类名
GO

注册函数成功以后，接下来测试一下。

DECLARE @TempTable TABLE
(
    Id INT NOT NULL,
    Name NVARCHAR(32) NOT NULL 
)
INSERT INTO @TempTable (
    Id,
    [Name]
)
SELECT '1','小张' UNION ALL 
SELECT '2','小明' UNION ALL 
SELECT '2','小丽' UNION ALL 
SELECT '2','小李' UNION ALL 
SELECT '3','小王' UNION ALL 
SELECT '3','小舞' 

SELECT dbo.ConvertToHexadecimal('15')

SELECT dbo.ConvertToDecimal('FC')

SELECT * FROM SqlSplit(',',',123,456,789,')

SELECT Id,dbo.SumString([Name]) Names 
FROM @TempTable 
GROUP BY Id

结果如图。

 

下面是删除函数和删除程序集的 SQL 语句，虽然可能用不到，可是仍是贴出来吧。

这里须要注意的是，删除程序集时要保证不存在函数、存储过程、触发器等对程序集的引用。

--删除标量函数 ConvertToHexadecimal 
DROP FUNCTION dbo.ConvertToHexadecimal

--删除标量函数 ConvertToDecimal 
DROP FUNCTION dbo.ConvertToDecimal

--删除表值函数 SqlSplit 
DROP FUNCTION dbo.SqlSplit

--删除聚合函数 SumString 
DROP FUNCTION dbo.SumString

--删除程序集 UserDefinedClrAssembly 
DROP ASSEMBLY UserDefinedClrAssembly

 

本想一篇写完的，仍是算了，存储过程和触发器留待下一篇。

其实存储过程和触发器也没什么了，只是 C# 代码不同而已，其余注册之类的大同小异。

 

这里推荐一篇博客，你们也能够去看这篇，写得仍是挺完整的，有些地方都是借鉴于此。

http://blog.csdn.net/tjvictor/article/details/4726933

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程