这篇文章主要讲解了“golang如何操作mysql数据”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“golang如何操作mysql数据”吧!
什么是 MySQL
MySQL 是一种广泛应用于互联网基础设施中的关系型数据库管理系统,由 Oracle 公司赞助开发。它支持多种操作系统和编程语言,包括 Go 语言,并且拥有一系列对于大型数据集成和高性能查询支持良好的特性。
MySQL 的数据是基于表的,一行数据对应一个记录,一列数据对应一个字段。它使用 SQL 语言对数据进行操作,其中最常见的 SQL 操作包括 SELECT、INSERT、UPDATE、DELETE 和 CREATE TABLE。
Go 语言中的 MySQL 驱动
在 Go 语言中,我们可以使用第三方 MySQL 驱动程序来连接和查询 MySQL 数据库。但是,GO 语言标准库中已经包含了
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 ", id, name) count++ } if err := rows.Err(); err != nil { log.Fatal(err) } fmt.Printf("Found %d users ", 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 ", rowsAffected)
我们可以使用
result.RowsAffected()获取结果集中受影响的行数,并使用该数值在控制台中打印更新数据的数量。