SQL Server2005杂谈(2):按列连接字符串的三种方法

本文为原创,如需转载,请注明作者和出处,谢谢!

最近做一个项目,遇到一个在分组的情况下,将某一列的字段值(varchar类型)连接起来的问题,类似于sum函数对int型字段值求和。 如有一个表t_table,结构和数据如图1

                                          图1

    其中要按着xh字段分组,并且将每一组name字段值连接起来。最终结果希望如图2所示

             图2

表中的th字段值对于每一个xh值是唯一的,也是有限的,也就是说,对于一个xh值,th的值不会太多,如最多是10个(从1至10)。

以上需求最终想了三种方法来解决这个问题。

一、修改表结构

如果是新的项目,可以考虑修改一下表的结构。如果t_table的结构修改如下:

    xh     value1 value2  
value3    value4     .... ....                 value10
   0001 123456 654321 456789 
   0002 12abcd 4d2r343 343dfd
   0003 abcde3 132323

这种方法将value的值纵向改为横向,也就是说,按每一个xh值,将value字段的值按逆时针旋转了90度。 但这种方法要有一个前提,就是假设xh的每一个值所对应的value值不会太多,如上面不超过10个,这样才有可能建立有限个字段。如果按着上面的字段结构,只需要将这些字段加一起就可以了,也不用分组。如下所示:

select xh , (value1 + value2 + value3 +  + value10) as value from t_table

但这种方法至少有如下三个缺陷:

1. 需要修改表结构,这对于已经进行很长时间或是已经上线的项目产不适用

2. 对每一个xh字段的value取值数有限制,如果太多,就得建立很多字段。这样性能会降低。

3. 这样做虽然查询容易,但如果需要对每一个xh的不同值频繁修改或加入新的值时,如果把它们都放到一行,容易因为行锁而降低性能。

二、动态生成select语句

    让我们先看三条SQL语句:

select xh,value as th1 from t_table where th=1 
select xh,value as th2 from t_table where th=2
select xh,value as th3 from t_table where th=3

这三条语句分别使用th字段按着所有th可能的值来查询t_table,这三条SQL语句所查询出来的记录如图3所示。

                        图 3

    然后再使用下面的语句按着xh分组:

    select xh from t_table group by xh

得到的结果如图4所示。

       图4

然后使用left join,以图4所示的表为最左边的表,进行连接,SQL语句如下:

select a.xh, b.th1, c.th2, d.th3 from
(select xh from t_table group by xh) a 
left join 
(select xh,value as th1 from t_table where th=1) b on a.xh=b.xh 
left join 
(select xh,value as th2 from t_table where th=2) c on a.xh=c.xh 
left join 
(select xh,value as th3 from t_table where th=3) d on a.xh=d.xh

    之所以使用left join,是因为按着th查询后,有的表的某些xh值可以没有,如图3中的第三个表,就没有0003。如果使用内连接,0003就无法在记录集中体现。这面的SQL的查询结果如图5所示。

              图5

    然后我们就可以使用如下的语句来连接th1、th2和th3了。 

select xh, (th1+th2+th3) as th from myview

myview表示将上面用left join的语句保存成的视图。

下面可以将这个过程写成一条SQL语句:

select xh, (th1+th2+th3) as th from 
(
select a.xh,  (case when b.th1 is null then '' else b.th1 end) as th1,
 (case when c.th2 is null then '' else c.th2 end) as th2,
 (case when d.th3 is null then '' else d.th3 end) as th3 
from
(select xh from t_table group by xh) a  
left join 
(select xh,value as th1 from t_table where th=1) b on a.xh=b.xh 
left join 
(select xh,value as th2 from t_table where th=2) c on a.xh=c.xh 
left join
(select xh,value as th3 from t_table where th=3) d on a.xh=d.xh
) x

 

    由于null加上任何字符串都为null,因此,使用case语句来将null转换为空串。上面的SQL就会得到图2所示的查询结果。也许有的读者会问,如果th的可能取值可变呢!如xh为0001的th值四个:1至4。
