Comment effectuer des opérations ACID dans la base de données MySQL en utilisant le langage Go

Avec le développement rapide d'Internet et de la numérisation, la formation et le traitement de divers big data sont devenus l'une des choses les plus importantes du moment. Dans le traitement des données, les bases de données relationnelles jouent un rôle important. En tant que l'une des bases de données relationnelles les plus populaires actuellement, MySQL est souvent utilisée dans le traitement du Big Data. ACID (Atomicité, Cohérence, Isolation, Durabilité) est la fonctionnalité de traitement des transactions la plus élémentaire dans les bases de données relationnelles, et c'est également le principe qui doit être suivi lors de toute opération sur les données. Cet article explique comment utiliser le langage Go pour effectuer des opérations ACID dans la base de données MySQL.

1. Packages requis pour l'installation

Avant de commencer à utiliser le langage Go pour les opérations de base de données MySQL, nous devons installer certains packages nécessaires. Le plus courant est le pilote mysql, qui peut être installé à l'aide de la commande suivante

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

Si vous utilisez le framework Gorm pour le développement MySQL, vous devez installer les packages suivants

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

#🎜 🎜# 2. Connectez-vous à la base de données

Avant d'utiliser le langage Go pour effectuer des opérations sur la base de données MySQL, nous devons nous connecter à la base de données MySQL. Ce qui suit est un exemple de code pour se connecter à la base de données 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())
    }
}

Ceci est l'exemple de code de connexion le plus basique. Parmi eux, mysql est le nom du pilote ; root:password est le nom d'utilisateur et le mot de passe ; 127.0.0.1:3306 est l'adresse du serveur et le numéro de port est le nom de la base de données à connecter. Lorsque vous utilisez le processus de connexion, vous devez également utiliser d'autres paramètres, tels que le délai d'expiration de la connexion, etc. Des paramètres spécifiques peuvent être modifiés en consultant la documentation correspondante.

3. Opération de transaction

L'opération de transaction fait référence à une série d'opérations dans la base de données, qui ne seront appliquées à la base de données qu'une fois qu'elles auront toutes été exécutées avec succès. Dans Go, vous pouvez utiliser le Tx du package SQL pour effectuer des opérations de transaction. Ce qui suit est un exemple d’opération de transaction de base.

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()
        }
    }
}

Ceci est un exemple d'opération de transaction de base. Deux opérations sont effectuées dans ce programme : la première consiste à insérer des données et la seconde à mettre à jour les données. Si les deux opérations s'exécutent avec succès, la transaction est validée. Si l'une des opérations échoue, la transaction sera annulée et toutes les modifications seront annulées.

4. Niveau d'isolement

Lors de l'exécution d'opérations de transaction, nous devons prendre en compte le niveau d'isolement. MySQL divise le niveau d'isolement en quatre niveaux : lecture non validée (lecture non validée), lecture validée (lecture validée), lecture répétable (lecture répétable) et sérialisable (sérialisable). Le niveau d'isolement utilisé par défaut est Lecture répétable. Lorsque nous utilisons des transactions, nous pouvons utiliser la méthode DB.Transaction() pour spécifier le niveau d'isolement. Voici un exemple :

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())
    }
}

Dans cet exemple, nous avons sélectionné le niveau d'isolement de niveau Serialisable. Si vous devez modifier le niveau d'isolement, modifiez simplement LevelSeriallessly.

5. Résumé

Dans cet article, nous expliquons comment utiliser le langage Go pour effectuer des opérations ACID dans la base de données MySQL, y compris la connexion à la base de données, les opérations de transaction et l'isolation. niveaux. Afin de garantir l'exactitude du code, nous devons suivre les directives de l'ACID pour garantir que les données sont correctement enregistrées lorsque des conditions anormales se produisent. Parallèlement, nous devons également apprendre à utiliser les niveaux d’isolement pour déterminer la cohérence et la fiabilité de la base de données.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!