Cara melaksanakan operasi ACID dalam pangkalan data MySQL menggunakan bahasa Go

Dengan perkembangan pesat Internet dan pendigitalan, pembentukan dan pemprosesan pelbagai data besar telah menjadi salah satu perkara yang paling penting pada masa ini. Dalam pemprosesan data, pangkalan data hubungan memainkan peranan penting. Sebagai salah satu pangkalan data hubungan yang paling popular pada masa ini, MySQL sering digunakan dalam pemprosesan data besar. ACID (Atomicity, Consistency, Isolation, Durability) ialah ciri pemprosesan transaksi yang paling asas dalam pangkalan data hubungan, dan ia juga merupakan prinsip yang mesti dipatuhi apabila melakukan sebarang operasi pada data. Artikel ini akan memperkenalkan cara menggunakan bahasa Go untuk melaksanakan operasi ACID dalam pangkalan data MySQL.

1. Pemasangan pakej yang diperlukan

Sebelum mula menggunakan bahasa Go untuk operasi pangkalan data MySQL, kami perlu memasang beberapa pakej yang diperlukan. Yang paling biasa ialah pemacu mysql, yang boleh dipasang menggunakan arahan berikut

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

Jika anda menggunakan rangka kerja Gorm untuk pembangunan MySQL, anda perlu memasang pakej berikut

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

2. Sambung ke pangkalan data

Sebelum menggunakan bahasa Go untuk operasi pangkalan data MySQL, kita perlu menyambung ke pangkalan data MySQL. Berikut ialah contoh kod untuk menyambung ke pangkalan data MySQL.

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

func main(){
    db, err := sql.Open("mysql", "root:password@tcp(127.0.0.1:3306)/database_name")
    if err != nil {
        panic(err.Error())
    }
}

Ini ialah contoh kod sambungan asas. Antaranya, mysql ialah nama pemacu: kata laluan ialah nama pengguna dan kata laluan 127.0.0.1:3306 ialah alamat pelayan dan nombor port adalah nama pangkalan data yang akan disambungkan; Apabila menggunakan proses sambungan, anda juga perlu menggunakan beberapa parameter lain, seperti tamat masa sambungan, dsb. Parameter khusus boleh diubah dengan merujuk kepada dokumentasi yang berkaitan.

3. Operasi transaksi

Operasi transaksi merujuk kepada siri operasi dalam pangkalan data, yang akan digunakan pada pangkalan data hanya selepas semuanya berjaya dilaksanakan. Dalam Go, anda boleh menggunakan Tx pakej sql untuk melaksanakan operasi transaksi. Berikut ialah contoh operasi transaksi asas.

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

func main(){
    db, err := sql.Open("mysql", "root:password@tcp(127.0.0.1:3306)/database_name")
    if err != nil {
        panic(err.Error())
    }

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

    _, err = tx.Exec("INSERT INTO table_name (column1, column2) VALUES (?, ?)", value1, value2)
    if err != nil {
        fmt.Println(err)
        tx.Rollback()
    } else {
        _, err = tx.Exec("UPDATE table_name SET column1 = ? WHERE column2 = ?", value1, value2)
        if err != nil {
            fmt.Println(err)
            tx.Rollback()
        } else {
            tx.Commit()
        }
    }
}

Ini ialah contoh operasi transaksi asas. Dua operasi dilakukan dalam program ini: yang pertama adalah untuk memasukkan data, dan yang kedua adalah untuk mengemas kini data. Jika kedua-dua operasi dilaksanakan dengan jayanya, transaksi itu dilakukan. Jika salah satu operasi gagal, transaksi akan dibatalkan dan semua perubahan akan dibuat asal.

4. Tahap pengasingan

Apabila melakukan operasi transaksi, kita perlu mempertimbangkan tahap pengasingan. MySQL membahagikan tahap pengasingan kepada empat peringkat: baca tanpa komitmen (baca tanpa komitmen), baca komited (komit baca), baca berulang (baca berulang) dan boleh bersiri (boleh bersiri). Tahap pengasingan yang digunakan secara lalai ialah Bacaan Boleh Diulang. Apabila kami menggunakan transaksi, kami boleh menggunakan kaedah DB.Transaction() untuk menentukan tahap pengasingan. Berikut ialah contoh:

func main() {
    db, err := sql.Open("mysql", "root:password@tcp(127.0.0.1:3306)/database_name")
    if err != nil {
        panic(err.Error())
    }

    txOptions := &sql.TxOptions{
        Isolation: sql.LevelSerializable,
    }
    tx, err := db.BeginTx(context.Background(), txOptions)
    if err != nil {
        panic(err.Error())
    }
}

Dalam contoh ini, kami telah memilih tahap pengasingan tahap Boleh Bersiri. Jika anda perlu mengubah suai tahap pengasingan, cuma tukar LevelSerializable.

5. Ringkasan

Dalam artikel ini, kami memperkenalkan cara menggunakan bahasa Go untuk melaksanakan operasi ACID dalam pangkalan data MySQL, termasuk menyambung ke pangkalan data, operasi transaksi dan tahap pengasingan. Untuk memastikan ketepatan kod, kita mesti mengikut garis panduan ACID untuk memastikan data disimpan dengan betul apabila keadaan tidak normal berlaku. Pada masa yang sama, kita juga mesti belajar cara menggunakan tahap pengasingan untuk menentukan ketekalan dan kebolehpercayaan pangkalan data.

Atas ialah kandungan terperinci Cara melaksanakan operasi ACID dalam pangkalan data MySQL menggunakan bahasa Go. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!