pertanyaan transaksi golang

Dengan pembangunan berterusan Internet dan Internet mudah alih, pemprosesan data telah menjadi bahagian penting dalam operasi perniagaan perusahaan. Untuk memastikan integriti dan konsistensi data, banyak syarikat menggunakan teknologi transaksi untuk mengurus operasi data. Dalam artikel ini, kami akan meneroka cara melaksanakan pertanyaan transaksi di Golang.

1. Apakah pertanyaan transaksi

Dalam pangkalan data, urus niaga merujuk kepada satu siri operasi, yang dianggap sebagai keseluruhan operasi ini sama ada dilaksanakan dengan jayanya atau semuanya gagal bukanlah pelaksanaan alternatif kejayaan dan kegagalan. Transaksi adalah untuk memastikan integriti dan konsistensi pangkalan data.

Transaksi mengandungi empat atribut asas (ACID):

1 Atomicity: Semua operasi dalam transaksi sama ada semuanya berjaya atau semua gagal, tanpa keadaan perantaraan.

2. Ketekalan: Sebelum dan selepas pelaksanaan transaksi, integriti dan konsistensi pangkalan data terjamin, dan kekangan data (seperti kunci utama, kunci asing, dll.) dikekalkan.

3. Pengasingan: Apabila mengakses urus niaga secara serentak, setiap transaksi hendaklah bebas dan tidak mengganggu satu sama lain.

4 Ketahanan: Setelah transaksi dilakukan, perubahan akan disimpan secara kekal dalam pangkalan data dan tidak akan hilang walaupun terdapat kegagalan sistem atau masa henti.

2. Pertanyaan transaksi Golang

Di Golang, gunakan pemacu pangkalan data untuk melaksanakan pertanyaan transaksi. Golang menyokong pelbagai pemacu pangkalan data, termasuk MySQL, PostgreSQL, Oracle, dll.

Mari kita ambil MySQL sebagai contoh untuk memperkenalkan cara melaksanakan pertanyaan transaksi di Golang.

1. Sambung ke pangkalan data

Pertama, kita perlu mewujudkan sambungan pangkalan data. Di Golang, kita boleh menggunakan pakej database/sql untuk menyambung ke pangkalan data MySQL seperti yang ditunjukkan di bawah:

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

func main() {
    db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close()
}

Di sini, kami menggunakan fungsi sql.Open() untuk membuka sambungan MySQL. Fungsi sql.Open() menerima dua parameter: parameter pertama ialah nama pemacu MySQL (dalam kes ini mysql), dan parameter kedua ialah rentetan sambungan MySQL, yang merangkumi nama pengguna, kata laluan, alamat hos dan port nombor pangkalan data dan nama pangkalan data.

2. Buat transaksi

Dalam MySQL, anda boleh menggunakan pernyataan BEGIN untuk memulakan transaksi. Untuk menggunakan transaksi MySQL di Golang, kita perlu menggunakan fungsi db.Begin() untuk memulakan transaksi.

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

Di sini, fungsi db.Begin() akan mengembalikan objek transaksi. Jika ralat berlaku, ralat dikembalikan.

3. Laksanakan operasi transaksi

Melaksanakan penyata SQL dalam transaksi adalah sama seperti melaksanakan penyata SQL secara individu. Adalah penting untuk ambil perhatian bahawa setiap pernyataan SQL yang dilaksanakan dalam urus niaga akan dipengaruhi oleh urus niaga tersebut.

// 执行事务操作
_, err = tx.Exec("UPDATE users SET name = ? WHERE id = ?", "Alice", 1)
if err != nil {
    tx.Rollback()
    log.Fatal(err)
}

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

Di sini, kami menggunakan fungsi tx.Exec() untuk melaksanakan pernyataan SQL. Jika ralat berlaku, gunakan fungsi tx.Rollback() untuk membuat asal transaksi. Jika semua operasi berjaya dilaksanakan, transaksi dilakukan menggunakan fungsi tx.Commit().

4. Mengendalikan akses serentak

Dalam transaksi, jika berbilang pengguna mengakses jadual data yang sama pada masa yang sama, keadaan perlumbaan mungkin berlaku. Untuk mengelakkan situasi ini, kita perlu menggunakan mekanisme kunci MySQL untuk mengendalikan akses serentak.

MySQL menyediakan dua jenis kunci: Kunci Dikongsi dan Kunci Eksklusif. Kunci yang dikongsi membolehkan berbilang pengguna melihat data pada masa yang sama, tetapi tidak membenarkan mereka mengubah suai data. Kunci eksklusif membolehkan pengguna memiliki data secara eksklusif semasa tempoh kunci, dan pengguna lain tidak boleh membaca atau mengubah suai data.

Di Golang, kita boleh menggunakan fungsi tx.Exec() untuk menambah pilihan SELECT atau FOR SHARE untuk menetapkan jenis kunci apabila melaksanakan pernyataan FOR UPDATE.

// 查询数据并设置共享锁
rows, err := tx.Query("SELECT * FROM users WHERE id = ? FOR SHARE", 1)
if err != nil {
    tx.Rollback()
    log.Fatal(err)
}
defer rows.Close()

// 查询数据并设置排它锁
rows, err := tx.Query("SELECT * FROM users WHERE id = ? FOR UPDATE", 1)
if err != nil {
    tx.Rollback()
    log.Fatal(err)
}
defer rows.Close()

Di sini, kami menggunakan fungsi tx.Query() untuk melaksanakan pernyataan SELECT dan menetapkan jenis kunci. Ambil perhatian bahawa fungsi tx.Query() mesti digunakan semasa melaksanakan pernyataan pertanyaan dalam transaksi. (Jika anda menggunakan fungsi db.Query(), hasil pertanyaan tidak akan terjejas oleh transaksi)

5 Balik urus niaga

Jika ralat berlaku dalam transaksi, kami perlu menggunakan tx.Rollback() berfungsi untuk membuat asal transaksi dan kembali ke keadaan sebelum memulakan transaksi.

// 执行事务操作
_, err = tx.Exec("UPDATE users SET name = ? WHERE id = ?", "Alice", 1)
if err != nil {
    tx.Rollback()
    log.Fatal(err)
}

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

Di sini, jika fungsi tx.Exec() mengembalikan ralat, fungsi tx.Rollack() digunakan untuk melancarkan transaksi.

6. Contoh kod lengkap

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

func main() {
    // 建立数据库连接
    db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close()

    // 开始事务
    tx, err := db.Begin()
    if err != nil {
        log.Fatal(err)
    }

    // 查询数据并设置锁类型
    rows, err := tx.Query("SELECT * FROM users WHERE id = ? FOR UPDATE", 1)
    if err != nil {
        tx.Rollback()
        log.Fatal(err)
    }
    defer rows.Close()

    // 执行事务操作
    _, err = tx.Exec("UPDATE users SET name = ? WHERE id = ?", "Alice", 1)
    if err != nil {
        tx.Rollback()
        log.Fatal(err)
    }

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

Di atas ialah cara melaksanakan pertanyaan transaksi di Golang. Penggunaan teknologi transaksi dapat memastikan integriti dan konsistensi data secara berkesan, yang sangat penting untuk perusahaan memproses operasi data.

Atas ialah kandungan terperinci pertanyaan transaksi golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!