zoukankan      html  css  js  c++  java
  • Golang之Mysql操作

    话说当年武大郎对着电脑一顿噼里啪啦,,,对mysql增删改查

    增加insert

    package main
    
    import (
        "fmt"
        "github.com/jmoiron/sqlx"
        _ "github.com/go-sql-driver/mysql" //初始化一个mysql驱动,必须
    )
    
    type Person struct {
        UserId   int    `db:"user_id"`
        Username string `db:"username"`
        Sex      string `db:"sex"`
        Email    string `db:"email"`
    }
    type Place struct {
        Country string `db:"country"`
        City    string `db:"city"`
        TelCode int    `db:"telcode"`
    }
    
    var Db *sqlx.DB
    
    func init() {
        //"mysql"指定数据库类型,  /test指定数据库  root:123 冒号隔开密码 root账号 123密码
        database, err := sqlx.Open("mysql", "root@tcp(127.0.0.1:3306)/test")
        if err != nil {
            fmt.Println("open mysql failed,", err)
            return
        }
        Db = database
    }
    func main() {
        //插入数据入表
        r, err := Db.Exec("insert into person(username,sex,email)values(?,?,?)", "chaoge", "man", "yc_uuu@163.com")
        if err != nil {
            fmt.Println("exec failed,", err)
            return
        }
        id, err := r.LastInsertId()
        if err != nil {
            fmt.Println("exec failed,", err)
            return
        }
        fmt.Println("insert succ:", id)
    }
    insert

    查询select

    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"`
    }
    type Place struct {
        Country string `db:"country"`
        City    string `db:"city"`
        TelCode int    `db:"telcode"`
    }
    
    var Db *sqlx.DB
    
    func init() {
        //初始化链接数据库
        database, err := sqlx.Open("mysql", "root:@tcp(127.0.0.1:3306)/test")
        if err != nil {
            fmt.Println("open mysql failed", err)
            return
        }
        Db = database
    }
    
    func main() {
        var person []Person
        err := Db.Select(&person, "select user_id,username,sex,email from person where user_id=?", 1)
        if err != nil {
            fmt.Println("exec failed,", err)
            return
        }
        fmt.Println("select succ:", person)
    
    }
    select

    改update

    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"`
    }
    type Place struct {
        Country string `db:"country"`
        City    string `db:"city"`
        TelCode int    `db:"telcode"`
    }
    
    var Db *sqlx.DB
    
    func init() {
        database, err := sqlx.Open("mysql", "root@tcp(127.0.0.1:3306)/test")
        if err != nil {
            fmt.Println("open mysql failed,", err)
            return
        }
        Db = database
    }
    func main() {
        _, err := Db.Exec("update person set username=? where user_id=?", "chaoge666", 1)
        if err != nil {
            fmt.Println("exec failed,", err)
        }
    }
    update

    删delete

    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"`
    }
    
    type Place struct {
        Country string `db:"country"`
        City    string `db:"city"`
        TelCode int    `db:"telcode"`
    }
    
    var Db *sqlx.DB
    
    func init() {
        //初始化链接数据库
        database, err := sqlx.Open("mysql", "root@tcp(127.0.0.1:3306)/test")
        if err != nil {
            fmt.Println("open mysql failed,", err)
            return
        }
        Db = database
    }
    
    func main() {
        _, err := Db.Exec("delete FROM person where user_id=?", 1)
        if err != nil {
            fmt.Println("exec failed,", err)
            return
        }
        fmt.Println("delete succ")
    }
    delete
  • 相关阅读:
    03.分支结构
    02.语言元素
    开博的第一天
    http://mirrors.163.com/centos/7.6.1810/os/x86_64/repodata/repomd.xml: [Errno 14]
    spring boot配置spring-data-jpa的时候报错CannotCreateTransactionException: Could not open JPA EntityManager for transaction; nested exception is java.lang.NoSuchMethodError
    开机自动运行exe
    hibernate.QueryException: Legacy-style query parameters (`?`) are no longer supported 问题
    elasticSearch7____BUG
    idea开发web项目${pageContext.request.contextPath}出现错误
    进阶
  • 原文地址:https://www.cnblogs.com/pyyu/p/8360069.html
Copyright © 2011-2022 走看看