Bagaimana untuk menutup sambungan pangkalan data yang betul untuk pelbagai goroutine yang dikongsi dalam bahasa Go?

Sambungan pangkalan data bersama Go Multi-Goroutine yang elegan

Dalam Pengaturcaraan Bersama GO, pelbagai sambungan pangkalan data bersama Goroutine adalah senario biasa. Penutupan sambungan yang tidak betul boleh mengakibatkan kehilangan data atau kemalangan program. Artikel ini meneroka cara untuk menutup sambungan pangkalan data dengan selamat untuk pelbagai goroutine dikongsi.

Analisis Masalah:

Menggunakan defer db.Close() secara langsung di goroutine utama tidak dapat menjamin bahawa semua goroutine kanak -kanak telah menyelesaikan operasi pangkalan data, yang boleh menyebabkan sambungan ditutup terlebih dahulu dan menimbulkan kesilapan. Menggunakan defer db.Close() dalam setiap kanak -kanak goroutine akan menyebabkan sambungan ditutup beberapa kali, dan kesilapan yang sama akan dibangkitkan.

Penyelesaian:

Adalah disyorkan untuk menggunakan kaunter dan sync.WaitGroup untuk menyelaraskan pelaksanaan goroutine dan penutupan sambungan pangkalan data.

Contoh kod:

 Pakej utama

import (
    "FMT"
    "Sync"
    "Masa"

    "Pangkalan Data/SQL"
    _ "github.com/go-sql-driver/mysql" // gantikan dengan pemacu pangkalan data anda)

taip dbconn struct {
    Conn *sql.db
    WG *Sync.WaitGroup
}

func Opendb () (*dbconn, error) {
    db, err: = sql.open ("mysql", "pengguna: kata laluan@tcp (127.0.0.1:3306)/pangkalan data") // Gantikan dengan rentetan sambungan pangkalan data anda jika err! = nil {
        Kembali nih, Err
    }
    kembali & dbconn {conn: db, wg: & sync.waitgroup {}}, nil
}

func (dc *dbconn) ralat () ralat {
    dc.wg.wait () // tunggu semua goroutine untuk melengkapkan kembali dc.conn.close ()
}

func querydb (dc *dbconn, i int) {
    menangguhkan dc.wg.done ()
    dc.wg.add (1) // kaunter ditambah 1
    // ... operasi pangkalan data ...
    time.sleep (time.second) // simulasi operasi pangkalan data yang memakan masa fmt.printf ("goroutine %d selesai \ n", i)
}

func main () {
    dc, err: = opendb ()
    jika err! = nil {
        fmt.println ("Pangkalan Data Pembukaan Ralat:", Err)
        Kembali
    }
    menangguhkan dc.close () // pastikan untuk menutup sambungan terakhir untuk i: = 0; i <p> <strong>Penjelasan kod:</strong></p><ol>
<li> Struktur <code>dbConn</code> mengandungi sambungan pangkalan data dan <code>sync.WaitGroup</code> untuk menguruskan pelaksanaan goroutine.</li>
<li> Fungsi <code>openDb</code> membuka sambungan pangkalan data dan mengembalikan contoh <code>dbConn</code> .</li>
<li> Kaedah <code>close</code> menggunakan <code>dc.wg.Wait()</code> untuk menunggu semua goroutine selesai sebelum menutup sambungan pangkalan data.</li>
<li> Fungsi <code>querydb</code> menggunakan <code>dc.wg.Add(1)</code> untuk meningkatkan kaunter sebelum melaksanakan operasi pangkalan data, dan menggunakan <code>defer dc.wg.Done()</code> untuk mengurangkan kaunter selepas operasi selesai.</li>
<li> Fungsi <code>main</code> bermula pelbagai goroutine untuk melaksanakan fungsi <code>querydb</code> , dan akhirnya menutup sambungan pangkalan data menggunakan <code>defer dc.close()</code> .</li>
</ol><p> Kaedah ini memastikan semua operasi pangkalan data Goroutine dan kemudian menutup sambungan pangkalan data, mengelakkan kehilangan data dan kesilapan. Ingat untuk menggantikan rentetan sambungan pangkalan data dan pemacu dalam kod sampel. Sekiranya masa operasi pangkalan data tidak dapat diramalkan, mekanisme yang lebih kompleks mungkin diperlukan untuk menunggu semua goroutine selesai, seperti isyarat menggunakan saluran.</p>

Atas ialah kandungan terperinci Bagaimana untuk menutup sambungan pangkalan data yang betul untuk pelbagai goroutine yang dikongsi dalam bahasa Go?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!