Golang操作MySQL数据库

待我称王封你为后i 2022-10-16 15:19 225阅读 0赞

### 文章目录 ###

*   *   *  事先准备
         *  插入数据
         *  查询数据
         *  更新操作
         *  删除数据
         *  事务操作

### 事先准备 ###

go下载两个东西：

*  MySQL驱动工具

go get github.com/go-sql-driver/mysql

*  对mysql驱动的封装，方便我们使用API操作

go get github.com/jmoiron/sqlx

创建数据库和表

### 插入数据 ###

package main
    
    import (
    	"fmt"
    
    	_ "github.com/go-sql-driver/mysql"
    	"github.com/jmoiron/sqlx"
    )
    
    var Db *sqlx.DB // 全局变量，初始化后该对象创建，main函数使用到
    
    func init() {  // 初始化
    	// sqlx.Open("数据库类型", "用户名:密码@tcp(地址:端口)/数据库名")
    	database, err := sqlx.Open("mysql", "root:123456@tcp(localhost:3306)/gomysql")
    	if err != nil { 
    		return
    	}
    	Db = database
    }
    
    func main() { 
    	defer Db.Close()
    	// 变量在语句中使用?符号作为占位符
    	insertResult, err := Db.Exec("insert into person(username, sex, email) values(?, ?, ?)", "臭宝", "男", "gzcc@qq.com")
    	if err != nil { 
    		fmt.Println("执行命令失败", err)
    		return
    	}
    	id, err := insertResult.LastInsertId() // 该数据来自递增列的数据
    	if err != nil { 
    		fmt.Println("获取最后插入的ID失败", err)
    		return
    	} else { 
    		fmt.Println("插入成功，最后插入的ID：", id)
    	}
    }
    /* 插入成功，最后插入的ID： 1 */

### 查询数据 ###

### 更新操作 ###

### 删除数据 ###

### 事务操作 ###

*  Db.Begin( )开启事务，并返回数据库事务对象，事务对象包含了sqlx.DB对象
 *  conn.Rollback( )回滚，发生错误时，可以使用该方法进行回滚操作
 *  conn.Commit( )提交事务

下面开启事务，然后进行插入操作，如果插入操作失败就回滚，还进行了删除操作，如果删除失败就回滚，最后提交事务。

package main
    
    import (
    	"fmt"
    
    	_ "github.com/go-sql-driver/mysql"
    	"github.com/jmoiron/sqlx"
    )
    
    type Person struct { 
    	UserId   int    `db:"user_id"`
    	Username string `db:"username"`
    	Sex      string `db:"sex"`
    	Email    string `db:"email"`
    }
    
    var Db *sqlx.DB // 全局变量，初始化后该对象创建，main函数使用到
    
    func init() {  // 初始化
    	database, err := sqlx.Open("mysql", "root:123456@tcp(localhost:3306)/gomysql")
    	if err != nil { 
    		return
    	}
    	Db = database
    }
    
    func main() { 
    	defer Db.Close()
    	conn, err := Db.Begin() // 开启事务
    	if err != nil { 
    		fmt.Println("事务开启失败")
    		return
    	}
    
    	insertResult, err := conn.Exec("insert into person(username, sex, email) values(?, ?, ?)", "牛啊", "女", "gzcc@qq.com")
    	if err != nil { 
    		fmt.Println("执行命令失败，开始回滚", err)
    		conn.Rollback() // 回滚
    		return
    	}
    	id, err := insertResult.LastInsertId() // 该数据来自递增列的数据
    	if err != nil { 
    		fmt.Println("获取最后插入的ID失败，开始回滚", err)
    		conn.Rollback() // 回滚
    		return
    	} else { 
    		fmt.Println("插入成功", id)
    	}
    
    	updateResult, err := Db.Exec("delete from person where user_id=?", 2)
    	if err != nil { 
    		fmt.Println("执行命令失败，开始回滚", err)
    		conn.Rollback() // 回滚
    		return
    	}
    	// 获取受影响的行数
    	row, err := updateResult.RowsAffected()
    	if err != nil { 
    		fmt.Println("删除操作失败，开始回滚", err)
    		conn.Rollback() // 回滚
    	} else { 
    		fmt.Println("删除成功，受影响的行数为：", row)
    	}
        
    	conn.Commit()  // 提交
    }
    /* 插入成功 6 删除成功，受影响的行数为： 1 */