主页 / dba / 问题 / 17921
Accepted
Ben Brocka
Asked: 2012-05-16 13:58:42 +0800 CST

将多行中的列合并为单行

  • 772

customer_comments由于数据库设计，我将一些拆分为多行，对于报告，我需要将comments每个唯一的行合并id为一行。我之前尝试过使用SELECT 子句和 COALESCE 技巧中的这个分隔列表，但我不记得它并且一定没有保存它。在这种情况下，我似乎也无法让它工作，似乎只能在一行上工作。

数据如下所示：

id  row_num  customer_code comments
-----------------------------------
1   1        Dilbert        Hard
1   2        Dilbert        Worker
2   1        Wally          Lazy

我的结果需要如下所示：

id  customer_code comments
------------------------------
1   Dilbert        Hard Worker
2   Wally          Lazy

所以对于每个row_num实际上只有一行结果；注释应按row_num. 上面的链接SELECT技巧可以将特定查询的所有值作为一行获取，但我不知道如何使它作为SELECT吐出所有这些行的语句的一部分工作。

我的查询必须自己遍历整个表并输出这些行。我没有将它们组合成多列，每行一个，所以PIVOT似乎不适用。

sql-server sql-server-2005

4 个回答

  1. Best Answer

    这对于相关子查询来说是相对微不足道的。您不能使用您提到的博客文章中突出显示的 COALESCE 方法，除非您将其提取到用户定义的函数中（或者除非您一次只想返回一行）。以下是我通常这样做的方式：

    DECLARE @x TABLE 
(
  id INT, 
  row_num INT, 
  customer_code VARCHAR(32), 
  comments VARCHAR(32)
);

INSERT @x SELECT 1,1,'Dilbert','Hard'
UNION ALL SELECT 1,2,'Dilbert','Worker'
UNION ALL SELECT 2,1,'Wally','Lazy';

SELECT id, customer_code, comments = STUFF((SELECT ' ' + comments 
    FROM @x AS x2 WHERE id = x.id
     ORDER BY row_num
     FOR XML PATH('')), 1, 1, '')
