Wie schließe ich Datenbankverbindungen für mehrere Goroutine, die in GO -Sprache geteilt wurden?

Eleganter Abschluss von Go Multi-Goroutine Shared Database Connection

Bei der gleichzeitigen Programmierung sind mehrere gemeinsam genutzte Datenbankverbindungen in Goroutine gemeinsame Szenarien. Eine unsachgemäße Verbindungsabschaltung kann zu Datenverlust oder Programmabsturz führen. In diesem Artikel wird untersucht, wie Datenbankverbindungen für mehrere gemeinsame Goroutine sicher schließen können.

Problemanalyse:

Die Verwendung von defer db.Close() direkt in der Haupt -Goroutine kann nicht garantieren, dass alle untergeordneten Goroutinen Datenbankvorgänge abgeschlossen haben, was dazu führen kann, dass die Verbindung im Voraus geschlossen wird und einen Fehler erhöht. Die Verwendung von defer db.Close() in jedem untergeordneten Goroutine führt dazu, dass die Verbindung mehrmals geschlossen wird, und der gleiche Fehler wird erhöht.

Lösung:

Es wird empfohlen, Zähler und sync.WaitGroup zu verwenden.

Beispielcode:

 Paket Main

importieren (
    "fmt"
    "Synchronisation"
    "Zeit"

    "Datenbank/SQL"
    _ "github.com/go-sql-driver/mysql" // durch Ihren Datenbanktreiber ersetzen)

Geben Sie die DBConn Struct {ein
    conn *sql.db
    wg *sync.waitgroup
}

func Opendb () (*dbconn, error) {
    DB, ERR: = SQL.OPEN ("MySQL", "Benutzer: Passwort@TCP (127.0.0.1:3306)/Datenbank") // Ersetzen Sie durch Ihre Datenbankverbindungszeichenfolge, wenn ERR! = NIL {
        Nil zurückgeben, ähm
    }
    return & dbconn {conn: db, wg: & sync.waitgroup {}}, nil
}

func (dc *dbconn) close () fehler {
    dc.wg.wait () // Warten Sie auf alle Goroutines, um die Rückgabe zu vervollständigen dc.conn.close ()
}

func querydb (dc *dbconn, i int) {
    Verschiebung dc.wg.done ()
    dc.wg.add (1) // Zähler wird hinzugefügt 1
    // ... Datenbankoperation ...
    time.sleep (time.second) // Simulation von Datenbankoperationen zeitaufwändiger fmt.printf ("goroutine %d fertig \ n", i))
}

func main () {
    DC, ERR: = OPENDB ()
    Wenn er! = nil {
        fmt.println ("Fehler Öffnen der Datenbank:", ERR)
        Zurückkehren
    }
    Defer dc.close () // Stellen Sie sicher, dass die Verbindung zuletzt für i: = 0 schließt; i <p> <strong>Code Erläuterung:</strong></p><ol>
<li> Die <code>dbConn</code> -Struktur enthält die Datenbankverbindung und <code>sync.WaitGroup</code> um die Ausführung von Goroutinen zu verwalten.</li>
<li> Die <code>openDb</code> -Funktion öffnet die Datenbankverbindung und gibt <code>dbConn</code> -Instanz zurück.</li>
<li> Die <code>close</code> verwendet <code>dc.wg.Wait()</code> um darauf zu warten, bis alle Goroutines abgeschlossen sind, bevor die Datenbankverbindung geschlossen wird.</li>
<li> <code>querydb</code> -Funktion verwendet <code>dc.wg.Add(1)</code> , um den Zähler zu erhöhen, bevor der Datenbankvorgang ausgeführt wird, und <code>defer dc.wg.Done()</code> um den Zähler nach Abschluss des Vorgangs zu verringern.</li>
<li> <code>main</code> startet mehrere GOROUTINES, um <code>querydb</code> auszuführen, und schließt schließlich die Datenbankverbindung mithilfe von <code>defer dc.close()</code> .</li>
</ol><p> Diese Methode stellt sicher, dass alle Goroutines Datenbankvorgänge abschließen und dann die Datenbankverbindung schließen, wodurch Datenverlust und Fehler vermieden werden. Denken Sie daran, die Datenbankverbindungszeichenfolge und den Treiber im Beispielcode zu ersetzen. Wenn die Datenbankbetriebszeit unvorhersehbar ist, können komplexere Mechanismen erforderlich sein, um auf die Fertigstellung aller Goroutinen zu warten, z. B. die Signalisierung mit einem Kanal.</p>

Das obige ist der detaillierte Inhalt vonWie schließe ich Datenbankverbindungen für mehrere Goroutine, die in GO -Sprache geteilt wurden?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!