AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • Início
  • system&network
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • Início
  • system&network
    • Recentes
    • Highest score
    • tags
  • Ubuntu
    • Recentes
    • Highest score
    • tags
  • Unix
    • Recentes
    • tags
  • DBA
    • Recentes
    • tags
  • Computer
    • Recentes
    • tags
  • Coding
    • Recentes
    • tags
Início / dba / Perguntas / 235227
Accepted
user9516827
user9516827
Asked: 2019-04-19 13:26:13 +0800 CST2019-04-19 13:26:13 +0800 CST 2019-04-19 13:26:13 +0800 CST

Converteu uma função escalar em uma função TVF para execução paralela - ainda em execução no modo serial

  • 772

Uma das minhas consultas estava sendo executada no modo de execução serial após um lançamento e notei que duas novas funções foram usadas em uma exibição que é referenciada no LINQ to SQL Query gerado a partir do aplicativo. Então eu converti essas funções SCALAR para funções TVF, mas ainda assim a consulta está sendo executada no modo serial.

Anteriormente eu fiz a conversão Scalar para TVF em algumas outras consultas e resolveu o problema de execução serial forçada.

Aqui está a função escalar:

CREATE FUNCTION [dbo].[FindEventReviewDueDate]
(
       @EventNumber VARCHAR(20),
       @EventID VARCHAR(25),
          @EventIDDate BIT
)

RETURNS DateTime
AS
BEGIN

DECLARE @CurrentEventStatus VARCHAR(20)
DECLARE @EventDateTime DateTime
DECLARE @ReviewDueDate DateTime


SELECT @CurrentEventStatus = (SELECT cis.EventStatus
                                 FROM CurrentEventStatus cis 
                                 INNER JOIN Event1 r WITH (NOLOCK) ON (cis.Event1Id = r.Id)
                                 WHERE (r.EventNumber = @EventNumber) AND r.EventID = @EventID)

SELECT @EventDateTime = (SELECT EventDateTime FROM Event1 r 
                          WHERE (r.EventNumber = @EventNumber) AND r.EventID = @EventID)

IF @CurrentEventStatus IN ('0','6') AND EventIDDate = 1
BEGIN

       SET @ReviewDueDate = DATEADD(DAY, 30, @EventDateTime)

       WHILE @ReviewDueDate < getdate() 
             SET @ReviewDueDate = DATEADD(DAY, 30, @ReviewDueDate)

       DECLARE @EventDateJournalDate DateTime

       SELECT @EventDateJournalDate = (SELECT TOP 1 ij.Date
                                       FROM EventPage_EventJournal ij 
                                       INNER JOIN EventJournalPages p ON ij.PageId = p.Id 
                                       INNER JOIN Journal f ON p.FormId = f.Id 
                                       INNER JOIN Event1 r WITH (NOLOCK) ON (f.Event1Id = r.Id)
                                       WHERE (r.EventNumber = @EventNumber AND r.EventID = @EventID) AND ij.ReviewType = 'Supervisor Monthly Review' ORDER BY ij.Date DESC)

      IF(DATEADD(DAY, 30, @EventDateTime) < getdate() AND
           (@EventDateJournalDate is null OR DATEADD(DAY, 30, @EventDateJournalDate) < getdate()) AND
              DATEADD(DAY, 14, @ReviewDueDate) > DATEADD(DAY, 30, getdate()))
                  SET @ReviewDueDate = DATEADD(DAY, -30, @ReviewDueDate)
         ELSE IF((@EventDateJournalDate is not null ) AND (DATEADD(DAY, 30, @EventDateJournalDate) >= @ReviewDueDate))
                  SET @ReviewDueDate = DATEADD(DAY, 30, @ReviewDueDate)

END
RETURN @ReviewDueDate

END

Aqui está a função TVF convertida.

CREATE FUNCTION [dbo].[FindEventReviewDueDate_test]
(
       @EventNumber VARCHAR(20),
       @EventID VARCHAR(25),
          @EventIDDate BIT
)

