Maison >développement back-end >Golang >Comment exploiter les données MySQL dans Golang

Comment exploiter les données MySQL dans Golang

PHPz
PHPzoriginal
2023-03-22 14:23:561675parcourir

Dans le génie logiciel moderne, les compétences requises pour créer des applications serveur efficaces et fiables sont très demandées. Parmi eux, l'utilisation du langage Go pour appeler une base de données relationnelle est une base indispensable. Dans cet article, nous utiliserons les packages standards du langage Go pour interroger et insérer des données MySQL.

Qu'est-ce que MySQL

MySQL est un système de gestion de bases de données relationnelles largement utilisé dans l'infrastructure Internet, développé sous le parrainage d'Oracle Corporation. Il prend en charge plusieurs systèmes d'exploitation et langages de programmation, y compris le langage Go, et dispose d'une série de fonctionnalités prenant en charge l'intégration de données volumineuses et les requêtes hautes performances.

Les données MySQL sont basées sur des tables. Une ligne de données correspond à un enregistrement et une colonne de données correspond à un champ. Il utilise le langage SQL pour opérer sur les données, les opérations SQL les plus courantes incluent SELECT, INSERT, UPDATE, DELETE et CREATE TABLE.

Pilote MySQL en langage Go

En langage Go, nous pouvons utiliser un pilote MySQL tiers pour nous connecter et interroger la base de données MySQL. Cependant, la bibliothèque standard du langage GO contient déjà le package database/sql, qui a implémenté l'interface de base de données SQL standard et peut interagir avec d'autres bases de données SQL pratiques et populaires, notamment MySQL, PostgreSQL et SQLite, etc. database/sql 包,这个包已经实现了标准的 SQL 数据库接口,可以和其他方便的流行的 SQL 数据库交互操作,包括 MySQL、PostgreSQL 和 SQLite 等。

因此,在我们开始构建查询 MySQL 的 Go 应用程序之前,我们需要安装 MySql 驱动程序。可以使用命令行命令 go get -u github.com/go-sql-driver/mysql 快捷安装。

这是因为在 Go 语言中,所有的数据访问都需通过 SQL.DB 连接进行。并且驱动程序的目的是用来实现 database/sql 的功能中那样的的接口约定。

建立连接

在 Go 语言中,建立到 MySQL 数据库的连接是基于连接字符串的,连接字符串包含连接 MySQL 所需的所有参数,如用户名、密码、主机名或 IP 地址、端口号和数据库名称等。

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

查询数据

在 Go 语言中,可以使用 db.Query()db.QueryRow()db.Exec() 函数查询和操作 MySQL 数据库中的数据。

db.Query() 函数用于查询多条记录,返回一个 *sql.Rows 对象。db.QueryRow() 函数用于查询单条记录,返回一个 *sql.Row 对象,类似于 resultset,但是它只返回第一行记录,通常用于查询单个唯一记录。db.Exec() 函数用于执行非查询 SQL 语句,例如 INSERT、UPDATE 和 DELETE,返回一个 sql.Result 对象。

在本例中,我们使用 db.Query() 函数来查询所有记录。我们将使用一个简单的计数器来统计记录的数量,并将每行数据打印到控制台。

rows, err := db.Query("SELECT id, name FROM users")
if err != nil {
    log.Fatal(err)
}
defer rows.Close()

count := 0
for rows.Next() {
    var id int
    var name string
    if err := rows.Scan(&id, &name); err != nil {
        log.Fatal(err)
    }
    fmt.Printf("id=%d, name=%s\n", id, name)
    count++
}
if err := rows.Err(); err != nil {
    log.Fatal(err)
}

fmt.Printf("Found %d users\n", count)

必须在检索数据后调用 rows.Close() 函数以释放与 *sql.Rows 关联的数据库资源。同时,代码中使用了 rows.Next() 函数,它返回一个布尔值,指示是否还有更多的行可以进行处理。另外,在这个例子中使用了 rows.Scan() 函数将每行记录的值复制到这个例子中定义的 idname 变量中,然后在控制台中打印每个值。

插入数据

我们也可以使用 Go 语言插入数据到 MySQL 数据库中,最简单的方法使用 db.Exec() 函数。我们可以将插入语句传递到 db.Exec() 函数中,它将以 SQL 语句的形式在 MySQL 中执行。

