【REST2SQL】07 GO 操作 Mysql 数据库

【REST2SQL】01RDB关系型数据库REST初设计
【REST2SQL】02 GO连接Oracle数据库
【REST2SQL】03 GO读取JSON文件
【REST2SQL】04 REST2SQL第一版Oracle版实现
【REST2SQL】05 GO 操作 达梦 数据库
【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] // dmconnstring := 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 objectresult, 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列名类型mapcoltyp := 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())}// rowvar 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)}//切片转jsonjsonBytes, 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 = svaluecase "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.ConnStringfunc 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 stringerr2 := 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] // dmconnstring := 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 objectresult, 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列名类型mapcoltyp := 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())}// rowvar 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)}//切片转jsonjsonBytes, 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 = svaluecase "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
}

运行结果截图：

在这里插入图片描述

完

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

什么是编程思路？如何训练提升自己的编程思路？

什么是编程思路？如何训练提升自己的编程思路？

哈喽&#xff0c;大家上午好呀&#xff01;又和大家如期见面了&#xff01; 今天给大家分享改变编程思路的9条技巧。 1.拆分项目&#xff0c;再编程 先按大类写子程序&#xff0c;例如自动&#xff0c;手动&#xff0c;报警&#xff0c;然后子程序中写FB块&#xff0c;FC程序&…
阅读更多...
el-upload实现可替换、删除、预览的图片上传。js 往返缓存（可判断当前页面是不是返回的页面）

el-upload实现可替换、删除、预览的图片上传。js 往返缓存（可判断当前页面是不是返回的页面）

el-upload实现可替换、删除、预览的图片上传 组件使用&#xff1a; <template><div><UploadImage sendUrl :limit"1" :size"size" :gifSize"gifSize" v-model"images"></UploadImage> </div> </tem…
阅读更多...
【Linux】Linux系统编程——Linux目录结构

【Linux】Linux系统编程——Linux目录结构

Linux的文件系统呈现为一种树状结构&#xff0c;以根目录/为最顶层&#xff0c;其下分布着各种不同的子目录&#xff0c;每个目录都有其特定的用途和功能。下面是Linux目录结构的详细介绍&#xff1a; 1. 根目录 / 根目录是整个文件系统的基础。所有的目录和文件都从这里开始…
阅读更多...
LeetCode刷题13:回溯+剪枝解决216.组合总和 III

LeetCode刷题13:回溯+剪枝解决216.组合总和 III

找出所有相加之和为 n 的 k 个数的组合&#xff0c;且满足下列条件&#xff1a; 只使用数字1到9每个数字 最多使用一次 返回 所有可能的有效组合的列表 。该列表不能包含相同的组合两次&#xff0c;组合可以以任何顺序返回。 示例 1: 输入: k 3, n 7 输出: [[1,2,4]] 解…
阅读更多...
阿里云c8i服务器CPU性能、架构及费用测评

阿里云c8i服务器CPU性能、架构及费用测评

阿里云第八代云服务器ECS计算型c8i实例&#xff0c;CPU采用Intel Xeon Emerald Rapids或者Intel Xeon Sapphire Rapids&#xff0c;主频不低于2.7 GHz&#xff0c;全核睿频3.2&#xff0c;阿里云百科aliyunbaike.com分享阿里云c8i服务器CPU处理器型号、存储、网络、安全、使用场…
阅读更多...
子域名收集

子域名收集

目录 1、OneForAll 2、利用Google的搜索 3、fofa 4、使用在线查询网站查询 5、利用ip反查 6、Layer子域名挖掘机 7、JSFinder 用法 在进行渗透的过程中有一个很重要的工作就是信息收集&#xff0c;而信息收集中的子域名收集是很重要的一项工作&#xff0c;在本篇中我会给大…
阅读更多...
绝地求生：【PC】2024年1月商店更新

绝地求生：【PC】2024年1月商店更新

亲爱的玩家朋友们&#xff0c;大家好&#xff01; 欢迎大家来到闲游盒2024年首次商店更新&#xff01; 我们在1月商店更新中准备了全新生存通行证&#xff1a;龙腾&#xff0c;彩色烟雾皮肤&#xff0c;地狱天使 VS 天堂恶魔系列皮肤&#xff0c;相信大家一定会喜欢~ 实用腰带…
阅读更多...
Linux操作系统——进程控制（三） 进程程序替换

Linux操作系统——进程控制（三） 进程程序替换

前言 目前我们接触到我们所创建的所有的子进程&#xff0c;它执行的代码都是父进程代码的一部分&#xff01;那么如果我们想让子进程执行新的程序呢&#xff1f;&#xff1f;&#xff1f;执行全新的代码和访问全新的数据&#xff0c;不在和父进程有瓜葛&#xff0c;我们该怎么…
阅读更多...
一文详解向量数据库Milvus Cloud动态 Schema

一文详解向量数据库Milvus Cloud动态 Schema

