XORM 框架的使用

1、xorm

1.1、xorm 简介

xorm 是一个简单而强大的Go语言ORM库. 通过它可以使数据库操作非常简便。

特性

  • 支持 struct 和数据库表之间的灵活映射,并支持自动同步
  • 事务支持
  • 同时支持原始SQL语句和ORM操作的混合执行
  • 使用连写来简化调用
  • 支持使用ID, In, Where, Limit, Join, Having, Table, SQL, Cols等函数和结构体等方式作为条件

1.2、安装环境

go get xorm.io/xorm

 1.3、快速开始

基本的连接信息

    var (username string = "root"password string = "xxxxxx"ip string = "127.0.0.1"port int = 3306dbName = "go_web"charset string = "utf8mb4")dataSource := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?charset=%s",username ,password,ip ,port ,dbName ,charset )

1.3.1、同步结构体到数据库

1. 创建引擎
    // 1. 创建引擎engine, err := xorm.NewEngine("mysql", dataSource)if err!=nil {println("连接失败")}
2. 创建结构体

        结构体中的每个字段都将对应一个表的字段,我们可以通过标签来告诉 xorm 同步到数据库或使用什么数据类型:

    // 2. 创建结构体type User struct {Id int64Name stringAge intPassword string `xorm:"varchar(200)"`Created time.Time `xorm:"created"`Updated time.Time `xorm:"updated"`}
3. 同步结构体
    // 3. 同步结构体err = engine.Sync(new(User))if err!=nil {println("创建表格失败")}

        同步结构体这个操作可以执行多次,如果我们删除了字段,只需要重新同步即可。但是如果修改了字段,就会把修改后的字段作为一个新的字段,所以一定要注意。

1.3.1、单条数据的插入

        插入数据需要使用 Insert 方法,这个方法需要传入一个对象的指针,因为我们知道,方法中的参数是形参,而且结构体类型是值类型,所以进入 Insert 方法后会拷贝一份,而不是操作我们的实参。

我们可以试着打印插入前后,我们实参的变化:

	// 1. 插入单条数据user1 := User{ Id: 2, Name: "李大喜", Age: 22, Password: "123456",}fmt.Println(user1)res,err := engine.InsertOne(&user1)if err != nil {println("插入失败",err)}else {fmt.Printf("成功插入 %d 条数据\n",res)}fmt.Println(user1)

运行结果:

        可以看到,对象未进入 insert 方法之前,它的两个 time 类型的字段是默认值,但是进入 insert 方法后,被赋值为当前时间。

1.3.2、多条数据的插入

1. 传入多个结构体对象插入
    // 1. 插入多条数据user1 := User{ Id: 3, Name: "刘能", Age: 52, Password: "123456",}user2 := User{ Id: 4, Name: "赵四", Age: 52, Password: "123456",}res,err := engine.Insert(&user1,&user2)if err != nil {println("插入失败",err)}else {fmt.Printf("成功插入 %d 条数据\n",res)}
2. 通过切片插入
	users := make([]User,2)user1 := User{ Id: 3, Name: "刘能", Age: 52, Password: "123456",}user2 := User{ Id: 4, Name: "赵四", Age: 52, Password: "123456",}users[0] = user1users[2] = user2res,err := engine.Insert(&users)if err != nil {println("插入失败",err)}else {fmt.Printf("成功插入 %d 条数据\n",res)}

虽然Go语言中的切片是引用类型,但在我们这里仍然需要传入切片的地址(指针)。

这是因为xorm的Insert方法在处理切片时,如果接收到的是切片的指针,它能够通过该指针获取到切片的实时长度信息。这个长度信息对于数据库的批量插入操作是非常重要的,因为它可以帮助xorm确定一次性能插入多少条记录,从而提高效率。

1.3.3、更新与删除

更新数据
    // 修改用户user := User{Name: "谢永强"}res,_ := engine.ID(1).Update(&user)fmt.Println(res)
删除数据
	// 1. 删除单条数据user := User{Name: "谢永强"}res,_ := engine.ID(1).Delete(&user)fmt.Println(res)
执行 SQL
	// 1. 执行 SQLres,_ := engine.Exec("UPDATE user SET name = '刘海柱' WHERE id = ?",1)fmt.Println(res)

1.3.4、查询与遍历

1. SQL 查询(不常用)
  • Query 最原始的也支持SQL语句查询,返回的结果类型为 []map[string][]byte。
  • QueryString 返回 []map[string]string, QueryInterface 返回 []map[string]interface{}。
	res1,_ := engine.Query("SELECT * FROM user");fmt.Println(res1)res2,_ := engine.QueryString("SELECT * FROM user");fmt.Println(res2)res3,_ := engine.QueryInterface("SELECT * FROM user");fmt.Println(res3)