RETURNS @FunctionResultTableVairable TABLE (
 CurrentEventStatus varchar(20),
 Event1DateTime DateTime,
 ReviewDueDate DateTime
 )
AS 
BEGIN

DECLARE @CurrentEventStatus VARCHAR(20)
DECLARE @EventDateTime DateTime
DECLARE @ReviewDueDate DateTime


SELECT @CurrentEventStatus = (SELECT cis.EventStatus
                                 FROM CurrentEventStatus cis 
                                 INNER JOIN Event1 r WITH (NOLOCK) ON (cis.Event1Id = r.Id)
                                 WHERE (r.EventNumber = @EventNumber) AND r.EventID = @EventID)

SELECT @EventDateTime = (SELECT EventDateTime FROM Event1 r 
                          WHERE (r.EventNumber = @EventNumber) AND r.EventID = @EventID)

IF @CurrentEventStatus IN ('0','6') AND EventIDDate = 1
BEGIN

       SET @ReviewDueDate = DATEADD(DAY, 30, @EventDateTime)

       WHILE @ReviewDueDate < getdate() 
             SET @ReviewDueDate = DATEADD(DAY, 30, @ReviewDueDate)

       DECLARE @EventDateJournalDate DateTime

       SELECT @EventDateJournalDate = (SELECT TOP 1 ij.Date
                                       FROM EventPage_EventJournal ij 
                                       INNER JOIN EventJournalPages p ON ij.PageId = p.Id 
                                       INNER JOIN Journal f ON p.FormId = f.Id 
                                       INNER JOIN Event1 r WITH (NOLOCK) ON (f.Event1Id = r.Id)
                                       WHERE (r.EventNumber = @EventNumber AND r.EventID = @EventID) AND ij.ReviewType = 'Supervisor Monthly Review' ORDER BY ij.Date DESC)

      IF(DATEADD(DAY, 30, @EventDateTime) < getdate() AND
           (@EventDateJournalDate is null OR DATEADD(DAY, 30, @EventDateJournalDate) < getdate()) AND
              DATEADD(DAY, 14, @ReviewDueDate) > DATEADD(DAY, 30, getdate()))
                  SET @ReviewDueDate = DATEADD(DAY, -30, @ReviewDueDate)
         ELSE IF((@EventDateJournalDate is not null ) AND (DATEADD(DAY, 30, @EventDateJournalDate) >= @ReviewDueDate))
                  SET @ReviewDueDate = DATEADD(DAY, 30, @ReviewDueDate)
                   insert into @FunctionResultTableVairable
      select @CurrentEventStatus,@EventDateTime,@ReviewDueDate          

END
return;
END

GO

Há algo de errado com minha implementação da função TVF que está impedindo que a consulta seja executada no modo paralelo.

Eu uso a função TVF na consulta conforme abaixo;

select ReviewDueDate from dbo.FunctionResultTableVairable('a','b','c')

Minha consulta real que usa a visão é bastante complexa e se eu comentar a parte da função na visão e na execução, a consulta é executada em paralelo. Portanto, é a função que está forçando a consulta a ser executada em paralelo.

Minha consulta real está no formato abaixo.

select 
dv.column1,
dv.column2,
---------
---------
--------
(select ReviewDueDate from dbo.FunctionResultTableVairable('a','b','c')) AS 'Columnx'
from
DemoView dv
Where 
condition1
conditon 2

Qualquer ajuda é apreciada.

sql-server performance
  • 3 3 respostas
  • 765 Views

