Bagaimana untuk mengekstrak data daripada pangkalan data MySQL menggunakan bahasa Go

MySQL ialah pangkalan data hubungan yang sangat popular, dan bahasa Go ialah bahasa pengaturcaraan yang berkembang pesat Jika anda menggabungkan kedua-duanya, anda boleh mencapai pengekstrakan data yang mudah dan cekap. Artikel ini akan memperkenalkan kaedah menggunakan bahasa Go untuk mengekstrak data MySQL Saya harap ia dapat memberi inspirasi dan membantu semua orang.

1. Pasang dan konfigurasikan pemacu MySQL

Sebelum menggunakan bahasa Go untuk mengekstrak data MySQL, kita perlu memasang pemacu MySQL terlebih dahulu. Terdapat banyak pilihan untuk pemacu MySQL Di sini kami memperkenalkan dua yang paling biasa digunakan: go-sql-driver dan mysql driver.

Untuk memasang menggunakan go-sql-driver, anda boleh menggunakan arahan berikut:

go get -u github.com/go-sql-driver/mysql

Untuk menggunakan pemacu mysql untuk memasang, anda boleh menggunakan arahan berikut:

go get -u github.com/mysql/mysql-go

Selepas pemasangan selesai, Hanya import pakej pemacu yang sepadan dalam kod, sebagai contoh:

import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
)

Walau bagaimanapun, perlu diperhatikan bahawa apabila menggunakan pemacu MySQL, anda juga perlu mengkonfigurasi MySQL secara khusus kaedah adalah seperti berikut:

1. Tetapkan set aksara MySQL kepada utf8mb4

Versi sebelum MySQL 5.7.7 menggunakan set aksara utf8 secara lalai, yang hanya menyokong 3 aksara unicode -byte, manakala dalam versi 7 dan lebih baru, set aksara lalai ialah utf8mb4, yang menyokong aksara unicode 4-bait Anda boleh menetapkan pelayan set aksara dalam fail konfigurasi my.cnf atau my.ini ke utf8mb4 untuk menyokong bahasa Cina, dsb. Kesan aksara khas.

2. Dayakan log binlog

Dalam MySQL, log binlog merekodkan semua pernyataan sql yang beroperasi pada MySQL, jadi apabila mengekstrak data, anda perlu mendayakan log binlog untuk penyegerakan data masa nyata. Ia boleh dikonfigurasikan dan didayakan dalam my.cnf atau my.ini.

2. Sambung ke pangkalan data MySQL

Selepas memasang pemacu MySQL dan mengkonfigurasinya dengan sewajarnya, seterusnya kita perlu menyambung ke pangkalan data MySQL. Kaedah untuk menyambung ke pangkalan data MySQL adalah seperti berikut:

db, err := sql.Open("mysql", "user:password@tcp(ip:port)/database")

Antaranya, pengguna dan kata laluan ialah nama pengguna dan kata laluan MySQL, ip dan port ialah alamat sambungan MySQL dan nombor port, dan pangkalan data adalah pangkalan data. untuk diakses.

Selepas berjaya menyambung ke pangkalan data MySQL, kami boleh melakukan operasi data yang sepadan, seperti membaca data dalam MySQL ke dalam bahasa Go, atau menyimpan data dalam bahasa Go ke dalam MySQL.

3. Pertanyaan pernyataan SQL

Sangat mudah untuk menggunakan pernyataan SQL untuk menanya data dalam MySQL dalam bahasa Go. Kita boleh menggunakan fungsi sql.Query untuk melaksanakan pernyataan pertanyaan dan menyimpan keputusan ke objek baris, seperti:

rows, err := db.Query("SELECT * FROM table1")

Selepas pelaksanaan berjaya, fungsi Seterusnya objek baris boleh digunakan untuk melintasi keputusan , dan satu rekod boleh dikeluarkan setiap kali Dan masukkannya ke dalam objek struct yang sepadan:

type Product struct {
    ID         int64  `db:"id"`
    Name       string `db:"name"`
    Price      int64  `db:"price"`
    CreateTime int64  `db:"create_time"`
}

func main() {
    rows, err := db.Query("SELECT * FROM product")  // 查询product表
    if err != nil {
        panic(err)
    }

    defer rows.Close()

    products := make([]Product, 0)

    for rows.Next() {  // 遍历结果集
        var p Product
        err = rows.Scan(&p.ID, &p.Name, &p.Price, &p.CreateTime)  // 将一条记录封装到Product对象中
        if err != nil {
            panic(err)
        }
        products = append(products, p)
    }
}

Ia juga sangat mudah untuk menggunakan fungsi sql.QueryRow untuk menanyakan satu rekod:

var p Product
err := db.QueryRow("SELECT * FROM product WHERE id=?", 1).Scan(&p.ID, &p.Name, &p.Price, &p.CreateTime)
if err != nil {
    panic(err)
}

4. Masukkan data

gunakan Memasukkan data ke dalam MySQL juga sangat mudah dengan bahasa Go. Kita boleh menggunakan fungsi sql.Exec untuk melaksanakan pernyataan SQL untuk mencapai ini:

stmt, err := db.Prepare("INSERT INTO product(name, price) VALUES(?,?)")
if err != nil {
    panic(err)
}

res, err := stmt.Exec("Product1", 100)
if err != nil {
    panic(err)
}

Fungsi Prepare dalam kod di atas digunakan untuk menyediakan pernyataan SQL, dan kemudian gunakan fungsi Exec untuk melaksanakan pernyataan SQL dan kembalikan hasilnya. Jika pelaksanaan berjaya, hasil yang dikembalikan mengandungi ID data yang dimasukkan (jika ada), yang boleh diperoleh menggunakan fungsi LastInsertId. Jika anda perlu mendapatkan bilangan baris yang terjejas, anda boleh menggunakan fungsi RowsAffected.

5. Kemas kini dan padam data

Serupa dengan memasukkan data, bahasa Go juga boleh menggunakan fungsi sql.Exec untuk melaksanakan pernyataan kemas kini SQL dan memadamkan pernyataan, seperti berikut:

// 执行更新操作
stmt, err := db.Prepare("UPDATE product SET price=? WHERE id=?")
if err != nil {
    panic(err)
}

res, err := stmt.Exec(200, 1)
if err != nil {
    panic(err)
}

// 执行删除操作
stmt, err = db.Prepare("DELETE FROM product WHERE id=?")
if err != nil {
    panic(err)
}

res, err = stmt.Exec(1)
if err != nil {
    panic(err)
}

6. Pengurusan Transaksi

Apabila menjalankan operasi data, kadangkala perlu memastikan keatoman data, iaitu semua operasi pangkalan data sama ada berjaya atau gagal. Pada ketika ini, kita boleh menggunakan mekanisme pengurusan transaksi untuk mencapai matlamat ini.

Dalam bahasa Go, anda boleh menggunakan db.Begin dan tx.Commit untuk membuka dan menyerahkan transaksi, seperti:

tx, err := db.Begin()
if err != nil {
    panic(err)
}

stmt, err := tx.Prepare("INSERT INTO product(name, price) VALUES(?,?)")
if err != nil {
    panic(err)
}

res, err := stmt.Exec("Product1", 100)
if err != nil {
    tx.Rollback()
    panic(err)
}

stmt, err = tx.Prepare("INSERT INTO product(name, price) VALUES(?,?)")
if err != nil {
    panic(err)
}

res, err = stmt.Exec("Product2", 200)
if err != nil {
    tx.Rollback()
    panic(err)
}

// 提交事务
err = tx.Commit()
if err != nil {
    tx.Rollback()
    panic(err)
}

Dalam kod di atas, selepas membuka transaksi, kami boleh melakukan berbilang operasi dalam operasi SQL transaksi. Selepas melaksanakan semua operasi SQL dan memastikan atomicity semua operasi SQL, anda perlu menggunakan fungsi Commit() untuk melakukan transaksi. Jika ralat berlaku dalam mana-mana operasi SQL, anda boleh menggunakan fungsi Rollback() untuk melancarkan transaksi.

7. Kesimpulan

Artikel ini memperkenalkan kaedah menggunakan bahasa Go untuk mengekstrak data daripada pangkalan data MySQL. Melalui pengenalan di atas, kita dapati bahawa menggunakan bahasa Go untuk melaksanakan operasi data pada pangkalan data MySQL adalah sangat mudah dan cekap. Jika anda belum mencuba menggunakan bahasa Go untuk operasi pangkalan data, anda juga boleh mencubanya. Saya percaya anda akan jatuh cinta dengannya.

Atas ialah kandungan terperinci Bagaimana untuk mengekstrak data daripada pangkalan data MySQL menggunakan bahasa Go. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!