【REST2SQL】07 GO 操作 Mysql 数据库

【REST2SQL】01RDB关系型数据库REST初设计
【REST2SQL】02 GO连接Oracle数据库
【REST2SQL】03 GO读取JSON文件
【REST2SQL】04 REST2SQL第一版Oracle版实现
【REST2SQL】06 GO 跨包接口重构代码

MySQL是一个关系型数据库管理系统,由瑞典MySQL AB 公司开发,属于 Oracle旗下产品。MySQL是最流行的关系型数据库管理系统之一,在 WEB 应用方面,MySQL是最好的RDBMS (Relational Database Management System,关系数据库管理系统)应用软件之一。
MySQL是一种关系型数据库管理系统,关系数据库将数据保存在不同的表中,而不是将所有数据放在一个大仓库内,这样就增加了速度并提高了灵活性。
MySQL所使用的 SQL 语言是用于访问数据库的最常用标准化语言。MySQL 软件采用了双授权政策,分为社区版和商业版,由于其体积小、速度快、总体拥有成本低,尤其是开放源码这一特点,一般中小型和大型网站的开发都选择 MySQL作为网站数据库。

1 准备工作

我的操作环境:
操作系统:Win10 x64
数据库: Ver 8.0.35 for Win64 on x86_64 (MySQL Community Server - GPL)
go:1.21.5
LiteIDE : X38.3

1.1 安装Mysql数据

登录 Mysql 官网,有Mysql社区版可以下载,官网下载显示的是32位,实际上安装包里也包括64位的,下载成功后,安装配置等这里省略5217字,我安装后就是64位的,自己脑补。
创建测试表 guci
导入部分测试数据

1.2 Mysql go驱动安装

第三方驱动下载。

go get -u github.com/go-sql-driver/mysql
//其中包含一个依赖库
go get -u filippo.io/edwards25519

众所周知的原因,可能同步失败,自己想办法翻墙或代理等一系列操作。
我这里偶尔能登录github.com网站,我从网站上手动下载下来加到开发环境中的src

2 新建一个gomysql的项目

新建一下gomysql的项目用来测试go操作mysql数据库。

2.1 go连接Mysql数据库

1 引入相关包

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

2 声明连接字符串

var ConnString string = "mysql://blma:5217@tcp(127.0.0.1:3306)/blma"

3 连接数据库

// 连接Mysql数据库
func connDB(connStr string) *sql.DB {
	end := strings.Index(connStr, "://")
	if end < 0 {
		log.Println("连接字符串设置有误。")
		panic(nil)
	}
	driverName := connStr[:end] // dm
	connstring := connStr[end+3:]
	db, err := sql.Open(driverName, connstring)

	dieOnError("Can't open the driver:", err)

	if err = db.Ping(); err != nil {
		fmt.Println("不能连接mysql数据库:", err)
		return nil
	}

	// fmt.Printf("connect to \"%s\" succeed.\n", connStr)
	return db
}

2.2 实现CRUD

CUD比较简单,都执行execSQL操作,只是sql语句不同。
代码如下:

/* 往表插入数据 */
func insertData(insertSql string) string {
	result, _ := execSQL(insertSql)
	rows, err := result.RowsAffected()
	dieOnError("Can't insert", err)
	ret := map[string]int{
		"Insert rowsAffected": int(rows),
	}
	jsonBytes, err := json.Marshal(ret)
	dieOnError("map 转 json失败:", err)
	return string(jsonBytes)
}

/* 删除表数据 */
func deleteData(deleteSql string) string {
	result, _ := execSQL(deleteSql)
	rows, err := result.RowsAffected()
	dieOnError("Can't delete", err)
	ret := map[string]int{
		"Delete rowsAffected": int(rows),
	}
	jsonBytes, err := json.Marshal(ret)
	dieOnError("map 转 json失败:", err)
	return string(jsonBytes)
}