那上面的SQL不是要再加一个left join吗?这样不是很不通用。 要解决这个问题也很容易。可以使用程序(如C#、Java等)自动生成上述的SQL,然后由程序提交给数据库,再执行。 当然,这需要程序事先知道th值对于当前程序最多有几个值,然后才可以自动生成上述的SQL语句。

这种方法几乎适合于所有的数据库,不过如果th的取值比较多的话,可能SQL语句会很长,但是如果用程序自动生成的话,就不会管这些了。

三、使用C#实现SQL Server2005的扩展聚合函数(当然,也可以用VB.NET)

    这一种方法笔者认为是最“酷”的方法。因为每一个人都只想写如下的SQL语句就可以达到目录。

select xh, dbo.joinstr(value) from t_table group by xh

 

其中joinstr是一个聚合函数,功能是将每一组的某个字符串列的值首尾连接。上面的SQL也可以查询图2所示的结果。但遗憾的是,sql server2005并未提供可以连接字符串的聚合函数。下面我们就来使用C#来实现一个扩展聚合函数。

    
首先用VS2008/VS2005建立一个SQL Server项目,如图6所示。

                                                                    图6

    点击“确定”按钮后,SQL Server项目会要求连接一个数据库,我们可以选择一个数据库,如图7所示。

                                       图7

    然后在工程中加入一个聚合类(joinstr.cs),如图8所示。

                                                                                      图8
    joinstr.cs中的最终代码如下:

using System;
using System.Data;
using Microsoft.SqlServer.Server;
using System.Data.SqlTypes;
using System.IO;
using System.Text;

[Serializable]
[SqlUserDefinedAggregate(
    Format.UserDefined, //use custom serialization to serialize the intermediate result
    IsInvariantToNulls = true, //optimizer property
    IsInvariantToDuplicates = false, //optimizer property
    IsInvariantToOrder = false, //optimizer property    
    MaxByteSize = 8000) //maximum size in bytes of persisted value
]

public struct joinstr :IBinarySerialize
{
    private System.Text.StringBuilder intermediateResult;
    
    public void Init()
    {
        // 在此处放置代码
        intermediateResult = new System.Text.StringBuilder();
    }

    public void Accumulate(SqlString Value)
    {
        intermediateResult.Append(Value.Value);
    }

    public void Merge(joinstr Group)
    {
        intermediateResult.Append(Group.intermediateResult);
    }

    public SqlString Terminate()
    {
        return new SqlString(intermediateResult.ToString());
    }

    public void Read(BinaryReader r)
    {
        intermediateResult = new StringBuilder(r.ReadString());
    }

    public void Write(BinaryWriter w)
    {
        w.Write(this.intermediateResult.ToString());
    }
}

由于本例需要聚合字符串,而不是已经被序列化的类型,如int等,因此,需要实现IBinarySerialize接口来手动序列化。使用C#实现SQL Server聚合函数,也会受到字符串最大长度为8000的限制。

    
在编写完上述代码后,可以使用Visual Studio来部署(右向工程,在弹出菜单上选“部署”即可)。也可以使用SQL语句来部署。假设上面的程序生成的dll为MyAggregate.dll,可以使用下面的SQL语句来部署:

CREATE ASSEMBLY MyAgg FROM 'D:/test/MyAggregate.dll'

CREATE AGGREGATE joinstr (@input nvarchar(200)) RETURNS nvarchar(max)
EXTERNAL NAME MyAgg.joinstr

    要注意的是,字符串类型需要用nvarchar,而不能用varchar。

第一条SQL语句是装载dll,第二条SQL语句是注册joinstr聚合函数(每一个C#类就是一个聚合函数)

在执行上面的SQL语句之前,需要将SQL Server2005的clr功能打开。如图9所示。

                                               图9

    如果想删除上面建立的聚合函数,可以使用如下的SQL语句:

drop aggregate joinstr

在删除聚合函数后,可以将MyAggregate.dll卸载。

drop assembly MyAgg

OK,现在可以使用joinstr来聚合字符串了。

    这种方法虽然显示很“酷”,但却要求开发人员熟悉扩展聚合函数的开发方法,如果开发人员使有的不是微软的开发工具,如使用Java,恐怕这种方法就只能是空谈了(除非开发小组内有人会用微软的开发工具)。

当然,如果使用其他的数据库,如oracle、mysql,也是可以实现类似扩展函数的功能的,如oracle可以使用java来进行扩展。但这要求开发人员具有更高的素质。
    以上介绍的三种方法仅供参考,至于采用哪种方法,可根据实际需要和具体情况而定。如果哪位读者有更好的方法,请跟贴!

时间: 2024-09-08 05:15:13

SQL Server2005杂谈(2):按列连接字符串的三种方法的相关文章

SQL Server2005杂谈(4):在SQL Server2005中按列连接字符串的三种方法

本文为原创,如需转载,请注明作者和出处,谢谢! 上一篇:SQL Server2005杂谈(3):四个排名函数(row_number.rank.dense_rank和ntile)的比较 最近做一个项目,遇到一个在分组的情况下,将某一列的字段值(varchar类型)连接起来的问题,类似于sum函数对int型字段值求和. 如有一个表t_table,结构和数据如图1                                           图1     其中要按着xh字段分组,并且将每一组na

动态改变EnterpriseLibary数据库访问链接字符串的三种方法

使用EnterpriseLibary做数据库访问底层是我一贯的做法,除了其能兼容多种数据库,且使用其进行数据库访问,对各种数据库操作均是透明的,基本不需要对特定的数据库进行操作,编写一次操作代码,基本在各种数据库都适用.对于一些特殊的数据库,很多同行已经编写出各种各样的扩展类库,直接适用即可. 言归正传,动态改变EnterpriseLibary数据库访问链接字符串一般在使用Access数据库.Sqlite数据库等文件式的数据库比较常见,因为我们不知道客户会把程序拷贝到哪里进行使用(即使是做了安装

详解JDBC连接Access的三种方法

JDBC连接Access第一种方法: 你用下面的代码试试 (强烈建议也是only可以建议的方法) con = DriverManager.getConnection("jdbc:odbc:Driver={MicroSoft Access Driver (*.mdb)};DBQ=C:/data/Access/test1.mdb","dba","sql"); 后面的代码一样.这样你就可以访问access数据库了. JDBC连接Access第二种方法:

C#判断空字符串的三种方法

3种方法分别是: string a=""; 1.if(a=="") 2.if(a==String.Empty) 3.if(a.Length==0) 3种方法都是等效的,那么究竟那一种方法性能最高呢?本人用实验说明问题. 建立3个aspx页面(为什么用网页,主要是利用Microsoft Application Center Test ) WebForm1.aspx private void Page_Load(object sender, System.EventAr

再谈DOS批处理下格式化日期字符串的三种方法(详解)_DOS/BAT

谈到日期字符串的输出,真是让人烦. 在Linux下,简单的一句话:date '+%Y%m%d-%H%M%S'就可以得到你要的输出:20120331-064219 可是在windows下,要想得到这个,还是需要费点功夫的. 1. 直接用字符串格式化输出 比如,如果你的机器上时间的输出是这样子的: c:\>echo %date%-%time% 2012-03-31 星期六- 6:44:02.50 那么,要想得到输出20120331- 64402,可以这样截取字符串: c:\>echo %date:

C++中访问字符串的三种方法总结_C 语言

1.用字符数组存放一个字符串 程序1:定义一个字符数组并初始化,然后输出其中的字符串. 复制代码 代码如下: #include<iostream>using namespace std;int main(){ char str[]="I lvoe China!"; cout<<str<<endl; return 0;} 输出结果: 复制代码 代码如下: I love China! str是字符数组名,它代表数组首元素的地址,输出str的时候,从str

asp DataTable添加列和行的三种方法_实用技巧

复制代码 代码如下: #region 方法一: DataTable tblDatas = new DataTable("Datas"); DataColumn dc = null; dc = tblDatas.Columns.Add("ID", Type.GetType("System.Int32")); dc.AutoIncrement = true;//自动增加 dc.AutoIncrementSeed = 1;//起始为1 dc.AutoI

ASP.NET中把对象序列化成JSON字符串的三种方法

//方法1 //using System.Runtime.Serialization.Json; //using System.IO; //using System.Text; //using System.Text.RegularExpressions; DataContractJsonSerializer jsonSerializer = new DataContractJsonSerializer(arr.GetType()); MemoryStream ms = new MemorySt

JS去除重复的字符串内容三种方法

例1  代码如下 复制代码 String.prototype.repeatOpt = function () {    var str = this + "",objStr = "";    for (var i = 0; i < this.length; i++) {        var s = str[i];        var newStr = str.replace(s, '');        var j = newStr.indexOf(s);