Warum ist Datenbank/SQL langsamer als die direkte Datenbankabfrage und wie kann ich das Problem beheben?

Untersuchung der Abfrageleistungsunterschiede: Datenbank/SQL vs. Direktabfrage

Abfragen, die mit dem Go-Paket Datenbank/SQL ausgeführt werden, sind deutlich langsamer als entsprechende Abfragen, die direkt für die Datenbank ausgeführt werden . Um diese Ungleichheit zu beseitigen, ist es wichtig, sich mit den zugrunde liegenden Mechanismen zu befassen.

Verbindungsverwaltung in Datenbank/SQL

Das sql.DB-Objekt stellt einen Pool von Verbindungen dar, nicht eine einzelne Verbindung. Wenn sql.Open aufgerufen wird, initialisiert es den Pool, stellt jedoch möglicherweise keine Verbindungen her. Erst wenn eine Abfrage angefordert wird, wird eine neue Verbindung erstellt.

Auswirkungen auf das Abfrage-Timing

Im bereitgestellten Code-Snippet stößt die erste Abfrage auf einen Leistungseinbruch, da sie die Erstellung einer neuen Verbindung auslöst Datenbankverbindung. Auch die zweite Abfrage weist aufgrund der fehlenden Wiederverwendung von Verbindungen eine Leistungslücke auf. Jede Abfrage stellt eine neue Verbindung her, anstatt eine vorhandene inaktive Verbindung aus dem Pool zu verwenden.

Verbindungen zurück zum Pool freigeben

Um dieses Problem zu beheben, ist es wichtig, Verbindungen zurück zum Pool freizugeben nach jeder Abfrage. Dies kann erreicht werden, indem der erste Rückgabewert von db.Query, der die Abfrageergebnisse darstellt, beibehalten und .Close() darauf aufgerufen wird.

Herstellen einer Leerlaufverbindung

Um mit einem zu beginnen Wenn eine Verbindung im Pool verfügbar ist, rufen Sie nach der Initialisierung Ping für das sql.DB-Objekt auf. Dadurch wird die Erstellung einer ersten Verbindung erzwungen.

Vorbereitete Anweisungen und Positionsparameter

Vorbereitete Anweisungen werden verwendet, wenn Abfragen Argumente enthalten. Das Postgres-Protokoll ermöglicht Parameter anstelle des direkten Einfügens von Werten in die Abfragezeichenfolge. Diese separate Parametrisierung ermöglicht eine effizientere Bearbeitung von Abfragen.

Codebeispiel

Der folgende Codeausschnitt veranschaulicht, wie Verbindungen korrekt verwaltet und vorbereitete Anweisungen wiederverwendet werden:

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/lib/pq"
    "time"
)

func main() {
    // Initialize database connection with initial idle connection
    db, err := sql.Open("postgres", "postgres:///?sslmode=disable")
    if err != nil {
        panic(err)
    }
    if err := db.Ping(); err != nil {
        panic(err)
    }

    for i := 0; i < 5; i++ {
        // Prepare query
        query := "select 1 where true"
        stmt, err := db.Prepare(query)
        if err != nil {
            panic(err)
        }

        // Execute and time query
        firstQueryStart := time.Now()
        rows, err := stmt.Query()
        firstQueryEnd := time.Now()
        if err != nil {
            panic(err)
        }

        // Release connection back to pool
        rows.Close()

        fmt.Println(fmt.Sprintf("query #%d took %s", i, firstQueryEnd.Sub(firstQueryStart).String()))
    }
}

Von Durch die Implementierung dieser Optimierungen kann die Lücke in der Abfrageleistung erheblich verringert werden, wodurch vergleichbare Ausführungszeiten wie bei direkten Abfragen erreicht werden.

Das obige ist der detaillierte Inhalt vonWarum ist Datenbank/SQL langsamer als die direkte Datenbankabfrage und wie kann ich das Problem beheben?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!