/* 修改表数据 */
func updateData(updateSql string) string {
	result, _ := execSQL(updateSql)
	rows, err := result.RowsAffected()
	dieOnError("Can't update", err)
	ret := map[string]int{
		"Update rowsAffected": int(rows),
	}
	jsonBytes, err := json.Marshal(ret)
	dieOnError("map 转 json失败:", err)
	return string(jsonBytes)
	// var sql =
	// result, err := db.Exec(sql)
	// if err != nil {
	// 	return err
	// }

	// affectedRows, _ := result.RowsAffected()
	// fmt.Println("updateTable succeed Affected rows:", affectedRows)
	// return nil
}

// 执行SQL, execute stmt (INSERT, UPDATE, DELETE, DML, PLSQL) and return driver.Result object
func execSQL(sqls string) (result driver.Result, err error) {
	//连接数据库
	DB := connDB(ConnString)
	//延迟关闭连接
	defer DB.Close()

	statement, err := DB.Prepare(sqls)
	if err != nil {
		fmt.Println("prepare statement failed:", err.Error())
	}
	defer statement.Close()

	//执行SQL, execute stmt (INSERT, UPDATE, DELETE, DML) and return driver.Result object
	result, err = statement.Exec()
	if err != nil {
		fmt.Println("Exec failed:", err.Error())
	}

	dieOnError("Can't execSql() ", err)

	return result, err
}

2.3 动态查询有点费劲

没仔细研究Mysql的驱动,还是用达梦数据库的思路。
总体思路是先查询获取 *sql.Rows对象,从这里通过rows.Columns()和 rows. ColumnTypes()再获取列名切片和列类型信息,第三步把列名和数据库数据类型组合在一个map[string]string里;第四步初始化列值接收变量;第五步 rows.Next() 逐行遍历返回结果集并根据数据库类型(目前只匹配的VARCHER2 和 NUMBER,遇到其它类型再匹配)转换为Go的数据类型,组成一个dataset数据集;第六步序列化并转json返回查询结果。
代码如下:

/* 查询表数据 */
func selectData(sqlSelect string) string {
	// 连接数据库
	DB := connDB(ConnString)
	//延迟关闭连接
	defer DB.Close()

	// 准备查询语句
	statement, err := DB.Prepare(sqlSelect)
	if err != nil {
		fmt.Println("prepare statement failed:", err.Error())
		return ""
	}
	defer statement.Close()
// 1查询
	rows, err := statement.Query()
	if err != nil {
		fmt.Println("query failed:", err.Error())
	}

	// 2查询的列名称切片
	columns, err := rows.Columns()
	if err != nil {
		fmt.Println(err.Error())
		return ""
	}
	//fmt.Println(columns)

	// 3数据库列类型
	cType, err := rows.ColumnTypes()
	if err != nil {
		log.Fatal(err)
	}
	//fmt.Println(cType[0].Name(), cType[0].DatabaseTypeName())
	// 4列名类型map
	coltyp := colType(cType)

// 5初始化列值接收变量
	row := make([]sql.RawBytes, len(columns))
	scanArgs := make([]interface{}, len(row))

	for i := range row {
		scanArgs[i] = &row[i]
	}

	// 查询结果数据集
	var dataset []map[string]interface{} //元素为map的切片

	for rows.Next() {
		err := rows.Scan(scanArgs...)
		if err != nil {
			panic(err.Error())
		}
		// row
		var row1 map[string]interface{} = make(map[string]interface{})
		for pos, col := range row {
			//fmt.Println(columns[pos], ":", string(col))
			colname := columns[pos]
			svalue := string(col)
			//数据类型处理
			value := typeConv(colname, svalue, coltyp)
			row1[colname] = value
		}

		//fmt.Println("row1:", row1)

		dataset = append(dataset, row1)
		//fmt.Println()
	}
	if err != io.EOF {
		dieOnError("Can't Next", err)
	}

	//切片转json
	jsonBytes, err := json.Marshal(dataset)
	dieOnError("slice 转 json失败:", err)
	//fmt.Println(string(jsonBytes))

	return string(jsonBytes)
}

// 生成列名和类型 map
func colType(cType []*sql.ColumnType) map[string]string {
	var colTyp map[string]string = make(map[string]string)
	for _, col := range cType {
		colTyp[col.Name()] = col.DatabaseTypeName()
	}
	//fmt.Println(colTyp)
	return colTyp
}

