Cara mengendalikan transaksi golang

Bahasa Go (golang) ialah bahasa yang disusun pada asalnya dibangunkan oleh Google dan mula diperkenalkan pada tahun 2009. Ia direka untuk meningkatkan produktiviti dan kebolehselenggaraan pengaturcara serta cuba menyediakan penyelesaian yang boleh dipercayai dari segi kod yang mudah ditulis dan difahami. Apabila menggunakan golang untuk pemprosesan pangkalan data, pemprosesan transaksi tidak dapat dielakkan. Artikel ini akan meneroka cara mengendalikan transaksi golang.

1. Apakah pemprosesan transaksi?

Transaksi ialah urutan operasi yang sama ada semua dilaksanakan atau tiada satu pun dilaksanakan. Penggunaan urus niaga yang paling biasa adalah untuk memproses operasi baca dan tulis data, seperti menyoal data daripada jadual, mengemas kini data atau melakukan operasi pemadaman. Urus niaga boleh memastikan bahawa satu siri operasi yang berkaitan diselesaikan bersama-sama Jika salah satu operasi gagal, keseluruhan urus niaga akan dikembalikan kepada keadaan asal. Ini bermakna selepas kegagalan, semua operasi yang dilakukan akan dibatalkan dan struktur akan kekal konsisten, sekali gus memastikan integriti data.

Dalam pangkalan data, transaksi boleh dilihat sebagai unit operasi logik. Transaksi boleh melibatkan satu atau lebih operasi pangkalan data, dan status operasi dijejaki untuk memastikan semua operasi selesai dengan jayanya.

2. Cara golang menggunakan transaksi

Dalam golang, memproses transaksi memerlukan penggunaan Begin(), Commit(), Rollback() dan fungsi lain dalam pangkalan data/pakej SQL. Fungsi ini menguruskan transaksi dalam pangkalan data. Di bawah ini kami akan memperkenalkan fungsi ini satu persatu.

1. Begin()

Fungsi Begin() digunakan untuk memulakan transaksi baharu dan ia mengembalikan objek Tx. Jika ralat berlaku semasa memulakan transaksi baharu, ralat yang sesuai akan dikembalikan.

Kod contoh:

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

2. Commit()

Fungsi Commit() digunakan untuk melakukan transaksi. Jika ralat berlaku semasa transaksi, operasi transaksi komit akan dibuat asal.

Kod sampel:

err := tx.Commit()
if err != nil {
    log.Fatal(err)
}

3. Rollback()

Fungsi Rollback() digunakan untuk melancarkan transaksi semasa proses transaksi. Jika ralat berlaku semasa melancarkan semula, operasi akan dibuat asal.

Kod sampel:

err := tx.Rollback()
if err != nil {
    log.Fatal(err)
}

4. Exec()

Fungsi Exec() digunakan untuk melaksanakan pernyataan SQL. Jika pernyataan SQL berjaya dilaksanakan, objek Hasil akan dikembalikan. Jika pernyataan SQL gagal dilaksanakan, ralat yang sepadan akan dikembalikan.

Kod sampel:

result, err := tx.Exec("INSERT INTO users (id, name) VALUES (?, ?)", 1, "John")
if err != nil {
    log.Fatal(err)
}

5. Prepare()

Prepare() function digunakan untuk menyediakan pernyataan SQL, ia akan mengembalikan Stmt objek . Fungsi ini biasanya digunakan apabila melaksanakan berbilang pernyataan SQL yang serupa, seperti dalam transaksi.

Kod sampel:

stmt, err := tx.Prepare("INSERT INTO users (id, name) VALUES (?, ?)")
if err != nil {
    log.Fatal(err)
}

6. Stmt.Exec()

Fungsi Stmt.Exec() digunakan untuk melaksanakan Penyata SQL yang disediakan , yang boleh menerima parameter semasa pelaksanaan. Jika pernyataan SQL berjaya dilaksanakan, objek Hasil akan dikembalikan. Jika pernyataan SQL gagal dilaksanakan, ralat yang sepadan akan dikembalikan.

Kod sampel:

result, err := stmt.Exec(1, "John")
if err != nil {
    log.Fatal(err)
}

3. Kod sampel

Kod contoh berikut menunjukkan cara menggunakan golang untuk mengendalikan transaksi pangkalan data.

package main

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

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

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

    // 准备SQL语句
    stmt, err := tx.Prepare("INSERT INTO users (id, name) VALUES (?, ?)")
    if err != nil {
        log.Fatal(err)
    }

    // 执行SQL语句
    _, err = stmt.Exec(1, "John")
    if err != nil {
        // 回滚事务
        tx.Rollback()
        log.Fatal(err)
    }

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

    // 查询结果
    rows, err := db.Query("SELECT id, name FROM users")
    if err != nil {
        log.Fatal(err)
    }

    // 处理查询结果
    for rows.Next() {
        var id int
        var name string
        err = rows.Scan(&id, &name)
        if err != nil {
            log.Fatal(err)
        }
        fmt.Printf("id:%d, name:%s\n", id, name)
    }
    rows.Close()
}

4 Ringkasan

Untuk memproses transaksi dalam golang, anda perlu menggunakan fungsi seperti Begin(), Commit(), Rollback(), Exec() dan Prepare() . Dengan menggunakan fungsi ini, transaksi dalam pangkalan data boleh diuruskan dengan cekap. Apabila menulis aplikasi Golang, pemprosesan transaksi adalah masalah yang tidak dapat dielakkan Hanya melalui pemprosesan transaksi yang munasabah dapat memastikan ketepatan dan integriti data.

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