golang连接mysql实现增删改查（CROD）

曾经终败给现在 2023-07-04 11:09 49阅读 0赞

1.安装mysql driver

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

2.初始化sql

use test;
    CREATE TABLE `t_test` (
     `id` int(11) NOT NULL AUTO_INCREMENT,
      `name` varchar(32) DEFAULT NULL,
      `password` varchar(255) DEFAULT NULL,
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

3.连接数据库代码

package db
    
    import (
    	"database/sql"
    	_ "github.com/go-sql-driver/mysql"
    )
    
    func Conn() (*sql.DB, error){
    	// root:root@tcp(127.0.0.1:3306)/test 说明：
    	// 第一个root是用户名
    	// 第二个root是密码
    	// 127.0.0.1:3306是地址
    	// test 是数据库
    	conn,err := sql.Open("mysql","root:root@tcp(127.0.0.1:3306)/test")
    	return conn, err
    }

4.数据库增删改查代码

package db
    
    import (
    	"encoding/json"
    	"fmt"
    )
    
    // 表t_test映射
    type Ttest struct {
    	Id int64
    	Name string
    	Password string
    }
    
    func err_handler(err error) {
    	fmt.Printf("err_handler, error:%s\n", err.Error())
    	panic(err.Error())
    }
    
    // 增
    func Insert()  {
    	conn, err := Conn()
    	if err == nil {
    		exec, err := conn.Exec("INSERT INTO t_test(name,password ) VALUES(?,?)", "小红", "123456")
    		if err == nil {
    			affected , _ := exec.RowsAffected()
    			fmt.Print(affected)
    		}
    
    		if(err != nil){
    			err_handler(err)
    		}
    	}
    }
    
    // 删
    func Delete()  {
    	conn, err := Conn()
    	if(err != nil){
    		err_handler(err)
    		return
    	}
    	exec, err := conn.Exec("delete from t_test where name = ?", "小红")
    	if(err != nil){
    		err_handler(err)
    		return
    	}
    	affected, err := exec.RowsAffected()
    	if(err == nil){
    		fmt.Print("删除行数：", affected)
    	}
    
    }
    
    // 改
    func Update()  {
    	conn, err := Conn()
    	if(err != nil){
    		err_handler(err)
    		return
    	}
    
    	exec, err := conn.Exec("update t_test set password = ? where name = ?", "11111", "小红")
    	if(err == nil){
    		affected, _ := exec.RowsAffected()
    		fmt.Print("更新:", affected)
    	}
    }
    
    // 查
    func Query()  {
    	conn, err := Conn()
    	if err == nil {
    		query, err := conn.Query("select id Id, name Name,password Password from t_test")
    		if err != nil{
    			err_handler(err)
    			return
    		}
    
    		for query.Next(){
    			var test Ttest
    			err := query.Scan(&test.Id, &test.Name, &test.Password)
    			if err != nil {
    				err_handler(err)
    			}
    
    			test_json, err := json.Marshal(test)
    			if(err == nil){
    				fmt.Print("\n",string(test_json))
    			}
    		}
    	}
    }

5.源码地址（在db文件夹下）

[https://github.com/15902124763/go-base][https_github.com_15902124763_go-base]

[https_github.com_15902124763_go-base]: https://github.com/15902124763/go-base