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教程