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 / 318982
Accepted
Biller Builder
Biller Builder
Asked: 2022-10-31 11:57:36 +0800 CST2022-10-31 11:57:36 +0800 CST 2022-10-31 11:57:36 +0800 CST

Como realizar atualizações em linhas recém-criadas dentro da mesma transação?

  • 772

Link do violino: https://dbfiddle.uk/EOE627Oa

Tabelas

CREATE TABLE accounts (
  id bigint GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
  created_at timestamptz NOT NULL DEFAULT CURRENT_TIMESTAMP,
  login text NOT NULL,
  password text NOT NULL,
  email text,
  init_index bigint,
  parent_id bigint REFERENCES accounts
);

Dados de entrada

[
  {
    "login": "11EB19631A",
    "password": "AE128AADEF97F1E54021",
    "reference_id": 1
  },
  {
    "login": "3ED4ECBBC9",
    "password": "E67EDDB6033D02140BB4",
    "email": "a@b",
    "reference_id": 2,
    "parent_reference": 1
  },
  {
    "login": "C86D7E2CF0",
    "password": "75404617C000A0EB070C",
    "reference_id": 3,
    "parent_reference": 2
  },
  {
    "login": "C51D77BF87",
    "password": "605509993A05EE393081",
    "email": null,
    "reference_id": 4,
    "parent_reference": 2
  },
  {
    "login": "2BAB5AA533",
    "password": "DFCAB818D812B1F8F761",
    "reference_id": 5,
    "parent_reference": 3
  },
  {
    "login": "4229D47E2C",
    "password": "CE4E14ED6AD77CBC71B5",
    "email": "b@c",
    "reference_id": 6,
    "parent_reference": 2
  }
]

Consulta

WITH account_inits AS (
  SELECT
    row_number () OVER () as init_index,
    login,
    password,
    email,
    reference_id,
    parent_reference
  FROM
    json_to_recordset(
      $json$$json$
    ) AS input_init(
      login text,
      password text,
      email text,
      reference_id int,
      parent_reference int
    )
),
-- create new accounts
new_accounts AS (
  INSERT INTO accounts
    (
      init_index,
      login,
      password,
      email
    )
  SELECT
    init_index,
    login,
    password,
    email
  FROM
    account_inits
  RETURNING
    *
),
parent_id_pairs AS (
    SELECT
      new_accounts.id,
      account_inits.reference_id
    FROM
      new_accounts
      INNER JOIN
      account_inits
      ON
        account_inits.reference_id IN (
          SELECT DISTINCT
            parent_reference AS reference_id
          FROM
            account_inits
        )
        AND
        new_accounts.init_index = account_inits.init_index
),
account_updates AS (
  SELECT
    new_accounts.id,
    parent_id_pairs.id AS parent_id
  FROM
    new_accounts
    INNER JOIN
    account_inits
    ON
      account_inits.parent_reference IS NOT NULL
      AND
      new_accounts.init_index = account_inits.init_index
    INNER JOIN
    parent_id_pairs
    ON
      account_inits.parent_reference = parent_id_pairs.reference_id
),
updated_accounts AS (
  UPDATE
    accounts
  SET
    parent_id = account_updates.parent_id
  FROM
    account_updates
  WHERE
    account_updates.id = accounts.id
  RETURNING
    *
)
SELECT
  *
FROM
  updated_accounts
;

SELECT
  id,
  init_index,
  parent_id
FROM
  accounts
;

O problema

A tabela em questão tem uma chave estrangeira para ela mesma para expressar um relacionamento semelhante a uma árvore entre suas linhas. Mas essas relações podem ser conhecidas antes mesmo de serem inseridas no lote. Portanto reference_ide parent_referencesão "identificadores de lote" que são gerados pelo aplicativo para mostrar as referências entre inicializadores.

No entanto, a base de dados não pode expressar esta relação no INSERTenunciado por motivos óbvios. Então pensei em executar uma UPDATEetapa separada em um CTE para linhas recém-criadas. Mas não funciona, apesar de todos os dados de entrada estarem corretos (você pode verificar isso SELECTdigitando os CTEs usados ​​no UPDATECTE), então o problema está no UPDATEpróprio bloco. Os documentos listam duas sintaxes diferentes para executar a UPDATEpartir de um conjunto de registros. Eu tentei os dois e nem apliquei nas parent_idlinhas criadas.

postgresql
  • 1 1 respostas
  • 41 Views

1 respostas

  • Voted
  1. Best Answer
    Erwin Brandstetter
    2022-10-31T22:47:46+08:002022-10-31T22:47:46+08:00

    Você pede atualizações...

    dentro da mesma transação

    Mas, mais especificamente, você está tentando fazer isso dentro do mesmo comando , o que faz toda a diferença.

    Solução

    Longa história curta:

    WITH account_inits AS (
       SELECT nextval(pg_get_serial_sequence('public.accounts', 'id')) AS id, *  -- !!!
       FROM   json_to_recordset($your_json_input)
       AS input_init(login text, password text, email text, reference_id int, parent_reference int)
       )
    INSERT INTO public.accounts
            (id,   login,   password,   email,   parent_id) OVERRIDING SYSTEM VALUE  -- !!!
    SELECT a.id, a.login, a.password, a.email, p.id                     -- !!!
    FROM   account_inits a
    LEFT   JOIN account_inits p ON p.reference_id = a.parent_reference  -- !!!
    RETURNING *;
    

    violino

    Isso é tudo. Observe os detalhes adicionados no violino simplificado.

    Isso pressupõe integridade referencial dentro de cada lote inserido: qualquer um reference_idque seja realmente referenciado por um parent_referencedeve existir exclusivamente no lote.

    Por quê? Como?

    O principal problema da sua tentativa original é explicado aqui

    • Por que as linhas inseridas em um CTE não podem ser atualizadas na mesma instrução?

    A solução seria executar instruções separadas (dentro da mesma transação). Mas não vá lá. Use a abordagem muito mais simples , conforme sugerido: Busque novos IDs seriais da sequência com nextval()antecedência. A LEFT JOINpara si mesmo faz o resto.

    Relacionado:

    • INSERT linhas em duas tabelas preservando a conexão com uma terceira tabela
    • Para cada linha, crie uma linha vinculada em outra tabela com ID gerado automaticamente

    Uma vez que o seu idé GENERATED ALWAYS AS IDENTITYdevemos usar OVERRIDING SYSTEM VALUEcomo demonstrado. Ver:

    • PostgreSQL Como DEFAULT coluna de identidade particionada?
    • INSERT linhas duplicadas para várias tabelas filho 1:M em cascata
    • 2

relate perguntas

  • Posso ativar o PITR depois que o banco de dados foi usado

  • Práticas recomendadas para executar a replicação atrasada do deslocamento de tempo

  • Os procedimentos armazenados impedem a injeção de SQL?

  • Sequências Biológicas do UniProt no PostgreSQL

  • Qual é a diferença entre a replicação do PostgreSQL 9.0 e o Slony-I?

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