百度360必应搜狗淘宝本站头条
nodejsbufferorg.jsoupsetnocountoncv2.bitwise_nottime.strptime
当前位置：网站首页 > 编程字典 > 正文

Golang连接MySQL执行查询并解析-告别结构体

toyiye 2024-06-21 12:14 7 浏览 0 评论

简介

本篇主要实践Golang采用官方驱动连接MySQL, 以及执行原生SQL语句和解析, 解析过程中不使用结构体.


核心原理图:

完整代码:

package main
import (
   "database/sql"
   "encoding/json"
   "fmt"
   _ "github.com/go-sql-driver/mysql" //被database/sql包使用的MYSQL驱动, 官方文档和项目:https://github.com/go-sql-driver/mysql
   "log"
   "time"
)

var (
   Db  *sql.DB
   err error
)


//获取数据库控制器
func GetDb(host string, port int, username string, password string) (*sql.DB, error) {
   //DSN (Data Source Name)数据源连接格式:[username[:password]@][protocol[(address)]]/dbname[?param1=value1&...?mN=valueN]
   //这里我们可以不选择数据库,或者增加可选参数,比如timeout(建立连接超时时间)
   //mysqlConnStr := fmt.Sprintf("%s:%s@tcp(%s:%d)/mysql?&charset=utf8&parseTime=True&loc=Local&timeout=5s", username, password, host, port)
   dsn := fmt.Sprintf("%s:%s@tcp(%s:%d)/?timeout=5s", username, password, host, port)
   Db, err = sql.Open("mysql", dsn)
   if err != nil {
      log.Printf("配置连接出错:%s\n", err.Error())
      return Db, err
   }
   // 设置连接池中空闲连接的最大数量。
   Db.SetMaxIdleConns(1)
   // 设置打开数据库连接的最大数量。
   Db.SetMaxOpenConns(1)
   // 设置连接可复用的最大时间。
   Db.SetConnMaxLifetime(time.Second * 30)
   //设置连接最大空闲时间
   Db.SetConnMaxIdleTime(time.Second * 30)

   //检查连通性
   err = Db.Ping()
   if err != nil {
      log.Printf("数据库连接出错:%s\n", err.Error())
      return Db, err
   }

   return Db, err
}



//单行数据解析 查询数据库，解析查询结果，支持动态行数解析
func QueryAndParse(Db *sql.DB, queryStr string) map[string]string {
   rows, err := Db.Query(queryStr)
   defer rows.Close()

   if err != nil {
      log.Printf("查询出错,SQL语句:%s\n错误详情:%s\n", queryStr, err.Error())
      return nil
   }

   //获取列名cols
   cols, _ := rows.Columns()
   if len(cols) > 0 {
      buff := make([]interface{}, len(cols)) // 创建临时切片buff
      data := make([][]byte, len(cols))      // 创建存储数据的字节切片2维数组data
      dataKv := make(map[string]string, len(cols))  //创建dataKv, 键值对的map对象
      for i, _ := range buff {
         buff[i] = &data[i]  //将字节切片地址赋值给临时切片,这样data才是真正存放数据
      }

      for rows.Next() {
         rows.Scan(buff...) // ...是必须的,表示切片
      }

      for k, col := range data {
         dataKv[cols[k]] = string(col)
         //fmt.Printf("%30s:\t%s\n", cols[k], col)
      }
      return dataKv
   } else {
      return nil
   }
}

//多行数据解析
func QueryAndParseRows(Db *sql.DB, queryStr string) []map[string]string {
   rows, err := Db.Query(queryStr)
   defer rows.Close()
   if err != nil {
      fmt.Printf("查询出错:\nSQL:\n%s, 错误详情:%s\n", queryStr, err.Error())
      return nil
   }
   //获取列名cols
   cols, _ := rows.Columns()
   if len(cols) > 0 {
      var ret []map[string]string
      for rows.Next() {
         buff := make([]interface{}, len(cols))
         data := make([][]byte, len(cols)) //数据库中的NULL值可以扫描到字节中
         for i, _ := range buff {
            buff[i] = &data[i]
         }
         rows.Scan(buff...) //扫描到buff接口中，实际是字符串类型data中
         //将每一行数据存放到数组中
         dataKv := make(map[string]string, len(cols))
         for k, col := range data { //k是index，col是对应的值
            //fmt.Printf("%30s:\t%s\n", cols[k], col)
            dataKv[cols[k]] = string(col)
         }
         ret = append(ret, dataKv)
      }
      return ret
   } else {
      return nil
   }
}


