Schließt DBI Freigabesperre von Postgres-Datenbank

Question

Ich versuche, eine Webanwendung zu schreiben, die auf mehreren Servern ausgeführt wird, aber eine einzelne Datenbank für finanzielle Transaktionen gemeinsam nutzen.

In einfachen Worten möchte ich Geld von Konto A zu B übertragen. Aber es könnte mehrere Anfragen sein, Geld von dem gleichen Konto zu überweisen.

Das Guthaben kann niemals negativ sein, daher entschied ich mich, SELECT FOR UPDATE zu verwenden, um das Guthaben zu holen, um die Zeile zu sperren.

Ich verwende JDBI für eine Verbindung mit der Datenbank: http://jdbi.org/

Der Code Fluss wird wie folgt dar:

Controller:

DBI dbi = new DBI(datasource); 

..... 
getAccountBalance(); 

.... 

transfer() 

Hier die DOA Teil

public int getAccountBalance(String id) { 
     Handle h = dbi.open(); 
     try{ 
      return h.createQuery("SELECT balance FROM accounts " + 
           " WHERE id=:id FOR UPDATE;") 
        .bind("id", id) 
        .mapTo(Integer.class) 
        .first(); 
     } finally { 
      h.close(); 
     } 
    } 

Der DAO gibt den Saldo zurück, ich führe einen Saldo-Check durch ee, wenn die Übertragung durchgeführt werden kann und dann eine andere Methode aufrufen, um die Übertragung durchzuführen.

public void transfer(String fromAccountId, String toAccountId, int transferAmount) { 
     Handle h = dbi.open(); 
     try{ 
      h.begin(); 
      h.createStatement("UPDATE accounts SET balance = balance - :transferAmount WHERE id = :fromAccountId") 
       .bind("fromAccountId", fromAccountId) 
       .bind("transferAmount", transferAmount) 
       .execute(); 
      h.createStatement("UPDATE accounts SET balance = balance + :transferAmount WHERE id = :toAccountId") 
       .bind("toAccountId", toAccountId) 
       .bind("transferAmount", transferAmount) 
       .execute(); 
      h.commit(); 
     } finally { 
      h.close(); 
     } 
    } 

Meine Frage ist, wenn ich den Griff in getAccountBalance() schließt er die Sperre freigeben auf die Zeile sie ausgewählt? Wenn das der Fall ist, wie halte ich das Schloss? Ich bin neu bei DBI. Danke

Answer 1

Es ist tatsächlich vor der , unter h.commit() freigegeben. Zeilensperren werden nicht länger als festgeschrieben gespeichert.

Wenn Sie Sperren benötigen, die nach dem Commit gehalten werden, können Sie Advisory Locks verwenden, aber sie sind ein bisschen peinlich und nicht etwas, das ich für so etwas empfehlen würde.

Sonst lesen Sie bitte auf pessimistic vs optimistic locking. Siehe auch Optimistic vs. Pessimistic locking.