go 通过sql操作mysql

本文涉及的产品
云数据库 RDS MySQL,集群版 2核4GB 100GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: go 通过sql操作mysql

前言

表格

结果

go代码

package main

import (
  "database/sql"
  "fmt"
  "time"

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

var db *sql.DB   //全局变量client

func initMySQL() (err error) {
  dsn := "root:123456@tcp(127.0.0.1:3306)/test"
  db, err = sql.Open("mysql", dsn)
  if err != nil {
    panic(err)
  }
  err = db.Ping() //检测是否连接成功
  if err != nil {
    return
  }
  db.SetMaxOpenConns(200)                 //最大连接数
  db.SetMaxIdleConns(10)                  //连接池里最大空闲连接数。必须要比maxOpenConns小
  db.SetConnMaxLifetime(time.Second * 10) //最大存活保持时间
  db.SetConnMaxIdleTime(time.Second * 10) //最大空闲保持时间
  return
}

func main() {
  if err := initMySQL(); err != nil {
    fmt.Printf("connect to db failed,err:%v\n", err)
  } else {
    fmt.Println("connect to db success")
  }

  sqlStr := "SELECT id, name FROM sys_user WHERE id=?"
  var u user
  //非常重要:确保QueryRow之后调用Scan方法,否则持有的数据库链接不会被释放
  err := db.QueryRow(sqlStr, 1).Scan(&u.id, &u.name)
  if err != nil {
    fmt.Printf("scan failed, err: %v\n", err)
    return
  }
  fmt.Printf("id:%d,name:%s,age:%d\n", u.id, u.name)

  defer db.Close()

}

//user结构体
type user struct {
  id int
  name string
}

sql

database: test

CREATE TABLE `sys_user` (
  `id` int(11) NOT NULL,
  `name` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1;


汇总-增删改查

结果:

package main

import (
  "database/sql"
  "fmt"
  "time"

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

var db *sql.DB

func initMySQL() (err error) {
  dsn := "root:1234qwer@tcp(bj-cdb-mw08tjgs.sql.tencentcdb.com:60042)/test"
  db, err = sql.Open("mysql", dsn)
  if err != nil {
    panic(err)
  }
  err = db.Ping()
  if err != nil {
    return
  }
  db.SetMaxOpenConns(200)                 //最大连接数
  db.SetMaxIdleConns(10)                  //连接池里最大空闲连接数。必须要比maxOpenConns小
  db.SetConnMaxLifetime(time.Second * 10) //最大存活保持时间
  db.SetConnMaxIdleTime(time.Second * 10) //最大空闲保持时间
  return
}

func main() {
  if err := initMySQL(); err != nil {
    fmt.Printf("connect to db failed,err:%v\n", err)
  } else {
    fmt.Println("connect to db success")
  }
  select_one()
  queryMultiRowDemo()
  insertRowDemo()
  updateRowDemo()
  deleteRowDemo()
  defer db.Close()

}

type user struct {
  id int
  // age  int
  name string
}

//查询
func select_one() {
  sqlStr := "SELECT id, name FROM sys_user WHERE id=?"
  var u user
  //非常重要:确保QueryRow之后调用Scan方法,否则持有的数据库链接不会被释放
  err := db.QueryRow(sqlStr, 1).Scan(&u.id, &u.name)
  if err != nil {
    fmt.Printf("scan failed, err: %v\n", err)
    return
  }
  fmt.Printf("id:%d,name:%s\n", u.id, u.name)
}

// 查询多条数据示例
func queryMultiRowDemo() {
  sqlStr := "SELECT id,name FROM sys_user WHERE id>?"
  var u user
  rows, err := db.Query(sqlStr, 0)
  if err != nil {
    fmt.Printf("query failed, err:%v\n", err)
    return
  }
  //非常重要,关闭rows释放持有的数据库链接
  defer rows.Close()
  for rows.Next() {
    err := rows.Scan(&u.id, &u.name)
    if err != nil {
      fmt.Printf("scan failed, err: %v\n", err)
      return
    }
    fmt.Printf("id:%d,name:%s\n", u.id, u.name)
  }
}

//插入数据
func insertRowDemo() {
  sqlStr := "INSERT INTO sys_user(id,name) VALUES(?,?)"
  ret, err := db.Exec(sqlStr, 23, "javapub")
  if err != nil {
    fmt.Printf("insert failed, err:%v\n", err)
    return
  }
  var theID int64
  theID, err = ret.LastInsertId()
  if err != nil {
    fmt.Printf("get lastinsert ID failed,err:%v\n", err)
    return
  }
  fmt.Printf("insert success, the id is %d\n", theID)
}

//更新数据
func updateRowDemo() {
  sqlStr := "UPDATE sys_user SET name=? WHERE id=?"
  ret, err := db.Exec(sqlStr, "i love javapub", 23)
  if err != nil {
    fmt.Printf("updated failed,err:%v\n", err)
    return
  }
  var n int64
  n, err = ret.RowsAffected()
  if err != nil {
    fmt.Printf("get rowsAffected failed,err:%v\b", err)
    return
  }
  fmt.Printf("updated success, the rows affected is %d\n", n)
}

//删除数据
func deleteRowDemo() {
  sqlStr := "DELETE FROM sys_user WHERE id=?"
  ret, err := db.Exec(sqlStr, 1)
  if err != nil {
    fmt.Printf("delete failed,err:%v\n", err)
    return
  }
  var n int64
  n, err = ret.RowsAffected()
  if err != nil {
    fmt.Printf("get RowsAffected failed, err:%v\n", err)
    return
  }
  fmt.Printf("delete success, affected rows:%d\n", n)
}

相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
5天前
|
SQL 关系型数据库 MySQL
MySQL 保姆级教程(一):了解 SQL
MySQL 保姆级教程(一):了解 SQL
|
7天前
|
SQL 安全 关系型数据库
【SQL】已解决:MySQL 服务无法启动
【SQL】已解决:MySQL 服务无法启动
41 1
|
7天前
|
SQL 关系型数据库 MySQL
「Python入门」python操作MySQL和SqlServer
**摘要:** 了解如何使用Python的pymysql模块与MySQL数据库交互。首先,通过`pip install pymysql`安装模块。pymysql提供与MySQL的连接功能,例如创建数据库连接、执行SQL查询。在设置好MySQL环境后,使用`pymysql.connect()`建立连接,并通过游标执行SQL(如用户登录验证)。注意防止SQL注入,使用参数化查询。增删改操作需调用`conn.commit()`来保存更改。pymssql模块类似,但导入和连接对象创建略有不同。
11 0
「Python入门」python操作MySQL和SqlServer
|
12天前
|
SQL 关系型数据库 MySQL
【MySQL从入门到精通】常用SQL语句分享
【MySQL从入门到精通】常用SQL语句分享
24 2
|
13天前
|
SQL Java 数据库连接
深入理解SQL中的LEFT JOIN操作
深入理解SQL中的LEFT JOIN操作
|
11天前
|
SQL 关系型数据库 MySQL
You have an error in your SQL syntax;check the manual that corresponds to you Mysql server version
You have an error in your SQL syntax;check the manual that corresponds to you Mysql server version
|
12天前
|
关系型数据库 MySQL Go
mysql,数据库Server returns invalid timezone. Go to ‘Advanced‘ tab 数据库的行和列没有出现怎么办p
mysql,数据库Server returns invalid timezone. Go to ‘Advanced‘ tab 数据库的行和列没有出现怎么办p
|
5天前
|
JSON 测试技术 Go
零值在go语言和初始化数据
【7月更文挑战第10天】本文介绍在Go语言中如何初始化数据,未初始化的变量会有对应的零值:bool为`false`,int为`0`,byte和string为空,pointer、function、interface及channel为`nil`,slice和map也为`nil`。。本文档作为指南,帮助理解Go的数据结构和正确使用它们。
53 22
零值在go语言和初始化数据
|
7天前
|
安全 算法 程序员
在go语言中使用泛型和反射
【7月更文挑战第8天】本文介绍go支持泛型后,提升了代码复用,如操作切片、映射、通道的函数,以及自定义数据结构。 泛型适用于通用数据结构和函数,减少接口使用和类型断言。
69 1
在go语言中使用泛型和反射
|
9天前
|
缓存 编译器 Shell
回顾go语言基础中一些特别的概念
【7月更文挑战第6天】本文介绍Go语言基础涵盖包声明、导入、函数、变量、语句和表达式以及注释。零值可用类型如切片、互斥锁和缓冲,支持预分配容量以优化性能。
40 2
回顾go语言基础中一些特别的概念