sqlserver 巧妙的自关联运用
更新时间：2012年07月17日 21:36:21 作者：
最近在改报表分页，遇到一个很棘手的问题，需要将比较正常的数据记录新增加两列
第一列按照goodsid局部分组，然后在分组后的记录中按照audittime升序排序得到序号，从而显示某商品得第几次变迁。
第二列是取该商品的最后变迁价格newPrice，然后将该值赋到这个商品的其他行中，例如对于goodsid为1的，最后一个newprice为20，那么对于所有goodsid为1的记录curprice都写为20，从而达到外面控件分布的效果。
如下，比较正常的数据记录：
private void ChangeDataTable(DataTable dt)
{
dt.Columns.Add("curprice");
dt.Columns.Add("expandfield");
int goodsid = 0;
int index = 1; //指针
decimal curprice = 0;
IHashObject curpriceobj = new HashObject(); //键值对
//增加分布列
foreach(DataRow row in dt.Rows){
if (goodsid != Convert.ToInt32(row["goodsid"])) {
curpriceobj.Add("goodsid_"+goodsid, curprice);
//处理
index = 0;
goodsid = Convert.ToInt32(row["goodsid"]);
}
curprice = Convert.ToDecimal(row["newprice"]);
index += 1;
row["expandfield"] = "第" + index + "次变迁";
}
if(dt.Rows.Count != 0){ //添加最后一个商品的现行价
curpriceobj.Add("goodsid_"+goodsid, curprice);
}
//增加现行价
foreach (DataRow row in dt.Rows) {
row["curprice"] = curpriceobj["goodsid_" + row["goodsid"]];
}
}
但现在报表存储过程必须分页，分页后还要支持排序，如果客户端要求按照最新价格newPrice排序，很明显这样通过服务端转换的数据源是没办法支持的（因为在数据库分页前的数据源并没有newPrice这个字段）。
另外在C#服务端处理，其实是比较占内存的，其一对DataTable遍历了两次，另外还用了临时键值对对象，反复赋值是有性能消耗。
综上所述，最终我选择放在数据库来构建这两列。
关于第一列局部排序，我很快想到了一个以前看过的语法 ROW_NUMBER() OVER(PARTITION BY...ORDER BY)，于是第一列expandfield很容易就构建了，SQL如下：
SELECT '第' + CAST(ROW_NUMBER() OVER(PARTITION BY GoodsId ORDER BY audittime DESC) AS VARCHAR(10)) + '次变迁' AS expandfield,
GoodsId, price , discount , newPrice , begindate as [date]
FROM #test
但真正麻烦的是第二列，我抠破脑壳来想都没想出来，甚至想到用临时表来记录这个结果集，然后用游标来遍历结果集，update这个表来修改记录，但还是感觉相当的繁琐，而且性能很差。后来我请教了下公司的DBA，她给出了一种思路，这种方案无论从效率还是可行性都是最优的。先贴出代码如下：
WITH _TEMP AS (
SELECT ROW_NUMBER() OVER ( PARTITION BY GoodsId ORDER BY audittime DESC ) AS num2 ,
ROW_NUMBER() OVER ( PARTITION BY GoodsId ORDER BY audittime ) AS num ,
GoodsId, price , discount , newPrice , begindate as [date]
FROM #test
)
SELECT '第' + CAST(a.num AS VARCHAR(10)) + '次变迁' AS expandfield ,
a.goodsid , a.price , a.discount , a.newprice , a.date , b.newprice AS curprice
FROM _TEMP a
INNER JOIN _TEMP b ON a.GoodsId = b.GoodsId AND b.num2 = 1
这里用了一个CTE表达式的自关联查询，从性能上说是很有优势的，相对于临时表减少了对tempdb的开销，另外代码的可读性也比嵌套查询更强，num列是用来构建第几次变迁列的，这里很巧妙得多加了按照audittime降序列的num2列，在下面临时记录b中，通过指定b.num2 = 1取得所有goodsid最后变价的记录，再通过一个INNER JOIN就得到了我们想要的值curprice值。
另外补充一下，像上面存在多个列上排序字段时，SQL会选择后者进行重排，即先按goodsid分组，然后再各个组中按audittime升序排列，如果将num放在前，num2放在后，是得不到我们要的记录。
第二列是取该商品的最后变迁价格newPrice，然后将该值赋到这个商品的其他行中，例如对于goodsid为1的，最后一个newprice为20，那么对于所有goodsid为1的记录curprice都写为20，从而达到外面控件分布的效果。
如下，比较正常的数据记录：
复制代码 代码如下:
private void ChangeDataTable(DataTable dt)
{
dt.Columns.Add("curprice");
dt.Columns.Add("expandfield");
int goodsid = 0;
int index = 1; //指针
decimal curprice = 0;
IHashObject curpriceobj = new HashObject(); //键值对
//增加分布列
foreach(DataRow row in dt.Rows){
if (goodsid != Convert.ToInt32(row["goodsid"])) {
curpriceobj.Add("goodsid_"+goodsid, curprice);
//处理
index = 0;
goodsid = Convert.ToInt32(row["goodsid"]);
}
curprice = Convert.ToDecimal(row["newprice"]);
index += 1;
row["expandfield"] = "第" + index + "次变迁";
}
if(dt.Rows.Count != 0){ //添加最后一个商品的现行价
curpriceobj.Add("goodsid_"+goodsid, curprice);
}
//增加现行价
foreach (DataRow row in dt.Rows) {
row["curprice"] = curpriceobj["goodsid_" + row["goodsid"]];
}
}
但现在报表存储过程必须分页，分页后还要支持排序，如果客户端要求按照最新价格newPrice排序，很明显这样通过服务端转换的数据源是没办法支持的（因为在数据库分页前的数据源并没有newPrice这个字段）。
另外在C#服务端处理，其实是比较占内存的，其一对DataTable遍历了两次，另外还用了临时键值对对象，反复赋值是有性能消耗。
综上所述，最终我选择放在数据库来构建这两列。
关于第一列局部排序，我很快想到了一个以前看过的语法 ROW_NUMBER() OVER(PARTITION BY...ORDER BY)，于是第一列expandfield很容易就构建了，SQL如下：
复制代码 代码如下:
SELECT '第' + CAST(ROW_NUMBER() OVER(PARTITION BY GoodsId ORDER BY audittime DESC) AS VARCHAR(10)) + '次变迁' AS expandfield,
GoodsId, price , discount , newPrice , begindate as [date]
FROM #test
但真正麻烦的是第二列，我抠破脑壳来想都没想出来，甚至想到用临时表来记录这个结果集，然后用游标来遍历结果集，update这个表来修改记录，但还是感觉相当的繁琐，而且性能很差。后来我请教了下公司的DBA，她给出了一种思路，这种方案无论从效率还是可行性都是最优的。先贴出代码如下：
复制代码 代码如下:
WITH _TEMP AS (
SELECT ROW_NUMBER() OVER ( PARTITION BY GoodsId ORDER BY audittime DESC ) AS num2 ,
ROW_NUMBER() OVER ( PARTITION BY GoodsId ORDER BY audittime ) AS num ,
GoodsId, price , discount , newPrice , begindate as [date]
FROM #test
)
SELECT '第' + CAST(a.num AS VARCHAR(10)) + '次变迁' AS expandfield ,
a.goodsid , a.price , a.discount , a.newprice , a.date , b.newprice AS curprice
FROM _TEMP a
INNER JOIN _TEMP b ON a.GoodsId = b.GoodsId AND b.num2 = 1
这里用了一个CTE表达式的自关联查询，从性能上说是很有优势的，相对于临时表减少了对tempdb的开销，另外代码的可读性也比嵌套查询更强，num列是用来构建第几次变迁列的，这里很巧妙得多加了按照audittime降序列的num2列，在下面临时记录b中，通过指定b.num2 = 1取得所有goodsid最后变价的记录，再通过一个INNER JOIN就得到了我们想要的值curprice值。
另外补充一下，像上面存在多个列上排序字段时，SQL会选择后者进行重排，即先按goodsid分组，然后再各个组中按audittime升序排列，如果将num放在前，num2放在后，是得不到我们要的记录。
相关文章
这篇文章主要介绍了sql server Bulk Insert命令详细 ,需要的朋友可以参考下2015-08-08
win2008 r2 安装sql server 2005/2008 无法连接服务器解决方法
在与 SQL Server 建立连接时出现与网络相关的或特定于实例的错误。未找到或无法访问服务器。请验证实例名称是否正确并且 SQL Server 已配置为允许远程连接2015-01-01
得到执行计划的方式有两种:一种是在指令的前面打开一些开关，让执行计划信息打在结果集里，这种方法比较适合在一个测试环境里对单个语句调优;另一种方法是使用SQL Trace里的事件跟踪来跟踪语句的执行计划,感兴趣的朋友可以了解下2013-01-01
乐观锁对应于生活中乐观的人总是想着事情往好的方向发展,悲观锁对应于生活中悲观的人总是想着事情往坏的方向发展.这两种人各有优缺点,不能不以场景而定说一种人好于另外一种人,文中详细介绍了悲观锁与乐观锁,需要的朋友可以参考下2022-08-08
本文主要讲了SQL Server的交叉联接和内部联接，同时也给出了使用需要注意的地方。有需要的朋友可以看下2016-12-12
花了这么多时间最终还是回到了数据库，但是数据库中一张一张的表格找不到脚本，也不是自己设计的数据库，完全没有一点头绪，后来突然想起来sql有个数据库关系图，可以很快的适合数据库程序员很快的掌握数据库表之间的关系2012-08-08
这篇文章主要介绍了获取SqlServer存储过程定义的三种方法的相关资料,非常不错，具有参考借鉴价值，需要的朋友可以参考下2016-07-07
SQL中Group分组获取Top N方法实现可首选row_number
统计每个城市的最新10个产品本文采用了游标方法/Count查询/cross apply方法/row_number方法等等对比不难发现Group获取Top N场景时，可以首选row_number，游标cursor其次，另外两个就基本不考虑了2013-03-03
之前脚本之家发过数据类型方面的文章，但内容不是很充实，这里的一篇文章，正好弥补以前的一些，建议这两篇文章一起看效果更好。2010-04-04
一个函数解决SQLServer中bigint 转 int带符号时报错问题
这篇文章主要介绍了解决SQLServer中bigint 转 int带符号时报错问题的函数,需要的朋友可以参考下2014-08-08
最新评论