Langage Go et base de données MySQL : comment effectuer des transactions de données ?

De nos jours, les applications Internet doivent traiter des données. Vous pouvez rencontrer les situations suivantes lors du traitement des données :

1. Vous souhaitez insérer un enregistrement, mais l'une des colonnes ne répond pas aux exigences, ou la base de données sera incohérente après l'insertion.
2. Effectuez une série d'opérations. Si une erreur se produit dans l'une d'entre elles, toutes les opérations précédentes doivent être annulées.
3. Plusieurs utilisateurs effectuent la même opération en même temps. Sans contrôle, des lectures sales et des lectures non répétables sont susceptibles de se produire.

À ce stade, nous devons effectuer le traitement des transactions pour garantir que la base de données peut maintenir l'intégrité et la cohérence des données. Voyons comment effectuer le traitement des transactions sur la base de données MySQL dans le langage Go.

1. Connectez-vous à la base de données

Lorsque vous utilisez le langage Go pour le traitement des transactions de la base de données MySQL, vous devez d'abord établir une connexion avec la base de données MySQL. On peut utiliser le package "database/sql" pour se connecter, le code spécifique est le suivant :

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 {
        fmt.Printf("连接数据库错误: ", err)
    }
    defer db.Close()
}

Parmi eux, "root" représente le nom d'utilisateur MySQL, "password" représente le mot de passe MySQL, " 127.0.0.1:3306 " est l'adresse IP et le numéro de port de MySQL, et " nom_base de données " est le nom de la base de données connectée.

2. Start Transaction

Après avoir terminé la connexion à la base de données via le code ci-dessus, nous devons démarrer une nouvelle transaction. Pour démarrer une nouvelle transaction, nous pouvons utiliser la méthode db.Begin(), comme suit :

tx, err := db.Begin()
if err != nil {
    fmt.Println("开始事务错误: ", err)
}

Ce code renverra un objet de transaction de type Tx, que nous pourrons utiliser pour effectuer une opération de restauration.

3. Exécuter des instructions SQL

Lorsque nous devons effectuer des opérations SQL efficaces, nous pouvons exécuter les instructions SQL correspondantes via tx.Exec() méthode , comme indiqué ci-dessous :

result, err := tx.Exec("INSERT INTO users (name, age, sex) values (?, ?, ?)", "张三", 18, "男")
if err != nil {
    fmt.Println("插入错误: ", err)
    tx.Rollback()
}

Où, ? Il s'agit d'un espace réservé et sera remplacé par la valeur lors d'une exécution spécifique. Grâce à l'objet résultat renvoyé par la méthode tx.Exec(), vous pouvez obtenir le nombre de lignes affectées par l'opération, l'ID d'auto-incrémentation et d'autres informations.

4. Submit transaction

Selon le code ci-dessus, nous avons effectué une gestion des erreurs lors de l'exécution de l'instruction SQL. Si une erreur se produit, nous en avons besoin. pour retourner la transaction Roll. Une fois l'opération de transaction terminée, nous devons soumettre la transaction via la méthode tx.Commit(), comme indiqué ci-dessous :

if err := tx.Commit(); err != nil {
    fmt.Println("提交事务错误: ", err)
    tx.Rollback()
}

Lors de la soumission de la transaction via la méthode tx.Commit(), si le la soumission échoue, une opération de restauration est nécessaire pour maintenir l’intégrité et la cohérence des données.

5. Summary

Grâce aux étapes ci-dessus, nous pouvons conclure que l'utilisation du langage Go pour le traitement des transactions de la base de données MySQL. Parmi elles, des opérations telles que l'établissement d'une connexion avec MySQL, le démarrage d'une transaction, l'exécution d'instructions SQL et la soumission de transactions sont nécessaires pour garantir l'intégrité et la cohérence des données.

Ce qui précède est un article sur le traitement des transactions de données entre le langage Go et la base de données MySQL, montrant les principales étapes et méthodes. J'espère que cet article pourra vous être utile dans le traitement des transactions de la base de données MySQL en langage Go.

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!