3 respostas

  • Voted
  1. Erik Darling
    2019-04-19T14:41:29+08:002019-04-19T14:41:29+08:00

    Forrest está quase certo, mas os detalhes mais sutis são:

    O SQL Server não pode paralelizar modificações em variáveis ​​de tabela, que sua função usa.

    Antes da execução intercalada do SQL Server 2017 , as estimativas de linha das funções com valor de tabela de várias instruções eram muito baixas.

    Um efeito colateral disso é que os planos custavam muito mal na extremidade inferior e muitas vezes não quebravam o limite de custo para o paralelismo.

    • 11
  2. Forrest
    2019-04-19T13:37:59+08:002019-04-19T13:37:59+08:00

    O SQL Server não pode paralelizar TVFs de várias instruções, que é o seu. Somente TVFs Inline podem ser paralelizados.

    • 10
  3. Best Answer
    Martin Smith
    2019-04-20T07:43:13+08:002019-04-20T07:43:13+08:00

    é possível converter minha função escalar para TVF Inline?

    Sim. Algo como o abaixo faria isso.

    Ainda é bastante robusto e, se executado correlacionado, provavelmente seria bastante ineficiente. Como Aaron aponta nos comentários, você está chamando isso com valores constantes, portanto, esperamos que o plano de consulta reflita isso e o execute apenas uma vez.

    CREATE FUNCTION [dbo].[FindEventReviewDueDateInline] (@EventNumber VARCHAR(20),
                                                          @EventID     VARCHAR(25),
                                                          @EventIDDate BIT)
    RETURNS TABLE
    AS
        RETURN
          WITH X
               AS (SELECT cis.EventStatus AS CurrentEventStatus,
                          r.EventDateTime
                   FROM   CurrentEventStatus cis
                          INNER JOIN Event1 r
                                  ON cis.Event1Id = r.Id
                   WHERE  r.EventNumber = @EventNumber
                          AND r.EventID = @EventID
                          AND cis.EventStatus IN ( '0', '6' )
                          AND @EventIDDate = 1)
          SELECT X.CurrentEventStatus,
                 X.EventDateTime,
                 CA4.ReviewDueDate
          FROM   X
                 --SET @ReviewDueDate = DATEADD(DAY, 30, @EventDateTime)
                 CROSS APPLY(VALUES(DATEADD(DAY, 30, X.EventDateTime))) CA1(ReviewDueDate)
                 -- WHILE @ReviewDueDate < getdate() 
                 --       SET @ReviewDueDate = DATEADD(DAY, 30, @ReviewDueDate)
                 CROSS APPLY(VALUES( IIF(CA1.ReviewDueDate >= GETDATE(), CA1.ReviewDueDate, DATEADD(DAY, 30 * CEILING(( IIF(CAST(GETDATE() AS TIME) > CAST(CA1.ReviewDueDate AS TIME), 1, 0)
                                                                                                               + DATEDIFF(DAY, CA1.ReviewDueDate, GETDATE()) ) / 30.0), CA1.ReviewDueDate)))) CA2(ReviewDueDate)
                 --SELECT @EventDateJournalDate = ....
                 CROSS APPLY(SELECT TOP 1 ij.Date
                             FROM   EventPage_EventJournal ij
                                    INNER JOIN EventJournalPages p
                                            ON ij.PageId = p.Id
                                    INNER JOIN Journal f
                                            ON p.FormId = f.Id
                                    INNER JOIN Event1 r WITH (NOLOCK)
                                            ON ( f.Event1Id = r.Id )
                             WHERE  ( r.EventNumber = @EventNumber
                                      AND r.EventID = @EventID )
                                    AND ij.ReviewType = 'Supervisor Monthly Review'
                             ORDER  BY ij.Date DESC) CA3(EventDateJournalDate)
                 -- IF(DATEADD(DAY, 30, @EventDateTime) < getdate()
                 CROSS APPLY(VALUES ( CASE
                              WHEN ( DATEADD(DAY, 30, X.EventDateTime) < GETDATE()
                                     AND ( CA3.EventDateJournalDate IS NULL
                                            OR DATEADD(DAY, 30, CA3.EventDateJournalDate) < GETDATE() )
                                     AND DATEADD(DAY, 14, CA2.ReviewDueDate) > DATEADD(DAY, 30, GETDATE()) )
                                THEN DATEADD(DAY, -30, CA2.ReviewDueDate)
                              WHEN( ( CA3.EventDateJournalDate IS NOT NULL )
                                    AND ( DATEADD(DAY, 30, CA3.EventDateJournalDate) >= CA2.ReviewDueDate ) )
                                THEN DATEADD(DAY, 30, CA2.ReviewDueDate)
                              ELSE CA2.ReviewDueDate
                            END )) CA4(ReviewDueDate); 
    
    • 5

relate perguntas

  • Quais são as principais causas de deadlocks e podem ser evitadas?

  • Como determinar se um Índice é necessário ou necessário

  • Onde posso encontrar o log lento do mysql?

  • Como posso otimizar um mysqldump de um banco de dados grande?

Sidebar

Stats

  • Perguntas 205573
  • respostas 270741
  • best respostas 135370
  • utilizador 68524
  • Highest score
  • respostas
  • Marko Smith

    conectar ao servidor PostgreSQL: FATAL: nenhuma entrada pg_hba.conf para o host

    • 12 respostas
  • Marko Smith

    Como fazer a saída do sqlplus aparecer em uma linha?

    • 3 respostas
  • Marko Smith

    Selecione qual tem data máxima ou data mais recente

    • 3 respostas
  • Marko Smith

    Como faço para listar todos os esquemas no PostgreSQL?

    • 4 respostas
  • Marko Smith

    Listar todas as colunas de uma tabela especificada

    • 5 respostas
  • Marko Smith

    Como usar o sqlplus para se conectar a um banco de dados Oracle localizado em outro host sem modificar meu próprio tnsnames.ora

    • 4 respostas
  • Marko Smith

    Como você mysqldump tabela (s) específica (s)?

    • 4 respostas
  • Marko Smith

    Listar os privilégios do banco de dados usando o psql

    • 10 respostas
  • Marko Smith

    Como inserir valores em uma tabela de uma consulta de seleção no PostgreSQL?

    • 4 respostas
  • Marko Smith

    Como faço para listar todos os bancos de dados e tabelas usando o psql?

    • 7 respostas
  • Martin Hope
    Jin conectar ao servidor PostgreSQL: FATAL: nenhuma entrada pg_hba.conf para o host 2014-12-02 02:54:58 +0800 CST
  • Martin Hope
    Stéphane Como faço para listar todos os esquemas no PostgreSQL? 2013-04-16 11:19:16 +0800 CST
  • Martin Hope
    Mike Walsh Por que o log de transações continua crescendo ou fica sem espaço? 2012-12-05 18:11:22 +0800 CST
  • Martin Hope
    Stephane Rolland Listar todas as colunas de uma tabela especificada 2012-08-14 04:44:44 +0800 CST
  • Martin Hope
    haxney O MySQL pode realizar consultas razoavelmente em bilhões de linhas? 2012-07-03 11:36:13 +0800 CST
  • Martin Hope
    qazwsx Como posso monitorar o andamento de uma importação de um arquivo .sql grande? 2012-05-03 08:54:41 +0800 CST
  • Martin Hope
    markdorison Como você mysqldump tabela (s) específica (s)? 2011-12-17 12:39:37 +0800 CST
  • Martin Hope
    Jonas Como posso cronometrar consultas SQL usando psql? 2011-06-04 02:22:54 +0800 CST
  • Martin Hope
    Jonas Como inserir valores em uma tabela de uma consulta de seleção no PostgreSQL? 2011-05-28 00:33:05 +0800 CST
  • Martin Hope
    Jonas Como faço para listar todos os bancos de dados e tabelas usando o psql? 2011-02-18 00:45:49 +0800 CST

Hot tag

sql-server mysql postgresql sql-server-2014 sql-server-2016 oracle sql-server-2008 database-design query-performance sql-server-2017

Explore

  • Início
  • Perguntas
    • Recentes
    • Highest score
  • tag
  • help

Footer

AskOverflow.Dev

About Us

  • About Us
  • Contact Us

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve