Comment Golang exploite les données MySQL

Qu'est-ce que MySQL

MySQL, développé sous le parrainage d'Oracle Corporation, est une relation largement utilisée dans le type d'infrastructure Internet système de gestion de base de données. 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.

MySQL utilise une structure de données basée sur des tables, où chaque ligne représente un enregistrement et chaque colonne représente 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() 函数将每行记录的值复制到这个例子中定义的 id 和 name 变量中，然后在控制台中打印每个值。

插入数据

我们也可以使用 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()

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 se base sur la chaîne de connexion, et la chaîne de connexion contient la connexion à MySQL Tous les paramètres requis tels que le nom d'utilisateur, le mot de passe, le nom d'hôte ou l'adresse IP, le numéro de port, le nom de la base de données, etc. #🎜🎜#rrreee#🎜🎜##🎜🎜#Query data#🎜🎜##🎜🎜##🎜🎜#En langage Go, vous pouvez utiliser db.Query(), Les fonctions db.QueryRow() et db.Exec() interrogent et manipulent 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 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. La méthode la plus simple consiste à utiliser db. Fonction .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. #🎜🎜#

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!