Laksanakan kumpulan sambungan pangkalan data dengan mudah menggunakan bahasa Go

Bahasa Go ialah bahasa pengaturcaraan sumber terbuka dan cekap yang sangat sesuai untuk pengaturcaraan rangkaian dan pengaturcaraan serentak. Dalam bahasa Go, kumpulan sambungan pangkalan data adalah konsep yang sangat penting, yang boleh meningkatkan kecekapan operasi pangkalan data dan menjimatkan sumber sistem.

Artikel ini akan memperkenalkan cara menggunakan bahasa Go untuk melaksanakan kumpulan sambungan pangkalan data dengan mudah, termasuk cara memulakan kumpulan sambungan, cara mendapatkan sambungan, cara mengembalikan sambungan, dsb.

1. Mulakan kumpulan sambungan

Dalam bahasa Go, kita boleh menggunakan sync.Pool untuk melaksanakan kumpulan sambungan. sync.Pool ialah pelaksanaan kumpulan objek serentak dan selamat terbina dalam bahasa Go, yang boleh menyimpan dan menggunakan semula objek dalam apa jua jenis. Kita boleh menggunakan sync.Pool untuk melaksanakan pengumpulan sambungan pangkalan data.

Pertama, kita perlu mentakrifkan objek kumpulan sambungan:

type MySQLPool struct {
    pool *sync.Pool
    connector func() (*sql.DB, error)
}

Antaranya, kolam ialah penyegerakan. Objek Kolam, dan penyambung ialah fungsi untuk menyambung ke pangkalan data. Fungsi penyambung mengembalikan objek jenis *sql.DB dan objek ralat, yang mewakili hasil penyambungan ke pangkalan data.

Seterusnya, kita perlu memulakan kumpulan sambungan:

func NewMySQLPool(connector func() (*sql.DB, error)) *MySQLPool {
    return &MySQLPool{
        pool: &sync.Pool{
            New: func() interface{} {
                db, err := connector()
                if err != nil {
                    panic(err)
                }
                return db
            },
        },
        connector: connector,
    }
}

Dalam kod di atas, kami menggunakan fungsi NewMySQLPool untuk memulakan kumpulan sambungan. Parameternya ialah penyambung fungsi, digunakan untuk menyambung ke pangkalan data.

Kami mencipta objek penyegerakan.Kolam, dan medan Baharunya ialah fungsi yang digunakan untuk membuat sambungan baharu. Dalam fungsi ini, kami memanggil fungsi penyambung untuk menyambung ke pangkalan data dan mengembalikan sambungan. Jika sambungan gagal, kami akan membuang pengecualian panik.

Perlu diingatkan di sini bahawa kami tidak mengehadkan saiz kolam sambungan. Dalam bahasa Pergi, saiz penyegerakan.Kolam dilaraskan secara automatik. Apabila terdapat terlalu banyak objek dalam Pool, Pool akan mengurangkan bilangan objek secara dinamik untuk memastikan bilangan objek dalam pool adalah kecil. Oleh itu, kami tidak perlu mengawal saiz kolam sambungan secara manual.

2. Dapatkan sambungan

Selepas permulaan kumpulan sambungan selesai, kita boleh menggunakan sambungan pangkalan data. Kami menggunakan fungsi Dapatkan untuk mendapatkan sambungan. Fungsi

func (p *MySQLPool) Get() *sql.DB {
    return p.pool.Get().(*sql.DB)
}

Get mengembalikan objek sql.DB. Kami menggunakan penegasan jenis antara muka untuk menukar objek jenis antara muka{} kepada objek jenis sql.DB.

Sebelum mendapatkan sambungan, kami perlu memastikan bahawa kumpulan sambungan pangkalan data telah dimulakan. Kita boleh memanggil fungsi NewMySQLPool dalam fungsi utama untuk memulakan kumpulan sambungan.

func main() {
    pool := NewMySQLPool(func() (*sql.DB, error) {
        return sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
    })
    defer db.Close()
}

Dalam kod di atas, kami menggunakan fungsi NewMySQLPool untuk memulakan kumpulan sambungan. Kami akan menyambung ke pangkalan data MySQL dengan nama pengguna pengguna, kata laluan kata laluan, alamat 127.0.0.1, port 3306 dan nama pangkalan data dbname. Kita boleh meletakkan rentetan ini dalam fail konfigurasi untuk meningkatkan kebolehselenggaraan kod.

Apabila kumpulan sambungan pangkalan data dimulakan, kita boleh menggunakan fungsi Dapatkan untuk mendapatkan sambungan.

db := pool.Get()
defer db.Close()

Di sini, kami menggunakan kata kunci tangguh untuk mengembalikan sambungan ke kumpulan sambungan. Dengan cara ini, walaupun pengecualian berlaku semasa melaksanakan pernyataan SQL, sambungan akan dikembalikan dengan betul ke kumpulan sambungan untuk mengelakkan kebocoran sambungan dan pembaziran sumber.

3. Kembalikan sambungan

Selepas sambungan digunakan, kita perlu mengembalikan sambungan ke kolam sambungan. Kami menggunakan fungsi Put untuk mengembalikan sambungan.

func (p *MySQLPool) Put(db *sql.DB) {
    p.pool.Put(db)
}

Parameter fungsi Put ialah objek jenis *sql.DB, yang meletakkan objek ini kembali ke dalam kumpulan sambungan. Pelaksanaan fungsi ini sangat mudah, kerana sync.Pool disertakan dengan fungsi Put.

Selepas menggunakan sambungan, kami perlu mengembalikan sambungan ke kolam sambungan. Kami boleh menggunakan kata kunci tangguh untuk memastikan sambungan dikembalikan dengan betul.

db := pool.Get()
defer pool.Put(db)

Di sini, kami mula-mula menggunakan fungsi Dapatkan untuk mendapatkan sambungan, dan kemudian secara automatik memanggil fungsi Put di penghujung fungsi untuk mengembalikan sambungan ke kolam sambungan.

4. Ringkasan

Artikel ini memperkenalkan cara mudah untuk melaksanakan pengumpulan sambungan pangkalan data menggunakan bahasa Go. Kami menggunakan sync.Pool untuk melaksanakan kumpulan sambungan, gunakan fungsi Dapatkan untuk mendapatkan sambungan dan fungsi Put untuk mengembalikan sambungan. Pelaksanaan ini sangat mudah, mempunyai jumlah kod yang kecil, dan juga sangat cekap.

Menggunakan kumpulan sambungan pangkalan data boleh meningkatkan kecekapan operasi pangkalan data dan mengurangkan penggunaan sumber. Dalam bahasa Go, sangat mudah untuk melaksanakan pengumpulan sambungan dengan mudah menggunakan penyegerakan.Pool. Kami berharap artikel ini dapat membantu anda memahami dengan lebih baik dan menggunakan teknologi pengumpulan sambungan dalam bahasa Go.

Atas ialah kandungan terperinci Laksanakan kumpulan sambungan pangkalan data dengan mudah menggunakan bahasa Go. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!