result, err := db.Exec("INSERT INTO users(name, email) VALUES('John Doe', 'johndoe@gmail.com')")
if err != nil {
    log.Fatal(err)
}

rowsAffected, err := result.RowsAffected()
if err != nil {
    log.Fatal(err)
}
fmt.Printf("Inserted %d rows into users table\n", rowsAffected)

我们可以使用 result.RowsAffected() 获取结果集中受影响的行数,并使用该数值在控制台中打印更新数据的数量。

总结

在本文中,我们介绍了使用 Go 语言进行 MySQL 数据库的基础查询操作。我们了解了如何使用标准库 database/sql 和第三方 MySQL 驱动程序,建立连接并查询数据。我们还了解了如何插入数据,使用 db.Exec()

Donc, avant de commencer à créer une application Go qui interroge MySQL, nous devons installer le pilote MySql. Vous pouvez utiliser la commande de ligne de commande go get -u github.com/go-sql-driver/mysql pour une installation rapide. 🎜🎜En effet, dans le langage Go, tous les accès aux données doivent être effectués via une connexion SQL.DB. Et le but du pilote est d'implémenter les conventions d'interface dans les fonctions de database/sql. 🎜🎜🎜Établir une connexion🎜🎜🎜Dans le langage Go, l'établissement d'une connexion à la base de données MySQL est basé sur la chaîne de connexion. La chaîne de connexion contient tous les paramètres requis pour se connecter à MySQL, tels que le nom d'utilisateur, le mot de passe, le nom d'hôte. ou adresse IP, numéro de port et nom de la base de données, etc. 🎜rrreee🎜🎜Requête de données🎜🎜🎜En langage Go, vous pouvez utiliser db.Query(), db.QueryRow() et db.Exec() Fonctions pour interroger et manipuler les données dans la base de données MySQL. La fonction 🎜🎜db.Query() est utilisée pour interroger plusieurs enregistrements et renvoie un objet *sql.Rows. La fonction db.QueryRow() est utilisée pour interroger un seul enregistrement et renvoie un objet *sql.Row, similaire à resultset, mais il renvoie uniquement la première ligne A d'enregistrements, généralement utilisée pour interroger un seul enregistrement unique. La fonction db.Exec() exécute des instructions SQL sans requête telles que INSERT, UPDATE et DELETE, renvoyant un objet sql.Result. 🎜🎜Dans cet exemple, nous utilisons la fonction db.Query() pour interroger tous les enregistrements. Nous utiliserons un simple compteur pour compter le nombre d'enregistrements et imprimerons chaque ligne de données sur la console. 🎜rrreee🎜La fonction rows.Close() doit être appelée après avoir récupéré les données pour libérer les ressources de la base de données associées à *sql.Rows. De plus, le code utilise la fonction rows.Next(), qui renvoie une valeur booléenne indiquant si d'autres lignes peuvent être traitées. De plus, la fonction rows.Scan() est utilisée dans cet exemple pour copier la valeur de chaque enregistrement de ligne dans le id et le name définis. dans cet exemple > variable et imprimez chaque valeur dans la console. 🎜🎜🎜Insérer des données🎜🎜🎜Nous pouvons également utiliser le langage Go pour insérer des données dans la base de données MySQL. Le moyen le plus simple est d'utiliser la fonction db.Exec(). Nous pouvons passer l'instruction insert dans la fonction db.Exec() et elle sera exécutée dans MySQL en tant qu'instruction SQL. 🎜rrreee🎜Nous pouvons utiliser result.RowsAffected() pour obtenir le nombre de lignes affectées dans l'ensemble de résultats et utiliser cette valeur pour imprimer le nombre de données mises à jour dans la console. 🎜🎜🎜Résumé🎜🎜🎜Dans cet article, nous avons présenté les opérations de requête de base de la base de données MySQL à l'aide du langage Go. Nous avons appris à utiliser la bibliothèque standard database/sql et les pilotes MySQL tiers pour établir des connexions et interroger des données. Nous avons également appris à insérer des données dans une base de données MySQL à l'aide de la fonction db.Exec(). Ces concepts jouent un rôle important dans la création d'applications serveur efficaces et fiables dans Go et constituent une compétence essentielle dans l'ingénierie logicielle moderne. 🎜

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!

Déclaration:
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn