GO框架基础 (三)、xorm库

xorm介绍

官网:https://xorm.io/
git文档:https://github.com/go-xorm/xorm
xorm 是一个 Go 语言的 ORM(对象关系映射)库,它提供了一种简单、高效的方式来将 Go 语言中的结构体与数据库表进行映射,并提供了丰富的功能来进行数据库操作。

以下是 xorm 的一些特点和功能:

  1. 支持多种数据库: xorm 支持多种数据库,包括 MySQL、PostgreSQL、SQLite、Microsoft SQL Server、Oracle 等。

  2. 灵活的映射规则: 通过标签(tag)或者方法可以自定义结构体字段和数据库表字段之间的映射关系。

  3. 自动建表: xorm 支持根据结构体自动创建数据库表,也可以根据数据库表自动生成相应的结构体。

  4. 链式操作: xorm 支持链式操作,可以方便地构建复杂的 SQL 查询。

  5. 事务支持: xorm 支持事务操作,可以确保多个数据库操作的原子性。

  6. 缓存支持: xorm 提供了缓存机制,可以提高数据库查询的性能。

  7. 监听器: xorm 支持事件监听器,可以监听数据库操作的各个阶段,并执行相应的逻辑。

  8. SQL 日志: xorm 提供了 SQL 日志功能,可以记录数据库操作的 SQL 语句和执行时间,方便调试和性能优化。

  9. 适用于 Web 开发: xorm 与 Beego、Gin 等常用的 Go Web 框架集成良好,可以方便地在 Web 应用中使用。

  10. 社区活跃: xorm 是一个开源项目,拥有活跃的开发者社区,提供了丰富的文档和示例。

使用 xorm 可以帮助开发人员简化数据库操作,并提高开发效率。它提供了许多便利的功能和灵活的配置选项,适用于各种规模的项目。

GO安装xorm

	go get xorm.io/xorm

xorm连接数据库

使用xorm.NewEngine(“mysql”, dbStr)连接数据库

package mainimport ("fmt"_ "github.com/go-sql-driver/mysql""time""xorm.io/xorm"
)// 准备链接参数信息
var (userName  string = "root"passWord  string = "12345678"ipAddress string = "127.0.0.1"port      string = "3306"dbName    string = "xorm_test"charset   string = "utf8mb4"
)func main() {dbStr := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=%s", userName,passWord,ipAddress,port,dbName,charset)engine, err := xorm.NewEngine("mysql", dbStr)if err != nil {fmt.Println(err)}
}

xorm同步结构体致数据表

通过engine.Sync将结构体生成表,执行后会在xorm_test中生成一张User表

func main() {dbStr := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=%s", userName,passWord,ipAddress,port,dbName,charset)engine, err := xorm.NewEngine("mysql", dbStr)if err != nil {fmt.Println(err)}type User struct {Id      int64Name    stringSalt    stringAge     intPasswd  string    `xorm:"varchar(200)"`Created time.Time `xorm:"created"`Updated time.Time `xorm:"updated"`}//	数据同步,将结构体同步至数据库err1 := engine.Sync(new(User))if err1 != nil {fmt.Println(err1)}
}

exec

exec函数可以搭配所有sql语句来执行相应操作。

	//exec  函数+sql语句 ? 为占位符engine.Exec("update user set age = ? where id = ?", 10, 1003)

插入数据

通过Insert来向数据库中单个或批量添加数据。

	affected, err := engine.Insert(&user)// INSERT INTO struct () values ()affected, err := engine.Insert(&user1, &user2)// INSERT INTO struct1 () values ()// INSERT INTO struct2 () values ()affected, err := engine.Insert(&users)// INSERT INTO struct () values (),(),()affected, err := engine.Insert(&user1, &users)// INSERT INTO struct1 () values ()// INSERT INTO struct2 () values (),(),()
	//数据插入user1 := User{Id: 1000, Name: "xiaohong", Age: 18, Passwd: "123456"}user2 := User{Id: 1001, Name: "xiaoming", Age: 18, Passwd: "123456"}n, _ := engine.Insert(&user1, &user2)fmt.Println(n)if n >= 1 {fmt.Println("插入成功")}//批量插入  切片var users []Userusers = append(users, User{Id: 1002, Name: "xiaolan", Age: 18, Passwd: "123456"})users = append(users, User{Id: 1003, Name: "xiaohei", Age: 18, Passwd: "123456"})n1, _ := engine.Insert(&users)fmt.Println(n1)if n1 >= 1 {fmt.Println("插入成功")}

更新与删除数据

	affected, err := engine.ID(1).Update(&user)// UPDATE user SET ... Where id = ?affected, err := engine.Update(&user, &User{Name:name})// UPDATE user SET ... Where name = ?var ids = []int64{1, 2, 3}affected, err := engine.In("id", ids).Update(&user)// UPDATE user SET ... Where id IN (?, ?, ?)// force update indicated columns by Colsaffected, err := engine.ID(1).Cols("age").Update(&User{Name:name, Age: 12})// UPDATE user SET age = ?, updated=? Where id = ?// force NOT update indicated columns by Omitaffected, err := engine.ID(1).Omit("name").Update(&User{Name:name, Age: 12})// UPDATE user SET age = ?, updated=? Where id = ?affected, err := engine.ID(1).AllCols().Update(&user)// UPDATE user SET name=?,age=?,salt=?,passwd=?,updated=? Where id = ?affected, err := engine.Where(...).Delete(&user)// DELETE FROM user Where ...affected, err := engine.ID(2).Delete(&user)// DELETE FROM user Where id = ?
	upUser := User{Name: "lyh11"}upn, _ := engine.ID(1000).Update(upUser)fmt.Println(upn)if upn >= 1 {fmt.Println("更新成功")}deln, _ := engine.ID(1002).Delete(&User{})fmt.Println(deln)if deln >= 1 {fmt.Println("删除成功")}

条件查询与遍历输出

	//Query  字节切片  字符串切片  map切片  直接写sql语句进行查询res, _ := engine.Query("select * from user")fmt.Println(res)res1, _ := engine.QueryString("select * from user")fmt.Println(res1)res2, _ := engine.QueryInterface("select * from user")fmt.Println(res2)//Get 没条件,查询到数据库里的第一条数据user := User{}engine.Get(&user)fmt.Println(user)//指定条件查询  加条件user1 := User{Name: "xiaohong"}engine.Where("name=?", user1.Name).Desc("id").Get(&user1)fmt.Println(user1)//获取指定的值 将name拿出来单独赋值var name stringengine.Table(&user).Where("id=1001").Cols("name").Get(&name)fmt.Println(name)//查询多条记录var users []Userengine.Where("passwd=123456").And("age=18").Limit(10, 0).Find(&users)fmt.Println(1, users)//count 获取条数user2 := User{Name: "xiaoming"}total, _ := engine.Count(&user2)fmt.Println(total)//遍历 Iterate   rowsuser3 := User{Name: "xiaohong"}engine.Iterate(&user3, func(idx int, bean interface{}) error {fmt.Println(1, bean)fmt.Println(2, bean.(*User))return nil})rows, _ := engine.Rows(&user3)defer rows.Close()userBean := new(User)for rows.Next() {rows.Scan(userBean)fmt.Println(33, userBean)}

事务处理

在数据库操作中,事务(Transaction)是指由一系列操作组成的逻辑工作单元,这些操作要么全部成功执行,要么全部回滚(撤销),以确保数据库的一致性和完整性。

	session := engine.NewSession()defer session.Close()session.Begin()// 通过panic将恐慌抛出,并做回滚处理defer func() {err := recover()fmt.Println(err)if err != nil {session.Rollback()} else {session.Commit()}}()user4 := User{Id: 1009, Name: "xiaoming1", Passwd: "123456"}if _, err := session.Insert(&user4); err != nil {panic(err)}user5 := User{Name: "xiaohaung"}if _, err := session.Where("id=1000").Update(&user5); err != nil {panic(err)}if _, err := session.Where("name='aaa'").Delete(&User{}); err != nil {panic(err)}

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

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

相关文章

[OpenAI]继ChatGPT后发布的Sora模型解析与体验通道

前言 前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家:https://www.captainbed.cn/z ChatGPT体验地址 文章目录 前言OpenAI体验通道Spacetime Latent Patches 潜变量时空碎片, 建构视觉语言系统…

【RHCE】shell条件测试练习

目录 1、判断当前磁盘剩余空间是否有20G,如果小于20G,则将报警邮件发送给管理员,每天检查次磁盘剩余空间。 2、判断web服务是否运行 3、使用curl命令访问第二题的web服务,看能否正常访问,如果能正常访问,…

计算机网络-H3C网络端口基础信息与配置

一、网络端口基础信息与配置 这个主要是记录一下关于华三的交换机、防火墙和路由器的物理接口的一些基础知识与配置。 1.1 命名规范 H3C的端口命名主要是根据端口的速率来进行区分的。基本都是千兆速率往上的,百兆的端口比较多用于二层傻瓜交换机或者不能CLI管理的。…

《戴森球计划》好玩吗?《戴森球计划》怎么在苹果电脑上安装 戴森球计划攻略 Mac游戏推荐

《戴森球计划》是一款具有强大现实科学基础的模拟策略游戏,玩家的目标是构建能源效率极高的戴森球以解决能源问题。游戏的背景设定启发于科幻作品中的戴森球概念。游戏采用逼真的物理模拟,玩家需要合理规划资源,以应对复杂的能源危机。那么《…

【LeetCode+JavaGuide打卡】Day20|530.二叉搜索树的最小绝对差、501.二叉搜索树中的众数、236. 二叉树的最近公共祖先

学习目标: 530.二叉搜索树的最小绝对差 501.二叉搜索树中的众数 236. 二叉树的最近公共祖先 学习内容: 530.二叉搜索树的最小绝对差 题目链接&&文章讲解 给你一个二叉搜索树的根节点 root ,返回 树中任意两不同节点值之间的最小差值…

C语言easyx飞机大战源码+素材

飞机大战游戏完整源码 一、项目背景 在数字娱乐飞速发展的今天,电子游戏已经成为许多人生活中不可或缺的一部分。飞机大战,作为一款经典的射击游戏,以其简单易上手、刺激好玩的特点,深受玩家的喜爱。本项目旨在利用EasyX图形库,为玩家呈现一个全新的飞机大战游戏体验。 …

【计算机网络】网络编程套接字UDP服务器客户端的简单模拟

需要云服务器等云产品来学习Linux的同学可以移步/–>腾讯云<–/官网&#xff0c;轻量型云服务器低至112元/年&#xff0c;优惠多多。&#xff08;联系我有折扣哦&#xff09; 文章目录 1. 前置知识1.1 源IP和目的IP1.2 端口号1.3 TCP协议和UDP协议初识1.4 网络字节序1.5 …

C# OpenCvSharp DNN Low Light image Enhancement

目录 介绍 效果 模型信息 项目 代码 下载 C# OpenCvSharp DNN Low Light image Enhancement 介绍 github地址&#xff1a;https://github.com/zhenqifu/PairLIE 效果 模型信息 Model Properties ------------------------- ------------------------------------------…

文献学习-1-Continuum Robots for Medical Interventions

Chapt 5. 连续体机构分析 5.1 文献学习 5.1.1 Continuum Robots for Medical Interventions Authors: PIERRE E. DUPONT , Fellow IEEE, NABIL SIMAAN , Fellow IEEE, HOWIE CHOSET , Fellow IEEE, AND CALEB RUCKER , Member IEEE 连续体机器人在医学上得到了广泛的应用&a…

卷积神经网络的基本结构

卷积神经网络的基本结构 与传统的全连接神经网络一样&#xff0c;卷积神经网络依然是一个层级网络&#xff0c;只不过层的功能和形式发生了变化。 典型的CNN结构包括&#xff1a; 数据输入层&#xff08;Input Layer&#xff09;卷积层&#xff08;Convolutional Layer&#x…

Avalonia学习(二十四)-系统界面

目前项目式练习&#xff0c;界面内容偏多&#xff0c;所以不给大家贴代码了&#xff0c;可以留言交流。此次为大家展示的是物联项目的例子&#xff0c;仅仅是学习&#xff0c;我把一些重点列举一下。 界面无边框 以前的样例主要是通过实现控件来完成的&#xff0c;前面已经有窗…

Linux命令:stat命令

目录 1 简介2 说明3 实例-L&#xff1a;显示链接指向的文件的信息-f&#xff1a;显示文件系统信息-t&#xff1a;以简洁的形式输出 1 简介 stat命令&#xff1a;显示文件或文件系统的状态 2 说明 使用&#xff1a;stat [OPTION]… FILE 常用选项&#xff1a; -L, --derefer…

c语言游戏实战(9):球球大作战

前言&#xff1a; 这款简易版的球球大作战是一款单人游戏&#xff0c;玩家需要控制一个小球在地图上移动&#xff0c;吞噬其他小球来增大自己的体积。本游戏使用C语言和easyx图形库编写&#xff0c;旨在帮助初学者了解游戏开发的基本概念和技巧。 在开始编写代码之前&#xf…

新算法UoT助力AI提问——主动寻求信息,任务完成率提高57.8%

引言&#xff1a;信息寻求在不确定性环境中的重要性 在不确定性环境中&#xff0c;信息寻求的能力至关重要。在许多实际应用中&#xff0c;如医学诊断和故障排除&#xff0c;解决任务所需的信息并非一开始就给出&#xff0c;而需要通过提问后续问题来主动寻求&#xff08;例如…

使用AndroidStudio调试Framework

1.前言 最近在工作过程中&#xff0c;涉及到FW的一些修改&#xff0c;比如PhoneWindowManager&#xff0c;只能通过加日志看打印的方式查看一些内容&#xff0c;比较低效&#xff0c;所以想了解一下FW的调试方式&#xff0c;后来发现AS就可以调试FW.我平时都是在Docker服务器编…

K8S部署MySQL主从环境

1.创建mysql主从环境的命名空间 [rootk8s-master1 mysql]# kubectl create ns mysql namespace/mysql created2.创建master的pvc [rootk8s-master1 mysql]# cat mysql-master-pvc.yaml apiVersion: v1 kind: PersistentVolumeClaim metadata:name: mysql-pvcnamespace: mysql…

人工智能专业python论文毕设方向推荐

文章目录 0 前言1 如何选题1.1 选题技巧&#xff1a;如何避坑(重中之重)1.2 为什么这么说呢&#xff1f;1.3 难度把控1.4 题目名称1.5 最后 2 选题推荐2.1 &#x1f525;&#x1f525; 数据分析可视化选题推荐 &#x1f525;&#x1f525;2.2 &#x1f525;&#x1f525; 算法类…

网站管理新利器:免费在线生成 robots.txt 文件!

&#x1f916; 探索网站管理新利器&#xff1a;免费在线生成 robots.txt 文件&#xff01; 你是否曾为搜索引擎爬虫而烦恼&#xff1f;现在&#xff0c;我们推出全新的在线 robots.txt 文件生成工具&#xff0c;让你轻松管理网站爬虫访问权限&#xff0c;提升网站的可搜索性和…

代码随想录算法训练营——总结篇

不知不觉跟完了代码训练营为期两个月的训练&#xff0c;现在来做个总结吧~ 记得去年12月上旬的时候&#xff0c;我每天都非常浮躁。一方面&#xff0c;经历了三个多月的秋招&#xff0c;我的日常学习和实验室进展被完全打乱&#xff0c;导致状态很差&#xff1b;另一方面&#…

Redis(十四)双写一致性工程案例

文章目录 问题概述canal功能安装部署mysql配置canal服务端canal客户端&#xff08;Java程序&#xff09; 问题概述 canal https://github.com/alibaba/canal 功能 数据库镜像数据库实时备份索引构建和实时维护(拆分异构索引、倒排索引等)业务 cache 刷新带业务逻辑的增量数据…