//任意可序列化数据转为Json,便于查看
func Data2Json(anyData interface{}) string {
   JsonByte, err := json.Marshal(anyData)
   if err != nil {
      log.Printf("数据序列化为json出错:\n%s\n", err.Error())
   }
   return string(JsonByte)
}



func main() {
   //获取数据库控制器DB
   DB, err := GetDb("data", 3306, "root", "root")
   if err != nil {
      log.Printf("获取数据库控制器出错:%s\n", err.Error())
   }
   defer DB.Close() //延迟关闭数据库控制器,释放数据库连接
   //单行数据查询
   showMasterStatus := QueryAndParse(Db, "show master status")
   log.Printf("单行数据-数据库状态:%v\n", Data2Json(showMasterStatus))
   log.Printf("单行数据-数据库状态-File:%v\n", showMasterStatus["File"])


   //多行数据查询
   showProcessList := QueryAndParseRows(Db, "show processlist")
   log.Printf("多行数据-进程信息:%v\n", Data2Json(showProcessList))
   log.Printf("多行数据-进程信息-Host:%v\n", showProcessList[0]["Host"])
}

执行结果:

2020/11/03 21:50:08 单行数据-数据库状态:{"Binlog_Do_DB":"","Binlog_Ignore_DB":"","Executed_Gtid_Set":"","File":"mysql-bin.000002","Position":"11543900"}2020/11/03 21:50:08 单行数据-数据库状态-File:mysql-bin.0000022020/11/03 21:50:08 多行数据-进程信息:[{"Command":"Query","Host":"10.254.102.110:51582","Id":"17814","Info":"show processlist","State":"starting","Time":"0","User":"roo""}]2020/11/03 21:50:08 多行数据-进程信息-Host:10.254.102.110:51582

解释说明:

  • main函数开始执行,首先获取数据库控制器DBDB, err := GetDb("data", 3306, "root", "root")主要设置数据源连接信息, 连接池配置,联通性检测等//获取数据库控制器
    func GetDb(host string, port int, username string, password string) (*sql.DB, error) {
    //DSN (Data Source Name)数据源连接格式:[username[:password]@][protocol[(address)]]/dbname[?param1=value1&...?mN=valueN]
    //这里我们可以不选择数据库,或者增加可选参数,比如timeout(建立连接超时时间)
    //mysqlConnStr := fmt.Sprintf("%s:%s@tcp(%s:%d)/mysql?&charset=utf8&parseTime=True&loc=Local&timeout=5s", username, password, host, port)
    dsn := fmt.Sprintf("%s:%s@tcp(%s:%d)/?timeout=5s", username, password, host, port)
    Db, err = sql.Open("mysql", dsn)
    if err != nil {
    log.Printf("配置连接出错:%s\n", err.Error())
    return Db, err
    }
    // 设置连接池中空闲连接的最大数量。
    Db.SetMaxIdleConns(1)
    // 设置打开数据库连接的最大数量。
    Db.SetMaxOpenConns(1)
    // 设置连接可复用的最大时间。
    Db.SetConnMaxLifetime(time.Second * 30)
    //设置连接最大空闲时间
    Db.SetConnMaxIdleTime(time.Second * 30)
    //检查连通性
    err = Db.Ping()
    if err != nil {
    log.Printf("数据库连接出错:%s\n", err.Error())
    return Db, err
    }
    return Db, err
    }
  • 接着执行查询语句show master status,并解析查询结果,得到Map对象,便于直接取值. 这里没有使用结构体来解析,所以对于结果中包含多列字段的场景非常友好!//单行数据解析 查询数据库，解析查询结果，支持动态行数解析
    func QueryAndParse(Db *sql.DB, queryStr string) map[string]string {
    rows, err := Db.Query(queryStr)
    defer rows.Close()
    if err != nil {
    log.Printf("查询出错,SQL语句:%s\n错误详情:%s\n", queryStr, err.Error())
    return nil
    }
    //获取列名cols
    cols, _ := rows.Columns()
    if len(cols) > 0 {
    buff := make([]interface{}, len(cols)) // 创建临时切片buff
    data := make([][]byte, len(cols)) // 创建存储数据的字节切片2维数组data
    dataKv := make(map[string]string, len(cols)) //创建dataKv, 键值对的map对象
    for i, _ := range buff {
    buff[i] = &data[i] //将字节切片地址赋值给临时切片,这样data才是真正存放数据
    }
    for rows.Next() {
    rows.Scan(buff...) // ...是必须的,表示切片
    }
    for k, col := range data {
    dataKv[cols[k]] = string(col)
    //fmt.Printf("%30s:\t%s\n", cols[k], col)
    }
    return dataKv
    } else {
    return nil
    }
    }
  • 如果查询语句返回多行结果,与单行类似,只是返回map切片即可


参考文档:

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

END已结束

欢迎大家留言, 订阅, 交流哦!


相关推荐

为何越来越多的编程语言使用JSON（为什么编程）

JSON是JavascriptObjectNotation的缩写，意思是Javascript对象表示法，是一种易于人类阅读和对编程友好的文本数据传递方法，是JavaScript语言规范定义的一个子...

何时在数据库中使用 JSON（数据库用json格式存储）

在本文中，您将了解何时应考虑将JSON数据类型添加到表中以及何时应避免使用它们。每天?分享?最新?软件?开发?，Devops，敏捷?，测试?以及?项目?管理?最新?，最热门?的?文章?，每天?花?...

MySQL 从零开始:05 数据类型（mysql数据类型有哪些,并举例）

前面的讲解中已经接触到了表的创建，表的创建是对字段的声明，比如：上述语句声明了字段的名称、类型、所占空间、默认值和是否可以为空等信息。其中的int、varchar、char和decimal都...

JSON对象花样进阶（json格式对象）

一、引言在现代Web开发中，JSON（JavaScriptObjectNotation）已经成为数据交换的标准格式。无论是从前端向后端发送数据，还是从后端接收数据，JSON都是不可或缺的一部分。...

深入理解 JSON 和 Form-data（json和formdata提交区别）

在讨论现代网络开发与API设计的语境下，理解客户端和服务器间如何有效且可靠地交换数据变得尤为关键。这里，特别值得关注的是两种主流数据格式：...

JSON 语法（json 语法 priority）

JSON语法是JavaScript语法的子集。JSON语法规则JSON语法是JavaScript对象表示法语法的子集。数据在名称/值对中数据由逗号分隔花括号保存对象方括号保存数组JS...

JSON语法详解（json的语法规则）

JSON语法规则JSON语法是JavaScript对象表示法语法的子集。数据在名称/值对中数据由逗号分隔大括号保存对象中括号保存数组注意：json的key是字符串,且必须是双引号，不能是单引号...

MySQL JSON数据类型操作（mysql的json）

概述mysql自5.7.8版本开始，就支持了json结构的数据存储和查询，这表明了mysql也在不断的学习和增加nosql数据库的有点。但mysql毕竟是关系型数据库，在处理json这种非结构化的数据...

JSON的数据模式（json数据格式示例）

像XML模式一样，JSON数据格式也有Schema，这是一个基于JSON格式的规范。JSON模式也以JSON格式编写。它用于验证JSON数据。JSON模式示例以下代码显示了基本的JSON模式。{"...

前端学习——JSON格式详解（后端json格式）

JSON(JavaScriptObjectNotation)是一种轻量级的数据交换格式。易于人阅读和编写。同时也易于机器解析和生成。它基于JavaScriptProgrammingLa...

什么是 JSON:详解 JSON 及其优势（什么叫json）

现在程序员还有谁不知道JSON吗？无论对于前端还是后端，JSON都是一种常见的数据格式。那么JSON到底是什么呢？JSON的定义...

PostgreSQL JSON 类型:处理结构化数据

PostgreSQL提供JSON类型，以存储结构化数据。JSON是一种开放的数据格式，可用于存储各种类型的值。什么是JSON类型？JSON类型表示JSON(JavaScriptO...

JavaScript:JSON、三种包装类（javascript 包）

JOSN:我们希望可以将一个对象在不同的语言中进行传递，以达到通信的目的，最佳方式就是将一个对象转换为字符串的形式JSON（JavaScriptObjectNotation）-JS的对象表示法...

Python数据分析 只要1分钟 教你玩转JSON 全程干货

Json简介：Json，全名JavaScriptObjectNotation,JSON(JavaScriptObjectNotation(记号、标记))是一种轻量级的数据交换格式。它基于J...

比较一下JSON与XML两种数据格式?（json和xml哪个好）

JSON（JavaScriptObjectNotation）和XML（eXtensibleMarkupLanguage）是在日常开发中比较常用的两种数据格式，它们主要的作用就是用来进行数据的传...

取消回复欢迎 你 发表评论:

请填写验证码
一周热门
最近发表
标签列表