// 字符根据数据库类型转为go数据类型
func typeConv(colname string, svalue string, ct map[string]string) interface{} {
	var ret interface{}
	switch ct[colname] {
	case "VARCHAR":
		ret = svalue
	case "DECIMAL":
		if len(svalue) > 0 {
			flt, err := strconv.ParseFloat(svalue, 64)
			if err != nil {
				fmt.Println("转换失败:", colname, svalue, err)
			} else {
				ret = flt
			}
		} else { //空串处理
			ret = nil
		}
	default:
		ret = svalue
	}
	return ret
}

3 全部代码及运行结果截图

全部代码:

/*该例程实现了Mysql数据库插入数据,修改数据,删除数据,数据查询等基本操作。*/
package main

// 引入相关包
import (
	"database/sql"
	"database/sql/driver"
	"encoding/json"
	"fmt"
	"io"
	"log"
	"strconv"
	"strings"

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

var ConnString string = "mysql://blma:5217@tcp(127.0.0.1:3306)/blma"

// var ConnString string = config.Conf.ConnString

func main() {
	fmt.Println("\ngo 操作mysql数据库 demo")
	var (
		sqls   string //sql语句
		result string //sql执行后返回的结果
	)

	//显示版本号
	showMysqlVersion()
	// // insert 插入一行数据
	sqls = `INSERT INTO kezz(p_id,s_dm,s_mc,n_zzxj) VALUES(-101,'125217','白龙马',5217);`
	result = insertData(sqls)
	fmt.Println(result)

	// update 更新数据
	sqls = "UPDATE kezz SET n_zzxj = 111 WHERE p_id = -100"
	result = updateData(sqls)
	fmt.Println(result)

	// delete 删除数据
	sqls = "delete from kezz where p_id = -109"
	result = deleteData(sqls)
	fmt.Println(result)

	// select 查询数据
	sqls = "select p_id,s_dm,s_mc,n_zzxj from kezz limit 5 "
	result = selectData(sqls)
	fmt.Println(result)

}

func showMysqlVersion() {
	//连接数据库
	db := connDB(ConnString)

	var version string

	err2 := db.QueryRow("SELECT VERSION()").Scan(&version)

	if err2 != nil {
		log.Fatal(err2)
	}

	fmt.Println("Mysql:", version)
}

// 连接Mysql数据库
func connDB(connStr string) *sql.DB {
	end := strings.Index(connStr, "://")
	if end < 0 {
		log.Println("连接字符串设置有误。")
		panic(nil)
	}
	driverName := connStr[:end] // dm
	connstring := connStr[end+3:]
	db, err := sql.Open(driverName, connstring)

	dieOnError("Can't open the driver:", err)

	if err = db.Ping(); err != nil {
		fmt.Println("不能连接mysql数据库:", err)
		return nil
	}

	// fmt.Printf("connect to \"%s\" succeed.\n", connStr)
	return db
}

// 发生错误退出1
func dieOnError(msg string, err error) {
	if err != nil {
		log.Println(msg, err)
		//os.Exit(1)
	}
}

/* 往表插入数据 */
func insertData(insertSql string) string {
	result, _ := execSQL(insertSql)
	rows, err := result.RowsAffected()
	dieOnError("Can't insert", err)
	ret := map[string]int{
		"Insert rowsAffected": int(rows),
	}
	jsonBytes, err := json.Marshal(ret)
	dieOnError("map 转 json失败:", err)
	return string(jsonBytes)
}

/* 删除表数据 */
func deleteData(deleteSql string) string {
	result, _ := execSQL(deleteSql)
	rows, err := result.RowsAffected()
	dieOnError("Can't delete", err)
	ret := map[string]int{
		"Delete rowsAffected": int(rows),
	}
	jsonBytes, err := json.Marshal(ret)
	dieOnError("map 转 json失败:", err)
	return string(jsonBytes)
}

/* 修改表数据 */
func updateData(updateSql string) string {
	result, _ := execSQL(updateSql)
	rows, err := result.RowsAffected()
	dieOnError("Can't update", err)
	ret := map[string]int{
		"Update rowsAffected": int(rows),
	}
	jsonBytes, err := json.Marshal(ret)
	dieOnError("map 转 json失败:", err)
	return string(jsonBytes)
}

// 执行SQL, execute stmt (INSERT, UPDATE, DELETE, DML, PLSQL) and return driver.Result object
func execSQL(sqls string) (result driver.Result, err error) {
	//连接数据库
	db := connDB(ConnString)
	//延迟关闭连接
	defer db.Close()

	statement, err := db.Prepare(sqls)
	if err != nil {
		fmt.Println("prepare statement failed:", err.Error())
	}
	defer statement.Close()

	//执行SQL, execute stmt (INSERT, UPDATE, DELETE, DML) and return driver.Result object
	result, err = statement.Exec()
	if err != nil {
		fmt.Println("Exec failed:", err.Error())
	}

	dieOnError("Can't execSql() ", err)

	return result, err
}

/* 查询表数据 */
func selectData(sqlSelect string) string {
	// 连接数据库
	db := connDB(ConnString)
	//延迟关闭连接
	defer db.Close()

	// 准备查询语句
	statement, err := db.Prepare(sqlSelect)
	if err != nil {
		fmt.Println("prepare statement failed:", err.Error())
		return ""
	}
	defer statement.Close()
	// 1查询
	rows, err := statement.Query()
	if err != nil {
		fmt.Println("query failed:", err.Error())
	}

	// 2查询的列名称切片
	columns, err := rows.Columns()
	if err != nil {
		fmt.Println(err.Error())
		return ""
	}
	//fmt.Println(columns)

	// 3数据库列类型
	cType, err := rows.ColumnTypes()
	if err != nil {
		log.Fatal(err)
	}
	//fmt.Println(cType[0].Name(), cType[0].DatabaseTypeName())
	// 4列名类型map
	coltyp := colType(cType)

	// 5初始化列值接收变量
	row := make([]sql.RawBytes, len(columns))
	scanArgs := make([]interface{}, len(row))

	for i := range row {
		scanArgs[i] = &row[i]
	}

	// 查询结果数据集
	var dataset []map[string]interface{} //元素为map的切片

	for rows.Next() {
		err := rows.Scan(scanArgs...)
		if err != nil {
			panic(err.Error())
		}
		// row
		var row1 map[string]interface{} = make(map[string]interface{})
		for pos, col := range row {
			//fmt.Println(columns[pos], ":", string(col))
			colname := columns[pos]
			svalue := string(col)
			//数据类型处理
			value := typeConv(colname, svalue, coltyp)
			row1[colname] = value
		}

		//fmt.Println("row1:", row1)

		dataset = append(dataset, row1)
		//fmt.Println()
	}
	if err != io.EOF {
		dieOnError("Can't Next", err)
	}

	//切片转json
	jsonBytes, err := json.Marshal(dataset)
	dieOnError("slice 转 json失败:", err)
	//fmt.Println(string(jsonBytes))

	return string(jsonBytes)
}

// 生成列名和类型 map
func colType(cType []*sql.ColumnType) map[string]string {
	var colTyp map[string]string = make(map[string]string)
	for _, col := range cType {
		colTyp[col.Name()] = col.DatabaseTypeName()
	}
	//fmt.Println(colTyp)
	return colTyp
}

// 字符根据数据库类型转为go数据类型
func typeConv(colname string, svalue string, ct map[string]string) interface{} {
	var ret interface{}
	switch ct[colname] {
	case "VARCHAR":
		ret = svalue
	case "DECIMAL":
		if len(svalue) > 0 {
			flt, err := strconv.ParseFloat(svalue, 64)
			if err != nil {
				fmt.Println("转换失败:", colname, svalue, err)
			} else {
				ret = flt
			}
		} else { //空串处理
			ret = nil
		}
	default:
		ret = svalue
	}
	return ret
}


运行结果截图:

在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/307636.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【Spring Boot】SpringBoot maven 项目创建图文教程

创建一个Spring Boot项目并使用Maven进行构建是一项相对简单的任务。以下是使用IntelliJ IDEA创建Spring Boot Maven项目的详细教程&#xff1a; 步骤 1&#xff1a;安装 IntelliJ IDEA 确保你已经安装了最新版本的 IntelliJ IDEA。你可以从官方网站下载并安装。 步骤 2&am…

构建高效学习平台:企业培训系统源码深度解析

企业培训系统是组织中培养和提升员工技能的核心工具。本文将深入探讨企业培训系统的源码&#xff0c;通过关键技术代码解析&#xff0c;揭示其中的设计原理和功能实现&#xff0c;以构建更高效的学习平台。 1. 环境配置与依赖项安装 首先&#xff0c;让我们关注源码的环境配…

小测一下HCL中VSR的转发性能

正文共&#xff1a;555 字 10 图&#xff0c;预估阅读时间&#xff1a;1 分钟 上次我们在HCL中导入了NFV的自定义镜像&#xff08;如何在最新版的HCL 5.10.0中导入NFV镜像&#xff1f;&#xff09;&#xff0c;但是当时没有测试转发性能&#xff0c;最近HCL又更新了V5.10.1版本…

电脑文件mfc100u.dll丢失的解决方法分析,怎么修复mfc100u.dll靠谱

mfc100u.dll丢失了要怎么办&#xff1f;其实很多人都遇到过这样的电脑故障吧&#xff0c;说这个mfc100u.dll文件已经不见了&#xff0c;然后一些程序打不开了&#xff0c;那么这种情况我们要怎么解决呢&#xff1f;今天我们就来给大家详细的说说mfc100u.dll丢失的解决方法。 一…

虚拟机安装intel架构的银河麒麟V10(SP1)

一 背景 银河麒麟是国产操作系统之一&#xff0c;是基于Linux内核的桌面操作系统&#xff0c;有自己的应用中心&#xff0c;具有一定的生态系统。今从官网下载了V10&#xff08;SP1&#xff09;镜像文件&#xff0c;在Windowns的VMware虚拟机上安装试用。 官网&#xff1a;http…

ylov8的训练和预测使用(目标检测)

首先要配置文文件 1-配置数据集的yaml文件&#xff1a; 目录在ultralytics/cfg/datasets/下面&#xff1a; 例如我的&#xff1a; (这里面的yaml文件在/ultralytics/cfg/datasets下面有很多&#xff0c;可以找几个参考一下) path: /path/to/eye_datasets # dataset root di…

使用cURL命令在Linux中测试HTTP服务器的性能

cURL是一个强大的命令行工具&#xff0c;用于从或向服务器传输数据。它支持多种协议&#xff0c;包括HTTP、HTTPS、FTP等。在Linux系统中&#xff0c;cURL可以用于测试和评估HTTP服务器的性能。下面是一些使用cURL命令测试HTTP服务器性能的示例和说明。 1. 基本请求 要向指定…

虚幻引擎:开创视觉与创意的新纪元

先看看据说虚幻5做出来的东西吧&#xff1a; 虚幻引擎5&#xff01;&#xff01;&#xff01;4K画质PS5实机演示&#xff01; 好了&#xff0c;用文字认识一下吧&#xff1a; 虚幻引擎5.3对UE5的核心工具集作了进一步优化&#xff0c;涉及渲染、世界构建、程序化内容生成&…

怀念母校《山东海天软件工程学院》

当初就是个统招专科的分数&#xff0c;因个人喜欢英语和计算机&#xff0c;加之学校宣传学历技能培训&#xff0c;于是参加了夏令营&#xff0c;后来在海天度过了大学时光&#xff0c;有技术社团&#xff0c;有爱好社团&#xff0c;也参加了比赛&#xff0c;顺利实习&#xff0…

15-sharding-jdbc入门-基于inline模式实现水平分库分表__ev

水平分库分表&#xff1a; 将下面的数据库 order_db_1 ├── t_order_1 └── t_order_2 垂直分库分表到 order_db_2 ├── t_order_1 └── t_order_2 新建src/main/resources/application-test2.properties文件&#xff0c;在src/main/resources/application…

SD-WAN网关监控异地组网

SD-WAN网关监控异地组网是指利用SD-WAN网关对远程网络设备进行监控与管理&#xff0c;确保网络连接的稳定性与安全性。这种智能网络设备支持多种连接方式&#xff08;比如MPLS、互联网或无线网络&#xff09;&#xff0c;能够智能地选择最佳网络连接路径&#xff0c;以确保异地…

day 43动态规划(5)

day 43 代码随想录 2024.1.10 发烧中。。。简单过一遍等二刷DP问题&#xff01;&#xff08;最近赶一篇paper&#xff01;&#xff09; 1. 1049最后一块石头的重量 dp[j]表示容量&#xff08;这里说容量更形象&#xff0c;其实就是重量&#xff09;为j的背包&#xff0c;最多…

如何加密U盘数据?U盘数据加密软件怎么选?

U盘作为最常用的移动储存设备&#xff0c;是很多人储存数据的重要工具。而普通的U盘不具备保护数据的功能&#xff0c;很容易导致数据泄露。因此&#xff0c;我们需要使用专业的U盘加密软件来加密保护U盘数据。那么&#xff0c;U盘数据加密软件该怎么选择呢&#xff1f;下面我们…

JAVA毕业设计119—基于Java+Springboot+vue的智能停车场管理系统(源代码+数据库+9000字论文)

毕设所有选题&#xff1a; https://blog.csdn.net/2303_76227485/article/details/131104075 基于JavaSpringbootvue的智能停车场管理系统(源代码数据库9000字论文)119 一、系统介绍 本项目前后端不分离 登录、控制台、停车场管理、车牌识别、车辆管理角色管理、系统菜单、…

人体姿态识别(附教程+代码)

人体姿态识别&#xff08;Human Pose Estimation&#xff09;是一种基于计算机视觉和深度学习的技术&#xff0c;用于自动检测和识别人体的姿态和动作。它可以在图像或视频中准确地确定人体各个关节的位置和运动。 人体姿态识别技术具有广泛的应用领域。在健身和运动领域&…

酿酒生产废水处理设备如何选型

选型酿酒生产废水处理设备是确保废水处理过程高效稳定的关键步骤。酿酒生产过程中&#xff0c;产生的废水中含有大量有机物和悬浮物&#xff0c;因此需要选择适合的设备来进行处理。 首先&#xff0c;要根据酿酒生产废水的特点进行选型。酿酒废水的主要特点是&#xff1a;水量较…

unity C#中使用ref、out区别和使用案例

文章目录 ref 关键字out 关键字 在Unity&#xff08;以及C#编程语言中&#xff09;&#xff0c; ref 和 out 都是用来传递参数的引用&#xff0c;这意味着它们允许函数修改实参变量&#xff0c;并且这些修改会反映到调用函数的地方。但它们之间确实存在一些关键区别和使用场景…

golang中的循环依赖

作为 Golang 开发人员&#xff0c;您可能遇到过导入周期。Golang 不允许导入循环。如果 Go 检测到代码中的导入循环&#xff0c;则会抛出编译时错误。在这篇文章中&#xff0c;让我们了解导入周期是如何发生的以及如何处理它们。 导入周期 假设我们有两个包&#xff0c;p1并且…

phpcms v9后台添加草稿箱功能

一、后台添加文章模板phpcms/modules/content/templates/content_add.tpl.php中94行增加”保存草稿“按钮&#xff1a; <div class"button"><input value"<?php echo L(save_draft);?>" type"submit" name"dosubmit_draf…

Qt5插件开发入门+示例

目的 1、为什么用插件 现在大家最讲模块化开发了,怎么算模块化,分成不同的类,分成不同的文件夹,高内聚,低耦合,这个当然算是。 从高层次讲,它们是在一起的,只是逻辑上的模块化,不是物理上的模块化,或者说不是彻底的模块化,彻底的模块化应该像一个辆自行车一样,车…