zoukankan      html  css  js  c++  java
  • go mysql

    安装导入

    go get "github.com/go-sql-driver/mysql"
    go get "github.com/jmoiron/sqlx"
    
    import (
        _ "github.com/go-sql-driver/mysql"
        "github.com/jmoiron/sqlx"
    )
    

    github:

      https://github.com/go-sql-driver/mysql

      https://github.com/jmoiron/sqlx

    Doc:

          http://godoc.org/github.com/jmoiron/sqlx

      http://jmoiron.github.io/sqlx/

    使用

    1、连接

    package main
    
    import (
    _ "github.com/go-sql-driver/mysql"
    "github.com/jmoiron/sqlx"
    "fmt"
    )
    
    var Db *sqlx.DB
    
    func init() {
    
    	database, err := sqlx.Open("mysql", "root:root@tcp(10.10.83.162:3306)/etm-m-om")
    	if err != nil {
    		fmt.Println("open mysql failed,", err)
    		return
    	}
    
    	Db = database
    }
    
    func main()  {
    	fmt.Println(Db)
    }
    

    2、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: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)
    }
    

    3、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: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=?", "stu0003", 1)
    	if err != nil {
    		fmt.Println("exec failed, ", err)
    		return
    	}
    
    }
    

    4、insert

    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: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(?, ?, ?)", "stu001", "man", "stu01@qq.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)
    }
    

    5、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: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")
    }
    

      

  • 相关阅读:
    四则运算
    屏蔽恶意IP
    Vue企业级优雅实战05-框架开发01-登录界面
    Vue企业级优雅实战04-组件开发01-SVG图标组件
    Vue企业级优雅实战03-准备工作04-全局设置
    Vue企业级优雅实战02-准备工作03-提交 GIT 平台
    802.11ax TWT
    leetcode338
    春招实习面经(已拿阿里/腾讯/亚马逊)
    leetcode weekly contest138
  • 原文地址:https://www.cnblogs.com/shhnwangjian/p/7513596.html
Copyright © 2011-2022 走看看