golang本身没有提供连接mysql的驱动,但是定义了标准接口供第三方开发驱动。这里连接mysql可以使用第三方库,第三方库推荐使用https://github.com/Go-SQL-Driver/MySQL这个驱动,更新维护都比较好。下面演示下具体的使用,完整代码示例可以参考最后。
下载驱动
sudo go get github.com/go-sql-driver/mysql
如果提示这样的失败信息:cannot download, $GOPATH not set. For more details see: go help gopath,可以使用如下命令解决
sudo env GOPATH=/Users/chenjiebin/golang go get github.com/go-sql-driver/mysql
GOPATH的值根据自行环境进行替换。
创建测试表
在mysql test库中创建测试表
CREATE TABLE IF NOT EXISTS `test`.`user` ( `user_id` INT(11) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '用户编号', `user_name` VARCHAR(45) NOT NULL COMMENT '用户名称', `user_age` TINYINT(3) UNSIGNED NOT NULL DEFAULT 0 COMMENT '用户年龄', `user_sex` TINYINT(3) UNSIGNED NOT NULL DEFAULT 0 COMMENT '用户性别', PRIMARY KEY (`user_id`)) ENGINE = InnoDB AUTO_INCREMENT = 1 DEFAULT CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '用户表'
数据库连接
数据库连接使用datebase/sql Open函数进行连接
db, err := sql.Open("mysql", "user:password@tcp(localhost:5555)/dbname?charset=utf8")
其中连接参数可以有如下几种形式:
user@unix(/path/to/socket)/dbname?charset=utf8
user:password@tcp(localhost:5555)/dbname?charset=utf8
user:password@/dbname
user:password@tcp([de:ad:be:ef::ca:fe]:80)/dbname
通常我们都用第二种。
插入操作
stmt, err := db.Prepare(`INSERT user (user_name,user_age,user_sex) values (?,?,?)`) checkErr(err) res, err := stmt.Exec("tony", 20, 1) checkErr(err) id, err := res.LastInsertId() checkErr(err) fmt.Println(id)
这里使用结构化操作,不推荐使用直接拼接sql语句的方法。
查询操作
rows, err := db.Query("SELECT * FROM user") checkErr(err) for rows.Next() { var userId int var userName string var userAge int var userSex int rows.Columns() err = rows.Scan(&userId, &userName, &userAge, &userSex) checkErr(err) fmt.Println(userId) fmt.Println(userName) fmt.Println(userAge) fmt.Println(userSex) }
这里查询的方式使用声明4个独立变量userId、userName、userAge、userSex来保存查询出来的每一行的值。在实际开发中通常会封装数据库的操作,对这样的查询通常会考虑返回字典类型。
//构造scanArgs、values两个数组,scanArgs的每个值指向values相应值的地址 columns, _ := rows.Columns() scanArgs := make([]interface{}, len(columns)) values := make([]interface{}, len(columns)) for i := range values { scanArgs[i] = &values[i] } for rows.Next() { //将行数据保存到record字典 err = rows.Scan(scanArgs...) record := make(map[string]string) for i, col := range values { if col != nil { record[columns[i]] = string(col.([]byte)) } } fmt.Println(record) }
修改操作
stmt, err := db.Prepare(`UPDATE user SET user_age=?,user_sex=? WHERE user_id=?`) checkErr(err) res, err := stmt.Exec(21, 2, 1) checkErr(err) num, err := res.RowsAffected() checkErr(err) fmt.Println(num)
删除操作
stmt, err := db.Prepare(`DELETE FROM user WHERE user_id=?`) checkErr(err) res, err := stmt.Exec(1) checkErr(err) num, err := res.RowsAffected() checkErr(err) fmt.Println(num)
修改和删除操作都比较简单,同插入数据类似,只是使用RowsAffected来获取影响的数据行数。
完整代码
package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" ) func main() { insert() } //插入demo func insert() { db, err := sql.Open("mysql", "root:@/test?charset=utf8") checkErr(err) stmt, err := db.Prepare(`INSERT user (user_name,user_age,user_sex) values (?,?,?)`) checkErr(err) res, err := stmt.Exec("tony", 20, 1) checkErr(err) id, err := res.LastInsertId() checkErr(err) fmt.Println(id) } //查询demo func query() { db, err := sql.Open("mysql", "root:@/test?charset=utf8") checkErr(err) rows, err := db.Query("SELECT * FROM user") checkErr(err) //普通demo //for rows.Next() { // var userId int // var userName string // var userAge int // var userSex int // rows.Columns() // err = rows.Scan(&userId, &userName, &userAge, &userSex) // checkErr(err) // fmt.Println(userId) // fmt.Println(userName) // fmt.Println(userAge) // fmt.Println(userSex) //} //字典类型 //构造scanArgs、values两个数组,scanArgs的每个值指向values相应值的地址 columns, _ := rows.Columns() scanArgs := make([]interface{}, len(columns)) values := make([]interface{}, len(columns)) for i := range values { scanArgs[i] = &values[i] } for rows.Next() { //将行数据保存到record字典 err = rows.Scan(scanArgs...) record := make(map[string]string) for i, col := range values { if col != nil { record[columns[i]] = string(col.([]byte)) } } fmt.Println(record) } } //更新数据 func update() { db, err := sql.Open("mysql", "root:@/test?charset=utf8") checkErr(err) stmt, err := db.Prepare(`UPDATE user SET user_age=?,user_sex=? WHERE user_id=?`) checkErr(err) res, err := stmt.Exec(21, 2, 1) checkErr(err) num, err := res.RowsAffected() checkErr(err) fmt.Println(num) } //删除数据 func remove() { db, err := sql.Open("mysql", "root:@/test?charset=utf8") checkErr(err) stmt, err := db.Prepare(`DELETE FROM user WHERE user_id=?`) checkErr(err) res, err := stmt.Exec(1) checkErr(err) num, err := res.RowsAffected() checkErr(err) fmt.Println(num) } func checkErr(err error) { if err != nil { panic(err) } }
小结
整体上来说都比较简单,就是查询那边使用字典来存储返回数据比较复杂一些。既然说到数据库连接,通常应用中都会使用连接池来减少连接开销,关于连接池下次整理一下再放上来。
参考资料:《go web编程》,go web编程中对数据库连接做了比较详细的解说,值得一看。
<!-- 336x280 --> <iframe id="aswift_1" style="left: 0px; top: 0px; position: absolute;" name="aswift_1" frameborder="0" marginwidth="0" marginheight="0" scrolling="no" width="336" height="280"></iframe>转载请注明:快乐编程 » golang连接mysql操作示例增删改查
相关推荐
需求和思路 在一般的小项目或者一个小软件,例如... 如果同时需要增删查改功能的话,将map作为中间格式是比较合适的.接下来我们就来实现它. 查询操作 这种操作的实现比较简单,直接将文件中的数据读取出来,使用json库
ORM技术的主要目的是将数据库操作转化为对编程语言中的对象的操作,使得开发者无需编写大量SQL语句,就能实现数据的增删改查。在Go-Toyorm中,你可以通过定义Go的结构体来对应数据库中的表,从而简化数据库操作。 #...
Beego的ORM模块可以方便地与数据库交互,如MySQL、PostgreSQL等,进行数据的增删改查操作。 4. **中间件**:Beego支持自定义中间件,可以用来处理如用户验证、日志记录、性能监控等功能,提高代码的复用性和安全性...
3. **CRUD操作**:基本的增删改查(Create、Read、Update、Delete)功能是ORM的核心,petadb应该提供了简单易用的接口来实现这些操作。例如,通过一个简单的函数调用即可完成数据的插入、查询、更新和删除。 4. **...
在本文中,我们将深入探讨基于Go语言的Beego 2.0框架的开发基础,以及如何利用这个强大的工具实现文章管理系统的功能,如文章的增删改查和用户登录。Beego是一个快速、高效的Web应用框架,它为Go开发者提供了便利的...
在gotodo应用中,我们可能会定义如`/todos`、`/todos/{id}`等路由来处理增删改查(CRUD)操作。通常,这些接口会遵循RESTful原则,使用GET、POST、PUT和DELETE等HTTP方法。 3. **Go的net/http库**: Go标准库中的`...
GORM 是一个强大的 ORM 库,与 Gin 结合可以方便地进行数据库操作,包括增删改查、事务处理和预加载。 十五、原生 SQL 和 SQL 生成器 GORM 支持原生 SQL 语句执行,也可以使用其提供的 SQL 生成器来编写更安全的...
2. **编写UserController**:创建对应的控制器,实现用户的增删改查操作。 3. **配置路由**:在主程序中,使用Gin的`gin.New()`或`gin.Default()`创建一个新的Gin实例,然后注册路由,如`router.GET("/users", ...
开发者需要设计数据库表结构,将各种数据字段映射到相应的列,同时实现数据的增删改查操作。 6. **API调用与权限管理**:在调用阿里云API时,通常需要身份验证和权限控制。开发者可能使用Access Key ID和Access Key...
2. 数据管理:对各类业务数据进行增删改查操作,支持数据导入导出、备份恢复等。 3. 权限控制:根据角色和用户分配不同的操作权限,实现细粒度的权限管理。 4. 流程审批:实现工作流的自动化处理,如请假申请、报销...
在 Go 中,这通常意味着有一个单独的包或模块,比如 `repository`,包含了对数据的增删改查操作。 4. **数据库集成**:项目可能使用了某种数据库,如 PostgreSQL、MySQL 或者更轻量级的 SQLite,来持久化待办事项...