FROM @x AS x
GROUP BY id, customer_code
ORDER BY id;

    如果您遇到注释中的数据可能包含不安全的 XML 字符 ( >, <, &) 的情况，您应该更改此：

         FOR XML PATH('')), 1, 1, '')

    对于这种更精细的方法：

         FOR XML PATH(''), TYPE).value(N'(./text())[1]', N'varchar(max)'), 1, 1, '')

    （确保使用正确的目标数据类型，varchar或nvarchar，和正确的长度，并在所有字符串文字前加上Nif using nvarchar。）

    • 18

  2. 如果您被允许在您的环境中使用 CLR，这是为用户定义的聚合量身定制的案例。

    特别是，如果源数据非常大和/或您需要在应用程序中做很多此类事情，这可能是要走的路。我强烈怀疑Aaron 解决方案的查询计划不会随着输入大小的增长而很好地扩展。（我尝试向临时表添加索引，但这没有帮助。）

    与许多其他事情一样，此解决方案是一种权衡：

    • 甚至在您或您客户的环境中使用 CLR 集成的政治/政策。
    • CLR 函数可能更快，并且在给定一组真实数据的情况下会更好地扩展。
    • CLR 函数将可在其他查询中重用，并且您不必在每次需要执行此类操作时都复制（和调试）复杂的子查询。
    • 直接的 T-SQL 比编写和管理一段外部代码更简单。
    • 也许你不知道如何用 C# 或 VB 编程。
    • 等等

    编辑：好吧，我去尝试看看这是否真的更好，事实证明，使用聚合函数目前无法满足评论按特定顺序的要求。:(

    请参阅SqlUserDefinedAggregateAttribute.IsInvariantToOrder。基本上，您需要做的是OVER(PARTITION BY customer_code ORDER BY row_num)聚合时子句ORDER BY不支持。OVER我假设将此功能添加到 SQL Server 会引发大量蠕虫，因为在执行计划中需要更改的内容是微不足道的。前面提到的链接说这是为将来使用而保留的，所以这可以在将来实现（不过，在 2005 年你可能不走运）。

    这仍然可以通过将row_num值打包并解析到聚合字符串中来完成，然后在 CLR 对象中进行排序……这看起来很不自然。

    无论如何，下面是我使用的代码，以防其他人发现这很有用，即使有限制。我将把黑客部分作为练习留给读者。请注意，我使用 AdventureWorks (2005) 作为测试数据。

    聚合组装：

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

namespace MyCompany.SqlServer
{
    [Serializable]
    [SqlUserDefinedAggregate
    (
        Format.UserDefined,
        IsNullIfEmpty = false,
        IsInvariantToDuplicates = false,
        IsInvariantToNulls = true,
        IsInvariantToOrder = false,
        MaxByteSize = -1
    )]
    public class StringConcatAggregate : IBinarySerialize
    {
        private string _accum;
        private bool _isEmpty;

        public void Init()
        {
            _accum = string.Empty;
            _isEmpty = true;
        }

        public void Accumulate(SqlString value)
        {
            if (!value.IsNull)
            {
                if (!_isEmpty)
                    _accum += ' ';
                else
                    _isEmpty = false;

                _accum += value.Value;
            }
        }

        public void Merge(StringConcatAggregate value)
        {
            Accumulate(value.Terminate());
        }

        public SqlString Terminate()
        {
            return new SqlString(_accum);
        }

        public void Read(BinaryReader r)
        {
            this.Init();

            _accum = r.ReadString();
            _isEmpty = _accum.Length == 0;
        }

        public void Write(BinaryWriter w)
        {
            w.Write(_accum);
        }
    }
}

    用于测试的 T-SQL（省略了启用 CLR 和）CREATE ASSEMBLY：sp_configure

    CREATE TABLE [dbo].[Comments]
(
    CustomerCode int NOT NULL,
    RowNum int NOT NULL,
    Comments nvarchar(25) NOT NULL
)

INSERT INTO [dbo].[Comments](CustomerCode, RowNum, Comments)
    SELECT
        DENSE_RANK() OVER(ORDER BY FirstName),
        ROW_NUMBER() OVER(PARTITION BY FirstName ORDER BY ContactID),
        Phone
        FROM [AdventureWorks].[Person].[Contact]
GO

CREATE AGGREGATE [dbo].[StringConcatAggregate]
(
    @input nvarchar(MAX)
)
RETURNS nvarchar(MAX)
EXTERNAL NAME StringConcatAggregate.[MyCompany.SqlServer.StringConcatAggregate]
GO


SELECT
    CustomerCode,
    [dbo].[StringConcatAggregate](Comments) AS AllComments
    FROM [dbo].[Comments]
    GROUP BY CustomerCode
    • 6

  3. 这是一个基于游标的解决方案，可以保证评论的顺序row_num。（有关表格的填充方式，请参阅我的其他答案。）[dbo].[Comments]

    SET NOCOUNT ON

DECLARE cur CURSOR LOCAL FAST_FORWARD FOR
    SELECT
        CustomerCode,
        Comments
        FROM [dbo].[Comments]
        ORDER BY
            CustomerCode,
            RowNum

DECLARE @curCustomerCode int
DECLARE @lastCustomerCode int
DECLARE @curComment nvarchar(25)
DECLARE @comments nvarchar(MAX)

DECLARE @results table
(
    CustomerCode int NOT NULL,
    AllComments nvarchar(MAX) NOT NULL
)


OPEN cur

FETCH NEXT FROM cur INTO
    @curCustomerCode, @curComment

SET @lastCustomerCode = @curCustomerCode


WHILE @@FETCH_STATUS = 0
BEGIN

    IF (@lastCustomerCode != @curCustomerCode)
    BEGIN
        INSERT INTO @results(CustomerCode, AllComments)
            VALUES(@lastCustomerCode, @comments)

        SET @lastCustomerCode = @curCustomerCode
        SET @comments = NULL
    END

    IF (@comments IS NULL)
        SET @comments = @curComment
    ELSE
        SET @comments = @comments + N' ' + @curComment

    FETCH NEXT FROM cur INTO
        @curCustomerCode, @curComment

END

IF (@comments IS NOT NULL)
BEGIN
    INSERT INTO @results(CustomerCode, AllComments)
        VALUES(@curCustomerCode, @comments)
END

CLOSE cur
DEALLOCATE cur


SELECT * FROM @results
    • 1 
  4. -- solution avoiding the cursor ...

DECLARE @idMax INT
DECLARE @idCtr INT
DECLARE @comment VARCHAR(150)

SELECT @idMax = MAX(id)
FROM [dbo].[CustomerCodeWithSeparateComments]

IF @idMax = 0
    return
DECLARE @OriginalTable AS Table
(
    [id] [int] NOT NULL,
    [row_num] [int] NULL,
    [customer_code] [varchar](50) NULL,
    [comment] [varchar](120) NULL
)

DECLARE @FinalTable AS Table
(
    [id] [int] IDENTITY(1,1) NOT NULL,
    [customer_code] [varchar](50) NULL,
    [comment] [varchar](120) NULL
)

INSERT INTO @FinalTable 
([customer_code])
SELECT [customer_code]
FROM [dbo].[CustomerCodeWithSeparateComments]
GROUP BY [customer_code]

INSERT INTO @OriginalTable
           ([id]
           ,[row_num]
           ,[customer_code]
           ,[comment])
SELECT [id]
      ,[row_num]
      ,[customer_code]
      ,[comment]
FROM [dbo].[CustomerCodeWithSeparateComments]
ORDER BY id, row_num

SET @idCtr = 1
SET @comment = ''

WHILE @idCtr < @idMax
BEGIN

    SELECT @comment = @comment + ' ' + comment
    FROM @OriginalTable 
    WHERE id = @idCtr
    UPDATE @FinalTable
       SET [comment] = @comment
    WHERE [id] = @idCtr 
    SET @idCtr = @idCtr + 1
    SET @comment = ''

END 

SELECT @comment = @comment + ' ' + comment
        FROM @OriginalTable 
        WHERE id = @idCtr

UPDATE @FinalTable
   SET [comment] = @comment
WHERE [id] = @idCtr

SELECT *
FROM @FinalTable
    • 0

相关问题