在数据库中&#xff0c;Schema 常有&#xff0c;而动态 Schema 不常有。 例如&#xff0c;SQL 数据库有预定义的 Schema&#xff0c;但这些 Schema 通常都不能修改&#xff0c;用户只有在创建时才能定义 Schema。Schema 的作用是告诉数据库使用者所希望的表结构&#xff0c;确…
阅读更多...
如何利用 NFTScan Portfolio 功能分析钱包 NFT 持仓

如何利用 NFTScan Portfolio 功能分析钱包 NFT 持仓

随着 NFT 市场的扩大和投资者的增加&#xff0c;追踪和管理大量 NFT 资产正变得越来越复杂&#xff0c;无论是新手还是资深投资者&#xff0c;都需要借助实时的 NFT 数据作为判断依据。因此&#xff0c;一个能够全面分析 NFT 钱包持仓的工具就显得尤为重要。帮助投资者掌握自身…
阅读更多...
bootstrap搭建一个简单的官网案例附代码

bootstrap搭建一个简单的官网案例附代码

bootstrap搭建一个简单的官网案例附代码 效果常用属性完整代码 效果 大概的效果如下 主要都是用bootstrap的代码实现的 网站是照着 b站视频做的 查看视频教程 建议自己先看一遍文档再跟着视频写&#xff0c;不然可能看不懂 bootstarp中文文档 logo是从别人的站上扒的有点不太协…
阅读更多...
阿里巴巴提出AnyText:首个解决多语言视觉文本生成的工作

阿里巴巴提出AnyText:首个解决多语言视觉文本生成的工作

基于扩散模型的文本到图像在最近取得了令人瞩目的成就。尽管当前的图像合成技术已经非常先进&#xff0c;能够以高保真度生成图像&#xff0c;但当关注生成图像中的文本区域时&#xff0c;往往可能会暴露问题&#xff0c;因为合成文本通常包含模糊、不可读或不正确的字符&#…
阅读更多...
firewalld高级配置

firewalld高级配置

IP伪装与端口转发 在互联网发展初期&#xff0c;设计者们并没有想到互联网会发展到现在这个空前繁荣的阶段&#xff0c;所以&#xff0c;设 计的Pv4地址空间只有32位.但是随着互联网的发展&#xff0c;P地址变得严重缺乏&#xff0c;并且地址分配不均匀&#xff0c; 所以就在原…
阅读更多...
设计模式-规格模式

设计模式-规格模式

设计模式专栏 模式介绍模式特点应用场景规格模式和策略模式的区别和联系代码示例Java实现规格模式Python实现规格模式 规格模式在spring中的应用 模式介绍 规格模式&#xff08;Specification Pattern&#xff09;是一种行为设计模式&#xff0c;其目的是将业务规则封装成可重…
阅读更多...
AIGC实战——改进循环神经网络

AIGC实战——改进循环神经网络

AIGC实战——改进循环神经网络 0. 前言1. 堆叠循环网络2. 门控制循环单元3. 双向单元相关链接 0. 前言 我们已经学习了如何训练长短期记忆网络 (Long Short-Term Memory Network, LSTM) 模型&#xff0c;以学习使用给定风格生成文本&#xff0c;接下来&#xff0c;我们将学习如…
阅读更多...
OceanBase原生分布式数据库

OceanBase原生分布式数据库

1.历史背景 在Java Web项目中&#xff0c;常常使用免费开源的MySQL数据库存储业务数据&#xff0c;按业界经验MySQL单库超过多大数据体量&#xff0c;或单表超过几百万条数据后就会出现查询变慢的情况&#xff0c;单实例数据库只能扩展物理资源(CPU、内存)&#xff0c;来提升查…
阅读更多...
vivado 工程管理

vivado 工程管理

管理项目 打开项目 当项目打开时&#xff0c;Vivado IDE会从项目已关闭。项目状态包括当前源文件顺序、已禁用和已启用 源文件、活动约束文件和目标约束文件&#xff0c;以及合成、模拟和实现运行。要打开项目&#xff0c;请使用以下方法之一&#xff1a; •在“入门”页面…
阅读更多...
麦芯(MachCore)开发教程1 --- 设备软件中间件

麦芯(MachCore)开发教程1 --- 设备软件中间件

黄国强 2024/1/10 acloud163.com 对任何公司来说&#xff0c;在短时间内开发一款高质量设备专用软件&#xff0c;是一件不太容易做到的事情。麦芯是笔者发明的一款设备软件中间件产品。麦芯致力于给设备厂商提供一个开发工具和平台&#xff0c;让客户快速高效的开发自己的设备专…
阅读更多...
异构图 神经网络xFraud :Explaniable Fraud transcation detection

异构图 神经网络xFraud :Explaniable Fraud transcation detection

适用于异构图 2. 使用图进行异常检测 https://github.com/safe-graph/graph-fraud-detection-papers
阅读更多...
Android 通知简介

Android 通知简介

Android 通知简介 1. 基本通知 图1: 基本通知详情 小图标 : 必须提供,通过 setSmallIcon( ) 进行设置.应用名称 : 由系统提供.时间戳 : 由系统提供,也可隐藏时间.大图标(可选) : 可选内容(通常仅用于联系人照片,请勿将其用于应用图标),通过setLargeIcon( ) 进行设置.标题 : 可选…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023