Início / dba / Perguntas / 335669
Accepted
SOUser
Asked: 2024-02-09 16:18:56 +0800 CST

Incrementar um campo em tempo de execução para o pool de SQL dedicado do Synapse SQL

  • 772

Tenho a tarefa de incrementar a coluna do sinalizador esperado examinando os valores existentes. Resolvi isso usando o loop while e posso atualizar o valor esperado usando o loop while no Azure Synapse-Sql Data Warehouse. Mas eu gostaria de saber uma maneira direta de fazer isso usando alguma função de classificação?

Meus dados de amostra

CREATE TABLE [dbo].[work_table](
[work_order_key] [int] NULL,
[modification_date] [datetime2](7) NULL,
[from_status] [varchar](1000) NULL,
[to_status] [varchar](100) NULL,
[count] [int] NULL,
[sequence] [int] NULL,
[count_VCR] [int] NULL,
[flag] [int] NULL,
[flag_expected] [int] NULL
  )

  INSERT [dbo].[work_table] ([work_order_key], [modification_date], [from_status], [to_status], [count], [sequence], [count_VCR], [flag], [flag_expected]) VALUES (1002586, CAST(N'2022-04-14T11:53:05.1630000' AS DateTime2), N'Not Reviewed', N'Planned', 1, 1, 1, 1, NULL)
  INSERT [dbo].[work_table] ([work_order_key], [modification_date], [from_status], [to_status], [count], [sequence], [count_VCR], [flag], [flag_expected]) VALUES (1002586, CAST(N'2022-04-19T03:49:25.7370000' AS DateTime2), N'Planned', N'In Progress', 1, 2, 1, 1, NULL)
  INSERT [dbo].[work_table] ([work_order_key], [modification_date], [from_status], [to_status], [count], [sequence], [count_VCR], [flag], [flag_expected]) VALUES (1002586, CAST(N'2022-04-19T04:22:33.0630000' AS DateTime2), N'In Progress', N'Awaiting Parts', 1, 3, 1, 1, NULL)
  INSERT [dbo].[work_table] ([work_order_key], [modification_date], [from_status], [to_status], [count], [sequence], [count_VCR], [flag], [flag_expected]) VALUES (1002586, CAST(N'2022-04-27T02:58:54.7570000' AS DateTime2), N'Awaiting Parts', N'Parts Ordered', 1, 4, 0, 1, NULL)
  INSERT [dbo].[work_table] ([work_order_key], [modification_date], [from_status], [to_status], [count], [sequence], [count_VCR], [flag], [flag_expected]) VALUES (1002586, CAST(N'2022-04-27T02:59:00.8530000' AS DateTime2), N'Parts Ordered', N'Parts Received', 1, 5, 0, 1, NULL)
  INSERT [dbo].[work_table] ([work_order_key], [modification_date], [from_status], [to_status], [count], [sequence], [count_VCR], [flag], [flag_expected]) VALUES (1002586, CAST(N'2022-04-27T02:59:09.9000000' AS DateTime2), N'Parts Received', N'Planned', 1, 6, 0, 1, NULL)
  INSERT [dbo].[work_table] ([work_order_key], [modification_date], [from_status], [to_status], [count], [sequence], [count_VCR], [flag], [flag_expected]) VALUES (1002586, CAST(N'2022-04-28T07:59:58.1130000' AS DateTime2), N'Planned', N'In Progress', 1, 7, 1, 1, NULL)
  INSERT [dbo].[work_table] ([work_order_key], [modification_date], [from_status], [to_status], [count], [sequence], [count_VCR], [flag], [flag_expected]) VALUES (1002586, CAST(N'2022-04-29T07:53:30.9030000' AS DateTime2), N'In Progress', N'Work Completed', 1, 8, 1, 1, NULL)
  INSERT [dbo].[work_table] ([work_order_key], [modification_date], [from_status], [to_status], [count], [sequence], [count_VCR], [flag], [flag_expected]) VALUES (1002586, CAST(N'2022-05-05T06:15:34.4300000' AS DateTime2), N'Work Completed', N'Completed', 1, 9, 0, 1, NULL)

Meu resultado esperado é insira a descrição da imagem aqui

A coluna de partição é [work_order_key] e qualquer coluna da lista conforme adequado. Enquanto o loop pode obter essa resposta. Usei as colunas work_order_key e count_VCR para obter isso em um loop while. Mas quero verificar com o grupo a consulta direta usando qualquer janela SQL ou funções de classificação.

Não posso adicionar minha solução porque é de produção. Este é apenas um conjunto de dados de amostra. Obrigado pelo apoio.

sql-server

1 respostas

  1. Best Answer

    Este é um problema clássico de lacunas e ilhas . Existem muitas soluções, mas uma típica é usar LAGe depois um arquivo COUNT.

    WITH PrevValues AS (
    SELECT *,
      PrevCount_VCR = LAG(wt.count_VCR) OVER (PARTITION BY wt.work_order_key ORDER BY wt.sequence)
    FROM dbo.work_table wt
)
SELECT *,
  New_flag_expected = COUNT(CASE WHEN wt.count_VCR = wt.PrevCount_VCR THEN NULL ELSE 1 END)
    OVER (PARTITION BY wt.work_order_key ORDER BY wt.sequence ROWS UNBOUNDED PRECEDING)
FROM PrevValues wt;

    E como uma UPDATEdeclaração (observe que não há junções necessárias no SQL Server, pois você pode atualizar o CTE diretamente).

    WITH PrevValues AS (
    SELECT *,
      PrevCount_VCR = LAG(wt.count_VCR) OVER (PARTITION BY wt.work_order_key ORDER BY wt.sequence)
    FROM dbo.work_table wt
),
Counted AS (
    SELECT *,
      New_flag_expected = COUNT(CASE WHEN wt.count_VCR = wt.PrevCount_VCR THEN NULL ELSE 1 END)
        OVER (PARTITION BY wt.work_order_key ORDER BY wt.sequence ROWS UNBOUNDED PRECEDING)
    FROM PrevValues wt
)
UPDATE Counted
SET flag_expected = New_flag_expected;

    banco de dados<> violino

    • 1

relate perguntas