sqlserver巧妙的自关联运用

最近在改报表分页，遇到一个很棘手的问题，需要将比较正常的数据记录新增加两列

第一列按照goodsid局部分组，然后在分组后的记录中按照audittime升序排序得到序号，从而显示某商品得第几次变迁。

第二列是取该商品的最后变迁价格newPrice，然后将该值赋到这个商品的其他行中，例如对于goodsid为1的，最后一个newprice为20，那么对于所有goodsid为1的记录curprice都写为20，从而达到外面控件分布的效果。

如下，比较正常的数据记录：

需要增加特殊的两列效果为：

以前的做法是在C#服务端将正常记录取出来（先按照GoodsId和audittime排序再取的），然后遍历整个数据集，新增了两个列，通过第一次循环解决expandfield的值问题，并用键值对巧妙的记录最后一次的newPrice，第二次循环则将键值对记录的newPrice赋给同一个goodsid的curprice。代码如下：
代码如下:

<br>private void ChangeDataTable(DataTable dt) <br>{ <br>dt.Columns.Add("curprice"); <br>dt.Columns.Add("expandfield"); <br>int goodsid = 0; <br>int index = 1; //指针 <br>decimal curprice = 0; <br>IHashObject curpriceobj = new HashObject(); //键值对 <br>//增加分布列 <br>foreach(DataRow row in dt.Rows){ <br>if (goodsid != Convert.ToInt32(row["goodsid"])) { <br>curpriceobj.Add("goodsid_"+goodsid, curprice); <br>//处理 <br>index = 0; <br>goodsid = Convert.ToInt32(row["goodsid"]); <br>} <br>curprice = Convert.ToDecimal(row["newprice"]); <br>index += 1; <br>row["expandfield"] = "第" + index + "次变迁"; <br>} <br>if(dt.Rows.Count != 0){ //添加最后一个商品的现行价 <br>curpriceobj.Add("goodsid_"+goodsid, curprice); <br>} <br>//增加现行价 <br>foreach (DataRow row in dt.Rows) { <br>row["curprice"] = curpriceobj["goodsid_" + row["goodsid"]]; <br>} <br>} <br> <br>但现在报表存储过程必须分页，分页后还要支持排序，如果客户端要求按照最新价格newPrice排序，很明显这样通过服务端转换的数据源是没办法支持的（因为在数据库分页前的数据源并没有newPrice这个字段）。 <br>另外在C#服务端处理，其实是比较占内存的，其一对DataTable遍历了两次，另外还用了临时键值对对象，反复赋值是有性能消耗。 <br>综上所述，最终我选择放在数据库来构建这两列。 <br>关于第一列局部排序，我很快想到了一个以前看过的语法 ROW_NUMBER() OVER(PARTITION BY...ORDER BY)，于是第一列expandfield很容易就构建了，SQL如下： <br> 代码如下:<pre class="brush:php;toolbar:false layui-box layui-code-view layui-code-notepad"><ol class="layui-code-ol"><li><br>SELECT '第' + CAST(ROW_NUMBER() OVER(PARTITION BY GoodsId ORDER BY audittime DESC) AS VARCHAR(10)) + '次变迁' AS expandfield, <br>GoodsId, price , discount , newPrice , begindate as [date] <br>FROM #test <br> <br>但真正麻烦的是第二列，我抠破脑壳来想都没想出来，甚至想到用临时表来记录这个结果集，然后用游标来遍历结果集，update这个表来修改记录，但还是感觉相当的繁琐，而且性能很差。后来我请教了下公司的DBA，她给出了一种思路，这种方案无论从效率还是可行性都是最优的。先贴出代码如下： <br> 代码如下:<pre class="brush:php;toolbar:false layui-box layui-code-view layui-code-notepad"><ol class="layui-code-ol"><li><br>WITH _TEMP AS ( <br>SELECT ROW_NUMBER() OVER ( PARTITION BY GoodsId ORDER BY audittime DESC ) AS num2 , <br>ROW_NUMBER() OVER ( PARTITION BY GoodsId ORDER BY audittime ) AS num , <br>GoodsId, price , discount , newPrice , begindate as [date] <br>FROM #test <br>) <br>SELECT '第' + CAST(a.num AS VARCHAR(10)) + '次变迁' AS expandfield , <br>a.goodsid , a.price , a.discount , a.newprice , a.date , b.newprice AS curprice <br>FROM _TEMP a <br>INNER JOIN _TEMP b ON a.GoodsId = b.GoodsId AND b.num2 = 1 <br> <br>这里用了一个CTE表达式的自关联查询，从性能上说是很有优势的，相对于临时表减少了对tempdb的开销，另外代码的可读性也比嵌套查询更强，num列是用来构建第几次变迁列的，这里很巧妙得多加了按照audittime降序列的num2列，在下面临时记录b中，通过指定b.num2 = 1取得所有goodsid最后变价的记录，再通过一个INNER JOIN就得到了我们想要的值curprice值。 <br><br>另外补充一下，像上面存在多个列上排序字段时，SQL会选择后者进行重排，即先按goodsid分组，然后再各个组中按audittime升序排列，如果将num放在前，num2放在后，是得不到我们要的记录。                    </li></ol></pre></li></ol></pre>