Динамический запрос в хранимой процедуре, не возвращающий значение как DataSet / DataTable в ASP.Net Core 2.2 - PullRequest
Новая
       57

Динамический запрос в хранимой процедуре, не возвращающий значение как DataSet / DataTable в ASP.Net Core 2.2

0 голосов
/ 26 февраля 2019

У меня есть хранимая процедура, которая возвращает мне динамическую таблицу в результате.Код SQL за этот ответ 

create table temp
(
    date datetime,
    category varchar(3),
    amount money
)

insert into temp values ('1/1/2012', 'ABC', 1000.00)
insert into temp values ('1/1/2012', 'ABC', 2000.00)
insert into temp values ('2/1/2012', 'DEF', 500.00)
insert into temp values ('2/1/2012', 'DEF', 1500.00)
insert into temp values ('2/1/2012', 'GHI', 800.00)
insert into temp values ('2/10/2012', 'DEF', 700.00)
insert into temp values ('2/10/2012', 'DEF', 800.00)
insert into temp values ('3/1/2012', 'ABC', 1100.00)


CREATE PROCEDURE [dbo].[USP_DYNAMIC_PIVOT]
(
    @STATIC_COLUMN VARCHAR(255),
    @PIVOT_COLUMN VARCHAR(255),
    @VALUE_COLUMN VARCHAR(255),
    @TABLE VARCHAR(255),
    @AGGREGATE VARCHAR(20) = NULL
)
AS
BEGIN
    SET NOCOUNT ON;

    DECLARE @AVAIABLE_TO_PIVOT NVARCHAR(MAX),
            @SQLSTRING NVARCHAR(MAX),
            @PIVOT_SQL_STRING NVARCHAR(MAX),
            @TEMPVARCOLUMNS NVARCHAR(MAX),
            @TABLESQL NVARCHAR(MAX)

    IF ISNULL (@AGGREGATE, '') = '' 
    BEGIN
        SET @AGGREGATE = 'MAX'
    END

    SET @PIVOT_SQL_STRING ='SELECT top 1 STUFF((SELECT distinct '', '' + CAST(''[''+CONVERT(VARCHAR,'+ @PIVOT_COLUMN+')+'']''  AS VARCHAR(50)) [text()]
                        FROM '+@TABLE+'
                        WHERE ISNULL('+@PIVOT_COLUMN+','''') <> ''''
                        FOR XML PATH(''''), TYPE)
                        .value(''.'',''NVARCHAR(MAX)''),1,2,'' '') as PIVOT_VALUES
                        from '+@TABLE+' ma
                        ORDER BY ' + @PIVOT_COLUMN + ''

    DECLARE @TAB AS TABLE(COL NVARCHAR(MAX) )

    INSERT INTO @TAB 
        EXEC SP_EXECUTESQL @PIVOT_SQL_STRING, @AVAIABLE_TO_PIVOT 

    SET @AVAIABLE_TO_PIVOT = (SELECT * FROM @TAB)

    SET @TEMPVARCOLUMNS = (SELECT replace(@AVAIABLE_TO_PIVOT,',',' nvarchar(255) null,') + ' nvarchar(255) null')

    SET @SQLSTRING = 'DECLARE @RETURN_TABLE TABLE ('+@STATIC_COLUMN+' NVARCHAR(255) NULL,'+@TEMPVARCOLUMNS+')  
                INSERT INTO @RETURN_TABLE('+@STATIC_COLUMN+','+@AVAIABLE_TO_PIVOT+')

    SELECT * 
    FROM
        (SELECT ' + @STATIC_COLUMN + ' , ' + @PIVOT_COLUMN + ', ' + @VALUE_COLUMN + ' FROM '+@TABLE+' ) a
                PIVOT
                (
                '+@AGGREGATE+'('+@VALUE_COLUMN+')
                FOR '+@PIVOT_COLUMN+' IN ('+@AVAIABLE_TO_PIVOT+')
                ) piv

    SELECT * FROM @RETURN_TABLE'

    EXEC SP_EXECUTESQL @SQLSTRING
END

Это мой код C # в ASP.net Core 2.2 

DataTable dt = new DataTable();

using (SqlConnection conn = new SqlConnection(connectionString))
{
    SqlCommand sqlComm = new SqlCommand("USP_DYNAMIC_PIVOT", conn);

    sqlComm.Parameters.Add(new SqlParameter("@STATIC_COLUMN", SqlDbType.VarChar) { Direction = ParameterDirection.Input, Value = "Date" });
    sqlComm.Parameters.Add(new SqlParameter("@PIVOT_COLUMN", SqlDbType.VarChar) { Direction = ParameterDirection.Input, Value = "category" });
    sqlComm.Parameters.Add(new SqlParameter("@VALUE_COLUMN", SqlDbType.VarChar) { Direction = ParameterDirection.Input, Value = "amount" });
    sqlComm.Parameters.Add(new SqlParameter("@TABLE", SqlDbType.VarChar) { Direction = ParameterDirection.Input, Value = "dbo.temp" });
    sqlComm.Parameters.Add(new SqlParameter("@AGGREGATE", SqlDbType.VarChar) { Direction = ParameterDirection.Input, Value = "sum" });

    sqlComm.CommandType = CommandType.StoredProcedure;

    SqlDataAdapter da = new SqlDataAdapter();
    da.SelectCommand = sqlComm;

    da.Fill(dt);
}

dt равен нулю.Я пробовал трассировщик, и сгенерированный там вызов SQL возвращает правильные результаты при запуске.Трассировщик также показывает, что процедура завершила процесс.Что-то мне не хватает?

РЕДАКТИРОВАТЬ: Я добавил пакеты Nuget System.Data.Common и System.Data.SqlClient, как предложено в некоторых ответах здесь, но без изменений.

РЕДАКТИРОВАТЬ 2: Iя изменяю свой код, чтобы иметь полный рабочий пример.Это взято из этого примера , но проблема остается.Выполнение процедуры в трассировщике - 

exec USP_DYNAMIC_PIVOT @STATIC_COLUMN='Date',@PIVOT_COLUMN='category',@VALUE_COLUMN='amount',@TABLE='dbo.temp',@AGGREGATE='sum'

, что является правильным вызовом.

1 Ответ

0 голосов
/ 26 февраля 2019

Я (все еще) не могу это воспроизвести.Как видно из отслеживания действия, ADO.NET не пытается определить метаданные набора результатов перед выполнением команды.Вместо этого он проверяет метаданные, возвращенные в SqlDataReader, для создания схемы DataTable: 

using System;
using System.Data;
using System.Data.SqlClient;

namespace ConsoleApp15
{
    class Program
    {
        static void Main(string[] args)
        {
            var connectionString = "Server=.;Database=tempdb;integrated security=true";
            DataTable dt = new DataTable();
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                SqlCommand sqlComm = new SqlCommand("USP_DYNAMIC_PIVOT", conn);
                sqlComm.Parameters.Add(new SqlParameter("@STATIC_COLUMN", SqlDbType.VarChar) { Direction = ParameterDirection.Input, Value = "Date" });
                sqlComm.Parameters.Add(new SqlParameter("@PIVOT_COLUMN", SqlDbType.VarChar) { Direction = ParameterDirection.Input, Value = "category" });
                sqlComm.Parameters.Add(new SqlParameter("@VALUE_COLUMN", SqlDbType.VarChar) { Direction = ParameterDirection.Input, Value = "amount" });
                sqlComm.Parameters.Add(new SqlParameter("@TABLE", SqlDbType.VarChar) { Direction = ParameterDirection.Input, Value = "dbo.temp" });
                sqlComm.Parameters.Add(new SqlParameter("@AGGREGATE", SqlDbType.VarChar) { Direction = ParameterDirection.Input, Value = "sum" });

                sqlComm.CommandType = CommandType.StoredProcedure;

                SqlDataAdapter da = new SqlDataAdapter();
                da.SelectCommand = sqlComm;

                da.Fill(dt);

                Console.WriteLine($"SqlClient: { typeof(SqlConnection).Assembly.FullName}");
                dt.TableName = "sp_test";
                dt.WriteXmlSchema(Console.Out);
                Console.WriteLine();
                Console.WriteLine($"rows {dt.Rows.Count}");
            }


        }
    }
}

output 

SqlClient: System.Data.SqlClient, Version=4.5.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a
<?xml version="1.0" encoding="ibm437"?>
<xs:schema id="NewDataSet" xmlns="" xmlns:xs="http://www.w3.org/2001/XMLSchema" xmlns:msdata="urn:schemas-microsoft-com:xml-msdata">
  <xs:element name="NewDataSet" msdata:IsDataSet="true" msdata:MainDataTable="sp_test" msdata:UseCurrentLocale="true">
    <xs:complexType>
      <xs:choice minOccurs="0" maxOccurs="unbounded">
        <xs:element name="sp_test">
          <xs:complexType>
            <xs:sequence>
              <xs:element name="Date" type="xs:string" minOccurs="0" />
              <xs:element name="ABC" type="xs:string" minOccurs="0" />
              <xs:element name="DEF" type="xs:string" minOccurs="0" />
              <xs:element name="GHI" type="xs:string" minOccurs="0" />
            </xs:sequence>
          </xs:complexType>
        </xs:element>
      </xs:choice>
    </xs:complexType>
  </xs:element>
</xs:schema>
rows 4
...