1

我有一个转置表格的动态pivot/unpivot脚本。这足够动态，可以返回我想要的某些列并使用动态列。

我正在寻找的是将其转换为 aUDF或 aVIEW以便我可以将其加入其他表。

请帮忙。

ALTER PROC [dbo].[uspGetUserByValues]
(
    @Select NVARCHAR(4000) = '*',
    @Where NVARCHAR(4000) = NULL,
    @OrderBy NVARCHAR(4000) = NULL
)
AS
BEGIN
    DECLARE @cols AS NVARCHAR(MAX),
    @query  AS NVARCHAR(MAX)

select @cols = STUFF((SELECT distinct ',P.' + QUOTENAME(PropertyDescription) 
                    from System_Properties
            FOR XML PATH(''), TYPE
            ).value('.', 'NVARCHAR(MAX)') 
        ,1,1,'')

    set @query = 'SELECT ' + @cols + ', M.Email, C.Company_Name, C.Company_Type_ID, U.UserName, ISNULL(SMS.SMSProfiles,0) SMSProfiles, U.UserID
                 from 
                 (
                    select PropertyDescription, UP.UserID, PropertyValue
                    from User_Properties UP 
                        JOIN System_Properties SP ON UP.PropertyID = SP.PropertyID
                        JOIN aspnet_Membership M ON UP.UserID = M.UserID
                ) X 
                pivot 
                (
                    min(PropertyValue)
                    for PropertyDescription in (' + REPLACE(@cols,'P.','') + ')
                ) P 
                JOIN aspnet_Membership M ON P.UserID = M.UserID
                JOIN aspnet_Users U on P.UserID = U.UserID
                JOIN Companies C ON C.Company_ID = P.Company_ID
                LEFT JOIN (SELECT UserId, COUNT(Users_SMS_Profile_ID) SMSProfiles 
                        FROM Users_SMS_Profile GROUP BY UserID ) SMS ON SMS.UserID = P.UserID
                '

    SET @query = 'SELECT ' + @Select + ' FROM ('+ @query +') A'

    IF ISNULL(@Where,'NULL') != 'NULL'
    BEGIN
        SET @query = @query + ' WHERE ' + @Where
    END
    IF ISNULL(@OrderBy,'NULL') != 'NULL'
    BEGIN
        SET @query = @query + ' ORDER BY ' + @OrderBy
    END

    execute(@query)

    --PRINT(@query)
END
4

2 回答 2

0

简单地说：你不能

至少你不能使用传统的 TSQL 编程来做到这一点。这意味着您将不得不使用一些技巧。让我解释。

最接近您的 SP 的是 UDF。但是，UDF 相当受限制。UDF 期望的一件事是数据在执行时和执行后保持不变。当然，这意味着 EXEC() 在该范围内是被禁止的。

另一种可能性是观点。但是，您有许多参数，并且视图的架构取决于这些参数。SQL Server 中不存在根据输入参数更改视图架构的功能。

现在是黑客。

我能想到的一个技巧是：

  • 创建 CLR UDF
  • 基于上下文连接创建新连接（相同的服务器，相同的数据库）
  • 在那里执行你的 SP
  • 将结果返回到您的原始管道

但它可能会或可能不会起作用（毕竟这是一个黑客）。

如果破解不起作用，您可以尝试按书玩。这意味着创建一个 CLR UDF，在其中组装 select 语句并执行它，这意味着您将不得不丢弃您原来的 SP。但是，它不是黑客攻击，因为 SQL CLR UDF 是针对此类（和其他）情况而设计的。唯一需要注意的是使用SqlMetaData，因为 UDF 没有预定义的结果集。看到这个。

在我之前的回答中，我说过可以使用 CLR UDF 来完成，但这是错误的。我忘记的一件事是微软坚持为 UDF 提供有限数量的列。这在 .NET 中开发时可能并不明显——毕竟，您可以将任意数量的列返回给 SqlPipe。请参阅此（未经测试的）代码...

[SqlFunction(DataAccess = DataAccessKind.Read)]
public static void DynOutFunc(SqlString select, SqlString where, SqlString orderBy)
{
    // 1: Create SQL query
    string query = "select db_id(), db_name()";

    // 2: Find out which colums and their types are part of the output
    SqlMetaData[] metaData = 
        {
            new SqlMetaData("ID", System.Data.SqlDbType.Int),
            new SqlMetaData("Database", System.Data.SqlDbType.NVarChar, 256)
        };

    using (SqlConnection connection = new SqlConnection("context connection=true"))
    {
        connection.Open();
        SqlCommand command = new SqlCommand(query, connection);
        SqlDataReader reader = command.ExecuteReader();

        using (reader)
        {
            while (reader.Read())
            {
                SqlDataRecord record = new SqlDataRecord(metaData);

                SqlContext.Pipe.SendResultsStart(record);

                for(int i = 0; i < metaData.Length; i++)
                {
                    if(metaData[i].DbType == DbType.String)
                        record.SetString(i, reader.GetString(i));
                    else if(metaData[i].DbType == DbType.Int32)
                        record.SetInt32(i, reader.GetInt32(i));
                    // else if's should cover all supported data taypes
                }

                SqlContext.Pipe.SendResultsRow(record);
            }
        }

        SqlContext.Pipe.SendResultsEnd();
    }
}

