SQL SERVER 2008中用C#定义压缩与解压缩函数-阿里云开发者社区

开发者社区> 数据库> 正文

SQL SERVER 2008中用C#定义压缩与解压缩函数

简介: 下面用C#2010定义一个函数,供SQL SERVER 2008使用: 下面是压缩函数 1 using System.Data.SqlClient; 2 using System.Data.

下面用C#2010定义一个函数,供SQL SERVER 2008使用:

下面是压缩函数

 1 using System.Data.SqlClient;
 2 using System.Data.SqlTypes;
 3 using Microsoft.SqlServer.Server;
 4 using System.Collections;
 5 
 6 public partial class UserDefinedFunctions
 7 {
 8     [Microsoft.SqlServer.Server.SqlFunction(
 9         DataAccess=DataAccessKind.Read,
10         FillRowMethodName="GetNextDepartment",
11         TableDefinition="Name nvarchar(50),GroupName nvarchar(50)")]
12     public static IEnumerable GetDepartments()
13     {
14         // 在此处放置代码
15         using (SqlConnection conn = new SqlConnection("context connection=true"))
16         {
17             string sql = "Select Name,GroupName From HumanResources.Department";
18             conn.Open();
19             SqlCommand comm = new SqlCommand(sql, conn);
20             SqlDataAdapter adaptor = new SqlDataAdapter(comm);
21             DataSet dSet = new DataSet();
22             adaptor.Fill(dSet);
23             return (dSet.Tables[0].Rows);
24         }
25     }
26 
27     public static void GetNextDepartment(object row,
28         out string name,
29         out string groupName)
30     {
31         DataRow theRow = (DataRow)row;
32         name=(string)theRow["Name"];
33         groupName=(string)theRow["GroupName"];
34     }
35 };


解压函数:

 1 using System;
 2 using System.Data;
 3 using System.Data.SqlClient;
 4 using System.Data.SqlTypes;
 5 using System.IO;
 6 using System.IO.Compression;
 7 using Microsoft.SqlServer.Server;
 8 
 9 public partial class UserDefinedFunctions
10 {
11     [Microsoft.SqlServer.Server.SqlFunction]
12     public static SqlBytes BinaryDecompress(SqlBytes inputBinary)
13     {
14         // 在此处放置代码
15         byte[] inputBytes = (byte[])inputBinary.Value;
16 
17         using (MemoryStream memStreamIn = new MemoryStream(inputBytes))
18         {
19             using (GZipStream s = new GZipStream(memStreamIn, CompressionMode.Decompress))
20             {
21                 using (MemoryStream memStreamOut = new MemoryStream())
22                 {
23                     for (int num = s.ReadByte(); num != -1; num = s.ReadByte())
24                     {
25                         memStreamOut.WriteByte((byte)num);
26                     }
27                     return (new SqlBytes(memStreamOut.ToArray()));
28                 }
29             }
30         }
31     }
32 };

 

 

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
数据库
使用钉钉扫一扫加入圈子
+ 订阅

分享数据库前沿,解构实战干货,推动数据库技术变革

其他文章