go操作 mysql示例

ZzZz_ing · · 1413 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

出处:http://www.01happy.com/golang-mysql-demo/
修改案例:
package main

import (
    "database/sql"
    "fmt"

    _ "github.com/go-sql-driver/mysql"
)

func main() {
    insert()
}

func insert() {
    db, err := sql.Open("mysql", "root:000000@/test?charset=utf8")
    checkErr(err)

    cr_table := "create table if not exists user(user_id int auto_increment primary key, user_name varchar(128),user_age int,user_sex int not null default 0)"
    stmt1, err := db.Prepare(cr_table)
    checkErr(err)
    _, err = stmt1.Exec()
    checkErr(err)

    stmt, err := db.Prepare(`INSERT user (user_name,user_age,user_sex) values (?,?,?)`)
    checkErr(err)
    res, err := stmt.Exec("费大幅", 20, 1)
    checkErr(err)
    id, err := res.LastInsertId()
    checkErr(err)
    fmt.Println(id)
    //下面取消注释进入查询
    //query()
}

func query() {
    db, err := sql.Open("mysql", "root:000000@/test?charset=utf8")
    checkErr(err)

    rows, err := db.Query("SELECT * FROM user where user_name ='费大幅'")
    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, userName, userAge, userSex)
    }

    //下面取消注释进入更改
    //update()
}

func update() {
    db, err := sql.Open("mysql", "root:000000@/test?charset=utf8")
    checkErr(err)

    stmt, err := db.Prepare(`UPDATE user SET user_name=?,user_age=?,user_sex=? WHERE user_id=?`)
    checkErr(err)
    res, err := stmt.Exec("胖大海", 18, 3, 10)
    checkErr(err)
    num, err := res.RowsAffected()
    checkErr(err)
    fmt.Println(num)
    //下面取消注释进入删除
    //remove()
}
func check() {
    db, err := sql.Open("mysql", "root:000000@/test?charset=utf8")
    checkErr(err)
    rows, err := db.Query("SELECT * FROM user")
    checkErr(err)

    for rows.Next() {
        var userId, userAge, userSex int
        var userName string

        rows.Columns()
        err = rows.Scan(&userId, &userName, &userAge, &userSex)
        checkErr(err)

        fmt.Println(userId, userName, userAge, userSex, "update")
    }
}

func remove() {
    db, err := sql.Open("mysql", "root:000000@/test?charset=utf8")
    checkErr(err)
    check()
    stmt, err := db.Prepare(`DELETE FROM user WHERE user_name=?`)
    checkErr(err)
    res, err := stmt.Exec("sony")
    checkErr(err)
    num, err := res.RowsAffected()
    checkErr(err)
    fmt.Println(num)
    check()
}

func checkErr(err error) {
    if err != nil {
        panic(err)
    }
}

						

有疑问加站长微信联系(非本文作者)

本文来自:CSDN博客

感谢作者:ZzZz_ing

查看原文:go操作 mysql示例

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1413 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传