请注意保存有关列的信息的 SqlMetaData 集合。是什么阻止您在其中添加另一列？

但是（！）在 SQL Server 本身中注册该函数时，您必须提供参数，例如：

CREATE FUNCTION DynOutFunc 
  @select [nvarchar](4000), 
  @where [nvarchar](4000), 
  @orderBy [nvarchar](4000)
RETURNS TABLE (p1 type1, p2 type2, ... pN typeN)
AS EXTERNAL NAME SqlClrTest.UserDefinedFunctions.DynOutFunc;

事实证明，我能想到的没有任何技巧。或者这里根本没有黑客。

于 2013-07-17T13:06:37.437 回答
0

哦，哇，我成功了。

我知道这是使用“已知”列名，但实际上我不必知道它们。

首先，这是我用来创建视图的查询。至少每次添加新属性时，我都需要删除视图，或者我实际上可以编写一个作业来检查 System_Properties 中的所有属性是否都显示在视图中，如果没有，则删除视图并运行此代码。

CREATE PROC [dbo].[uspCreateViewUsers]
AS
BEGIN
    DECLARE @cols AS NVARCHAR(MAX),
    @query  AS NVARCHAR(MAX)

select @cols = STUFF((SELECT distinct ',P.' + QUOTENAME(PropertyDescription) 
                    from System_Properties
            FOR XML PATH(''), TYPE
            ).value('.', 'NVARCHAR(MAX)') 
        ,1,1,'')

    set @query = 'CREATE VIEW vwUsers AS SELECT ' + @cols + ', M.Email, C.Company_Name, C.Company_Type_ID, U.UserName, ISNULL(SMS.SMSProfiles,0) SMSProfiles, U.UserID
                 from 
                 (
                    select PropertyDescription, UP.UserID, PropertyValue
                    from User_Properties UP 
                        JOIN System_Properties SP ON UP.PropertyID = SP.PropertyID
                        JOIN aspnet_Membership M ON UP.UserID = M.UserID
                ) X 
                pivot 
                (
                    min(PropertyValue)
                    for PropertyDescription in (' + REPLACE(@cols,'P.','') + ')
                ) P 
                JOIN aspnet_Membership M ON P.UserID = M.UserID
                JOIN aspnet_Users U on P.UserID = U.UserID
                JOIN Companies C ON C.Company_ID = P.Company_ID
                LEFT JOIN (SELECT UserId, COUNT(Users_SMS_Profile_ID) SMSProfiles 
                        FROM Users_SMS_Profile GROUP BY UserID ) SMS ON SMS.UserID = P.UserID
                '

    execute(@query)
END

它们的视图，不能用表连接以图形方式表示，如下所示：

SELECT     P.[Company_ID], P.[Created_Date], P.[Created_User], P.[Cust_ID], P.[FirstName], P.[IPCheck], P.[JobTitle], P.[LastLogin], P.[LastModified_Date], P.[LastModified_User], 
                      P.[LastName], P.[Newsletter_OptIn], P.[Password_Change], P.[SupAdmin], P.[SysAccess], P.[SysAdmin], P.[User_Cat_1], P.[User_Cat_10], P.[User_Cat_2], 
                      P.[User_Cat_3], P.[User_Cat_4], P.[User_Cat_5], P.[User_Cat_6], P.[User_Cat_7], P.[User_Cat_8], P.[User_Cat_9], P.[UserClient_ID], M.Email, C.Company_Name, 
                      C.Company_Type_ID, U.UserName, ISNULL(SMS.SMSProfiles, 0) SMSProfiles, U.UserID
FROM         (SELECT     PropertyDescription, UP.UserID, PropertyValue
                       FROM          User_Properties UP JOIN
                                              System_Properties SP ON UP.PropertyID = SP.PropertyID JOIN
                                              aspnet_Membership M ON UP.UserID = M.UserID) X PIVOT (min(PropertyValue) FOR PropertyDescription IN ([Company_ID], [Created_Date], [Created_User], 
                      [Cust_ID], [FirstName], [IPCheck], [JobTitle], [LastLogin], [LastModified_Date], [LastModified_User], [LastName], [Newsletter_OptIn], [Password_Change], [SupAdmin], 
                      [SysAccess], [SysAdmin], [User_Cat_1], [User_Cat_10], [User_Cat_2], [User_Cat_3], [User_Cat_4], [User_Cat_5], [User_Cat_6], [User_Cat_7], [User_Cat_8], 
                      [User_Cat_9], [UserClient_ID])) P JOIN
                      aspnet_Membership M ON P.UserID = M.UserID JOIN
                      aspnet_Users U ON P.UserID = U.UserID JOIN
                      Companies C ON C.Company_ID = P.Company_ID LEFT JOIN
                          (SELECT     UserId, COUNT(Users_SMS_Profile_ID) SMSProfiles
                            FROM          Users_SMS_Profile
                            GROUP BY UserID) SMS ON SMS.UserID = P.UserID

这现在允许我像查询表一样查询视图。

我希望这对将来的其他人有所帮助。

于 2013-07-18T11:08:41.253 回答