Go实现对MySQL的增删改查 原
开发环境：windows7 64位、编辑器是sublime text3。 直接添上代码了，代码中有注释。 注：需要提前下载github.com/go-sql-driver/mysql，下面的程序才会运行成功。 package main
import ( "database/sql" //这个感觉有点类似java中的java.sql.* "fmt" _ "github.com/go-sql-driver/mysql" //这个感觉类似于jdbc )
func main() { //主函数，调用不同的方法 //Insert() //Delete() //Update() //Query() QueryWithParams() //QueryWithParam() }
//得到数据库的连接，并将连接返回 func Init() (*sql.DB, error) { //返回类型有俩个,第一个是数据库的连接(指针)，第二个是错误类型 //得到数据库的连接，"test"表示的是数据库名称 db, err := sql.Open("mysql", "root:dmj2010@tcp(localhost:3306)/test?charset=utf8") if err != nil { //err的值不是nil那么表示打开数据库连接失败 fmt.Println("打开数据库连接失败_" + err.Error()) return nil, err } return db, nil //返回的错误类型是nil，表示成功得到数据库连接 }
//向数据库中插入数据 func Insert() { //这个函数没有参数，也没有返回值 db, err := Init() //得到数据库连接
if err != nil { //if语句的判断语句不用加括号
fmt.Println("得到数据库连接有问题")
return
}
sql := "insert into user(name,age) values(?,?)"
stmt, err := db.Prepare(sql)
if err != nil {
fmt.Println("错误——" + err.Error())
return
}
defer stmt.Close() //表示当程序退出当前所在的函数(即Insert())时关闭stmt
defer db.Close() //表示当程序退出时当前所在的函数(即Insert())时关闭数据库连接db
fmt.Println("开始插入数据")
stmt.Exec("张三", 20) //设置参数并进行插入数据
stmt.Exec("李四", 45) //设置参数并进行插入数据
stmt.Exec("段幕", 36) //设置参数并进行插入数据
fmt.Println("插入结束")}
//删除数据 func Delete() { db, err := Init() if err != nil { fmt.Println("得到数据库连接结果失败——" + err.Error()) return } sql := "delete from user where id=?" stmt, err := db.Prepare(sql) if err != nil { fmt.Println("删除失败——" + err.Error()) return } defer stmt.Close() defer db.Close()
stmt.Exec(1) //设置参数，即id的值为1
stmt.Exec(2) //设置参数，即id的值为2}
//更新数据 func Update() { db, err := Init() if err != nil { fmt.Println("得到数据库连接结果失败——" + err.Error()) return } sql := "update user set name=?,age=? where id=?" stmt, err := db.Prepare(sql) if err != nil { fmt.Println("更新失败——" + err.Error()) return } defer stmt.Close() defer db.Close()
stmt.Exec("木婉清", 123, 3)
stmt.Exec("曾小邪", 18, 4)
stmt.Exec("其二", 23, 5)}
//查询数据 func Query() { db, err := Init() if err != nil { fmt.Println("得到数据库连接结果失败——" + err.Error()) return }
rows, err := db.Query("select * from user")
if err != nil {
fmt.Println("查询失败——" + err.Error())
return
}
for rows.Next() { //rows.Next()返回的是bool值
var id int //声明id为int型
var name string //声明name为string型
var age int //声明age为int型
err := rows.Scan(&id, &name, &age)
if err != nil {
fmt.Println("rows.Scan失败!——" + err.Error())
return
} //if
//fmt.Printf(....) 这个有点类似C中的printf(...)
fmt.Printf("id:%d name:%s age:%d \n", id, name, age) //%d表示显示整形数值 %s表示显示字符串
} //for
defer rows.Close()
defer db.Close()}
//查询数据，有参数设置&&返回值有多行 func QueryWithParams() { db, err := Init() if err != nil { fmt.Println("得到数据库连接结果失败——" + err.Error()) return }
rows, err := db.Query("select * from user where age=?", 20)
if err != nil {
fmt.Println("查询失败——" + err.Error())
return
}
for rows.Next() { //rows.Next()返回的是bool值
var id int
var name string
var age int
err := rows.Scan(&id, &name, &age)
if err != nil {
fmt.Println("rows.Scan失败!——" + err.Error())
return
} //if
//fmt.Printf(....) 这个有点类似C中的printf(...)
fmt.Printf("id:%d name:%s age:%d \n", id, name, age) //%d表示显示整形数值 %s表示显示字符串
} //for
defer rows.Close()
defer db.Close()}
//查询数据，有参数设置&&返回值最多只有一行 func QueryWithParam() { db, err := Init() if err != nil { fmt.Println("得到数据库连接结果失败——" + err.Error()) return }
var id int
var name string
var age int
row := db.QueryRow("select * from user where id=?", 3)
err = row.Scan(&id, &name, &age)
if err != nil {
fmt.Println("查询失败——" + err.Error())
return
}
//fmt.Printf(....) 这个有点类似C中的printf(...)
fmt.Printf("id:%d name:%s age:%d \n", id, name, age) //%d表示显示整形数值 %s表示显示字符串
defer db.Close()}
(adsbygoogle = window.adsbygoogle || []).push({});