sql >> Databáze >  >> RDS >> PostgreSQL

Pokračování transakce po chybě porušení primárního klíče

V transakci můžete také použít SAVEPOINTs.

Pythonish pseudokód je ilustrován ze strany aplikace:

database.execute("BEGIN")
foreach data_row in input_data_dictionary:
    database.execute("SAVEPOINT bulk_savepoint")
    try:
        database.execute("INSERT", table, data_row)
    except:
        database.execute("ROLLBACK TO SAVEPOINT bulk_savepoint")
        log_error(data_row)
        error_count = error_count + 1
    else:
        database.execute("RELEASE SAVEPOINT bulk_savepoint")

if error_count > error_threshold:
    database.execute("ROLLBACK")
else:
    database.execute("COMMIT")

Edit:Zde je skutečný příklad tohoto v akci v psql na základě mírné odchylky příkladu v dokumentaci (příkazy SQL s předponou ">"):

> CREATE TABLE table1 (test_field INTEGER NOT NULL PRIMARY KEY);
NOTICE:  CREATE TABLE / PRIMARY KEY will create implicit index "table1_pkey" for table "table1"
CREATE TABLE

> BEGIN;
BEGIN
> INSERT INTO table1 VALUES (1);
INSERT 0 1
> SAVEPOINT my_savepoint;
SAVEPOINT
> INSERT INTO table1 VALUES (1);
ERROR:  duplicate key value violates unique constraint "table1_pkey"
> ROLLBACK TO SAVEPOINT my_savepoint;
ROLLBACK
> INSERT INTO table1 VALUES (3);
INSERT 0 1
> COMMIT;
COMMIT
> SELECT * FROM table1;  
 test_field 
------------
          1
          3
(2 rows)

Všimněte si, že hodnota 3 byla vložena za chybu, ale stále uvnitř stejné transakce!

Dokumentace pro SAVEPOINT je na http://www.postgresql.org/docs/8.4/static/sql-savepoint.html.



  1. datagrip Nelze použít změny Tato tabulka je pouze pro čtení. Změny editoru buněk nelze použít

  2. Jak používat funkci LISTAGG společnosti Oracle s jedinečným filtrem?

  3. Jak vypustit tabulku v SQL

  4. Vícenásobná funkce REPLACE v Oracle