条件查询
可以使用 db.Query("SELECT * FROM user WHERE id = ?", mid) 进行条件查询：
result, err2 := db.Query("SELECT * FROM user WHERE id = ?", mid)
Go 代码如下：
package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" "log" ) func main() { db, err := sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/DB_TEST") db.Ping() defer db.Close() if err != nil { fmt.Println("数据库连接失败！") log.Fatalln(err) } var mid int = 1 result, err2 := db.Query("SELECT * FROM user WHERE id = ?", mid) if err2 != nil { log.Fatal(err2) } for result.Next() { var id int var name string err = result.Scan(&id, &name) if err != nil { log.Fatal(err) } fmt.Printf("Id: %d, Name: %s\n", id, name) } }
？是一个占位符，填充了 mid 变量中的值。在后台，db.Query 实际上准备、执行和关闭准备好的语句。
执行该代码：
Id: 1, Name: Wade
在 MySQL 终端中运行：
mysql> SELECT * FROM user WHERE id = 1; +----+------+ | id | name | +----+------+ | 1 | Wade | +----+------+ 1 row in set (0.00 sec)
删除数据
RowsAffected 返回受更新、插入或删除语句影响的行数。
在代码示例中，我们使用 DELETE SQL 语句删除一条数据。然后我们用 RowsAffected 打印删除的行数。
package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" "log" ) func main() { db, err := sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/DB_TEST") db.Ping() defer db.Close() if err != nil { fmt.Println("数据库连接失败！") log.Fatalln(err) } sql := "DELETE FROM user WHERE id = 1" res, err2 := db.Exec(sql) if err2 != nil { panic(err2.Error()) } affectedRows, err := res.RowsAffected() if err != nil { log.Fatal(err) } fmt.Printf("The statement affected %d rows\n", affectedRows) }
The statement affected 1 rows
此时，再回到 MySQL 终端查看：
mysql> SELECT * FROM user; +----+-------+ | id | name | +----+-------+ | 2 | Kyrie | +----+-------+ 1 row in set (0.00 sec)
修改数据
package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" "log" ) func main() { db, err := sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/DB_TEST") db.Ping() defer db.Close() if err != nil { fmt.Println("数据库连接失败！") log.Fatalln(err) } sql := "update user set name = ? WHERE id = ?" res, err2 := db.Exec(sql, "Yuzhou1su", 2) if err2 != nil { panic(err2.Error()) } affectedRows, err := res.RowsAffected() if err != nil { log.Fatal(err) } fmt.Printf("Update Success, The statement affected %d rows\n", affectedRows) }
运行结果：
Update Success, The statement affected 1 rows
可以看到 id = 2 的数据 name 修改为 Yuzhou1su ,数据库中验证：
mysql> SELECT * FROM user; +----+-----------+ | id | name | +----+-----------+ | 2 | Yuzhou1su | +----+-----------+ 1 row in set (0.01 sec)
总结
本文介绍了 Go 语言如何进行增删改查，可以看到增删改查的代码并不复杂，最主要就是掌握 MySQL 的 SQL 语句的写法，然后代码框架差不多，也可以把这些函数封装成一个工具，方便今后自己的使用 。本篇文章就到此结束了，下一篇文章再见~