运行结果:

[map[age:[50 50] created:[50 48 50 52 45 48 52 45 51 48 32 50 48 58 53 53 58 51 53] id:[49] name:[229 136 152 230 181 183 230 159 177] password:[49 50 51 52 53 54] updated:[50 48 50 52 45 48 52 45 51 48 32 50 49 58 49 52 58 50 57]] map[age:[50 50] created:[50 48 50 52 45 48 52 45 51 48 32 50 48 58 53 56 58 52 55] id:[50] name:[230 157 142 229 164 167 229 150 156] password:[49 50 51 52 53 54] updated:[50 48 50 52 45 48 52 45 51 48 32 50 48 58 53 56 58 52 55]] map[age:[53 50] created:[50 48 50 52 45 48 52 45 51 48 32 50 49 58 48 52 58 49 49] id:[51] name:[229 136 152 232 131 189] password:[49 50 51 52 53 54] updated:[50 48 50 52 45 48 52 45 51 48 32 50 49 58 48 52 58 49 49]] map[age:[53 50] created:[50 48 50 52 45 48 52 45 51 48 32 50 49 58 48 52 58 49 49] id:[52] name:[232 181 181 229 155 155] password:[49 50 51 52 53 54] updated:[50 48 50 52 45 48 52 45 51 48 32 50 49 58 48 52 58 49 49]]]
[map[age:22 created:2024-04-30 20:55:35 id:1 name:刘海柱 password:123456 updated:2024-04-30 21:14:29] map[age:22 created:2024-04-30 20:58:47 id:2 name:李大喜 password:123456 updated:2024-04-30 20:58:47] map[age:52 created:2024-04-30 21:04:11 id:3 name:刘能 password:123456 updated:2024-04-30 21:04:11] map[age:52 created:2024-04-30 21:04:11 id:4 name:赵四 password:123456 updated:2024-04-30 21:04:11]]
[map[age:22 created:2024-04-30 20:55:35 id:1 name:刘海柱 password:123456 updated:2024-04-30 21:14:29] map[age:22 created:2024-04-30 20:58:47 id:2 name:李大喜 password:123456 updated:2024-04-30 20:58:47] map[age:52 created:2024-04-30 21:04:11 id:3 name:刘能 password:123456 updated:2024-04-30 21:04:11] map[age:52 created:2024-04-30 21:04:11 id:4 name:赵四 password:123456 updated:2024-04-30 21:04:11]]
2. GET 查询(单行查询)
    // GET 查询user := User{}engine.Get(&user) // 默认查询第一条数据fmt.Println(user) // {1 刘海柱 22 123456 2024-04-30 20:55:35 +0800 CST 2024-04-30 21:14:29 +0800 CST}

指定条件来查询

    user := User{Name: "刘海柱"}// 查询指定用户名 且 根据id降序后的第一条数据engine.Where("name=?",user.Name).Desc("id").Get(&user)fmt.Println(user)

查询指定字段:

    // 获取指定字段值user := User{}var name string// Table(&user) 代表表结构和结构体 User 相同engine.Table(&user).Where("id = 1").Cols("name").Get(&name)fmt.Println(name)
3. Find 查询(多行查询)
    var users []Userengine.Where("id < 5").And("password = 123456").Limit(10).Find(&users)for i := 0; i < len(users);i++ {fmt.Println(users[i])}// 或者使用 range 遍历切片for _,user := range users{fmt.Println(user)}

运行结果: 

{1 刘海柱 22 123456 2024-04-30 20:55:35 +0800 CST 2024-04-30 21:14:29 +0800 CST}
{2 李大喜 22 123456 2024-04-30 20:58:47 +0800 CST 2024-04-30 20:58:47 +0800 CST}
{3 刘能 52 123456 2024-04-30 21:04:11 +0800 CST 2024-04-30 21:04:11 +0800 CST}
{4 赵四 52 123456 2024-04-30 21:04:11 +0800 CST 2024-04-30 21:04:11 +0800 CST}
4. Count 查询
    // 查询所有 password="123456" 的用户user := User{Password: "123456"}count,_ := engine.Count(&user)fmt.Println(count) // 4
5. Iterate 迭代查询

Iterate 方法有两个参数:

  1. 查询条件(哪个结构体对应的表以及过滤条件)
  2. 匿名函数(第一个参数代表查询到的当前元素的索引,第二个参数代表当前元素对象)
    engine.Iterate(&User{Password: "123456"}, func(idx int, bean interface{}) error {// 类型断言user := bean.(*User)fmt.Println(user)return nil})
6. Rows 迭代查询
    rows,_ := engine.Rows(&User{Password: "123456"})defer rows.Close()user := new(User) // 传递指针给userfor rows.Next(){rows.Scan(user)fmt.Println(user)}

        这里的 Scan 方法需要一个指针,所以我们上面使用 new(User) 来初始化一个指针给 user,我们也可以通过下面的方法,都是一样的:

	rows,_ := engine.Rows(&User{Password: "123456"})defer rows.Close()user := User{}for rows.Next(){rows.Scan(&user)fmt.Println(user)}

1.3.5、事务

        要使用事务的话,必须使用 session 类进行数据的增删改,并结合 panic 和 recover 来进行异常的处理,一旦出现异常就回滚所有事务:

	session := engine.NewSession()defer session.Close()// 通过 panic 和 recover 进行异常的处理defer func() {err := recover()if err != nil {fmt.Println("Rollback")session.Rollback()}else {session.Commit()}}()session.Begin() // 开启事务user := User{Id: 5,Name: "王老七",Age: 40}if _,err := session.Insert(&user);err!=nil{panic(err)}

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

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

相关文章

Python批量计算多张遥感影像的NDVI

本文介绍基于Python中的gdal模块&#xff0c;批量基于大量多波段遥感影像文件&#xff0c;计算其每1景图像各自的NDVI数值&#xff0c;并将多景结果依次保存为栅格文件的方法。 如下图所示&#xff0c;现在有大量.tif格式的遥感影像文件&#xff0c;其中均含有红光波段与近红外…

通过氧气退火增强β-Ga₂O₃二极管.中国科技大学和河北半导体研究所的研究人员在这一特定领域取得了最新重大进展

上图所示&#xff1a;&#xff08;a&#xff09;增加台面有助于提高β-Ga2O3肖特基势垒二极管的阻断电压&#xff08;b&#xff09;。 氧气退火和自对准台面终端使β-Ga2O3二极管进一步走向商业化。 虽然β-Ga2O3电力电子技术已经取得了长足的进步&#xff0c;但仍然存在挑战&…

QT creator qt6.0 使用msvc2019 64bit编译报错

qt creator qt6.0报错&#xff1a; D:\Qt6\6.3.0\msvc2019_64\include\QtCore\qglobal.h:123: error: C1189: #error: "Qt requires a C17 compiler, and a suitable value for __cplusplus. On MSVC, you must pass the /Zc:__cplusplus option to the compiler."…

VTK —— 三、简单操作 - 示例3 - 将点投影到平面上(附完整源码)

代码效果 本代码编译运行均在如下链接文章生成的库执行成功&#xff0c;若无VTK库则请先参考如下链接编译vtk源码&#xff1a; VTK —— 一、Windows10下编译VTK源码&#xff0c;并用Vs2017代码测试&#xff08;附编译流程、附编译好的库、vtk测试源码&#xff09; 教程描述 本…

什么是视频号小店?为什么这么多人都在做?一文带你轻松入门!

大家好&#xff0c;我是电商花花。 现在电商的快速发展&#xff0c;电商行业在各大电商平台上不断发展&#xff0c;而视频号小店也被更多人看到和入驻&#xff0c;让更多创业者对视频号小店产生兴趣。 知道的人都觉得视频号小店是一个不可多得的创业项目&#xff0c;因为这里…

下一代Nginx? OpenNjet 的入门实践

何为 OpenNjet &#xff1f; OpenNJet 应用引擎是基于 NGINX 的面向互联网和云原生应用提供的运行时组态服务程序&#xff0c;作为底层引擎&#xff0c;OpenNJet 实现了NGINX 云原生功能增强、安全加固和代码重构&#xff0c;利用动态加载机制可以实现不同的产品形态&#xff0…

休斯《公共管理导论》第5版/考研真题解析/章节题库

第一部分 考研真题精选 一、概念题二、简答题三、论述题四、案例分析题第二部分 章节题库 第1章 一个变革的时代第2章 政府的角色第3章 传统的公共行政模式第4章 公共管理第5章 公共政策第6章 治 理第7章 问 责第8章 利害关系人和外部环境第9章 管制、外包和公共企…

【机器学习与实现】线性回归示例——波士顿房价分析

目录 一、创建Pandas对象并查看数据的基本情况二、使用皮尔逊相关系数分析特征之间的相关性三、可视化不同特征与因变量MEDV&#xff08;房价中值&#xff09;间的相关性四、划分训练集和测试集并进行回归分析 一、创建Pandas对象并查看数据的基本情况 boston.csv数据集下载&a…

Go 语言基础之面向对象编程

1、OOP 首先&#xff0c;Go 语言并不是面向对象的语言&#xff0c;只是可以通过一些方法来模拟面向对象。 1.1、封装 Go 语言是通过结构体&#xff08;struct&#xff09;来实现封装的。 1.2、继承 继承主要由下面这三种方式实现&#xff1a; 1.2.1、嵌套匿名字段 //Add…

CoPilot 产品体验:提升 OpenNJet 的控制管理和服务提供能力

文章目录 前言系统架构介绍CoPilot 配置CoPilot 插件规范 体验 CoPilot 实例CoPilot: Broker 实例CoPilot: Ctrl 实例 开发其他语言编写的 CoPilot目标主要思路具体实现执行 go 程序代码 功能扩展总结 前言 CoPilot 是 OpenNJet 的一个重要组成部分&#xff0c;它在 Master-Wo…

246 基于matlab的交流电机动态方程

基于matlab的交流电机动态方程&#xff0c;用于交流电机动态分析。输入电机的额定功率(kW)、电机的额定转速(r/min)、转子外径(m)、铁心长(m)转子槽数、电机极对数 等参数&#xff0c;输出转速变化、力矩变化等结果。程序已调通&#xff0c;可直接运行。 246 交流电机动态 转速…

DAY 2

winget.cpp #include "widget.h"Widget::Widget(QWidget *parent): QWidget(parent) {this->resize(540,415);this->setFixedSize(540,415);//窗口标题this->setWindowTitle("盗版QQ");//窗口图标this->setWindowIcon(QIcon("E:\\qq\\pi…

30分钟打造属于自己的Flutter内存泄漏检测工具---FlutterLeakCanary

30分钟打造属于自己的Flutter内存泄漏检测工具 思路检测Dart 也有弱引用-----WeakReference如何执行Full GC&#xff1f;如何知道一个引用他的文件路径以及类名&#xff1f; 代码实践第一步&#xff0c;实现Full GC第二步&#xff0c;如何根据对象引用&#xff0c;获取出他的类…

HarmonyOS实战开发教程-如何开发一个2048游戏

今天为大家分享的是2048小游戏&#xff0c;先看效果图&#xff1a; 这个项目对于新手友友来说可能有一点难度&#xff0c;但是只要坚持看完一定会有收获。因为小编想分享的并不局限于ArkTs语言&#xff0c;而是编程思想。 这个游戏的基本逻辑是初始化一个4乘4的数组&#xff…

LeetCode 每日一题 Day 144-157

2385. 感染二叉树需要的总时间 给你一棵二叉树的根节点 root &#xff0c;二叉树中节点的值 互不相同 。另给你一个整数 start 。在第 0 分钟&#xff0c;感染 将会从值为 start 的节点开始爆发。 每分钟&#xff0c;如果节点满足以下全部条件&#xff0c;就会被感染&#xf…

网络基础(1)网络编程套接字TCP,守护进程化

TCP协议 下面我们来学习一下TCP套接字的使用。 也就是使用一下基本的接口。首先TCP套接字的使用和UDP套接字的使用是大同小异的&#xff0c;但是多了一些步骤。 这里回顾一下&#xff1a;UDP是不可靠的&#xff0c;无连接的协议。而TCP则是可靠的&#xff0c;面向连接的协议…

[HUBUCTF 2022 新生赛]checkin

数组反序列化弱比较 <?php $info array(username>true,password>true); echo serialize($info); ?> //?infoa:2:{s:8:"username";b:1;s:8:"password";b:1;}1.构造不能用类&#xff0c;因为$data_unserialize只是一个变量&#xff0c;不能…

vivado Versal ACAP 可编程器件镜像 (PDI) 设置

Versal ACAP 可编程器件镜像 (PDI) 设置 下表所示 Versal ACAP 器件的器件配置设置可搭配 set_property <Setting> <Value> [current_design] Vivado 工具 Tcl 命令一起使用。 注释 &#xff1a; 在 Versal ACAP 架构上 &#xff0c; 原先支持将可编程器…

游戏技术人福音!当游戏语音碰到网易云信 ,我服了!

“开黑吗&#xff1f;五黑的那种” 少年时代&#xff0c;放假后偷偷溜进网吧&#xff0c;一边打着游戏&#xff0c;一边连麦吐槽对手的惬意岁月&#xff0c;不仅承载了无数 80 后、90 后&#xff0c;甚至 00 后的青春记忆&#xff0c;也让游戏语音成为了“游戏少年”闲暇生活的…