XORM 框架的使用

news2024/11/28 2:28:41

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 = 3306
		dbName = "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 int64
		Name string
		Age int
		Password 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] = user1
	users[2] = user2
	res,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. 执行 SQL
	res,_ := 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 []User
	engine.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) // 传递指针给user
	for 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.coloradmin.cn/o/1650348.html

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

相关文章

nginx模型设计和进程讲解

nginx模型设计和进程讲解

一. Nginx进程模型解析 1. master主进程 和 worker工作进程 [rootlocalhost sbin]# ps -ef|grep nginx root 15411 1 0 21:08 ? 00:00:00 nginx: master process ./nginx nobody 15412 15411 0 21:08 ? 00:00:00 nginx: worker process root…
阅读更多...
pytest教程-39-钩子函数-pytest_runtest_setup

pytest教程-39-钩子函数-pytest_runtest_setup

领取资料&#xff0c;咨询答疑&#xff0c;请➕wei: June__Go 上一小节我们学习了pytest_runtest_protocol钩子函数的使用方法&#xff0c;本小节我们讲解一下pytest_runtest_setup钩子函数的使用方法。 pytest_runtest_setup 钩子函数在每个测试用例的 setup 阶段被调用。这…
阅读更多...
学习软考----数据库系统工程师22

学习软考----数据库系统工程师22

关系运算 基本的关系代数运算 拓展的关系运算 除&#xff1a;需要S连接中属性为C和D的两个元组都与R连接一样&#xff0c;且在R连接中对应的另外的元素完全一致 总结
阅读更多...
聊聊 ASP.NET Core 中间件（三）：如何创建自己的中间件？

聊聊 ASP.NET Core 中间件（三）：如何创建自己的中间件？

前言 本质上&#xff0c;中间件类也是一个普通的 .NET 类&#xff0c;它不需要继承任何父类或者实现任何接口。 但是有几个约定&#xff1a; 需要有一个构造方法构造方法至少要有一个 RequestDelegate 类型的参数&#xff0c;用来指向下一个中间件。需要定义一个名字为 Invo…
阅读更多...
交易复盘-20240507

交易复盘-20240507

仅用于记录当天的市场情况&#xff0c;用于统计交易策略的适用情况&#xff0c;以便程序回测 短线核心&#xff1a;不参与任何级别的调整&#xff0c;采用龙空龙模式 一支股票 10%的时候可以操作&#xff0c; 90%的时间适合空仓等待 蔚蓝生物 (5)|[9:25]|[36187万]|4.86 百合花…
阅读更多...
STM32F10x移植FreeRTOS

STM32F10x移植FreeRTOS

一、获取FreeRTOS源码 &#xff08;1&#xff09;登录FreeRTOS官网&#xff1a;www.freertos.org&#xff0c;下载第一个压缩包 &#xff08;2&#xff09;通过GitHub网站&#xff1a;github.com/FreeRTOS/FreeRTOS下载&#xff0c;由于该网站服务器在国外&#xff0c;所以访问…
阅读更多...
28.leetcode---前K个高频单词(Java版)

28.leetcode---前K个高频单词(Java版)

题目链接: https://leetcode.cn/problems/top-k-frequent-words/description/ 题解: 代码: 测试:
阅读更多...
巨控GRM561/562/563/564Q杀菌信息远程监控

巨控GRM561/562/563/564Q杀菌信息远程监控

摘要 通过程序编写、手机APP画面制作等运行系统&#xff0c;实现电脑及手机APP显示的历史曲线画面和数据图形化的实时性。 不仅流程效率提升90%以上&#xff0c;同时为杀菌生产提供有利的质量保障&#xff0c;还有效规避因触屏及内存卡的突发异常导致历史数据的丢失&#xff0…
阅读更多...
强大的禄得可转债自定义因子轮动系统完成，可转债三低为例子

强大的禄得可转债自定义因子轮动系统完成，可转债三低为例子

经过几天的测试终于完成了可转债自定义因子轮动&#xff0c;超过1000行的源代码 我提供了服务器的数据支持自动api下载&#xff0c;我给大家维护数据 网页 http://120.78.132.143:8023/ 录得数据支持http://120.78.132.143:8023/lude_data_app api数据支持&#xff0c;我提供…
阅读更多...
杭州恒生面试，社招，3年经验

杭州恒生面试，社招，3年经验

你好&#xff0c;我是田哥 一位朋友节前去恒生面试&#xff0c;其实面试问题大部分都是八股文&#xff0c;但由于自己平时工作比较忙&#xff0c;完全没有时间没有精力去看八股文&#xff0c;导致面试结果不太理想&#xff0c;HR说节后通知面试结果&#xff08;估计是凉了&…
阅读更多...
传统汽车空调系统工作原理

传统汽车空调系统工作原理

1.首先讲一个概念 液体变成气体&#xff1a;吸热 气体变成液体&#xff1a;放热 2.在汽车空调系统中热量的传递的介质不是水&#xff0c;而是氟利昂&#xff0c;简称&#xff1a;“氟”。 3.传统式汽车空调结构如下 该三个部件位于车头进气口位置 该部位位于汽车驾驶车厢前方…
阅读更多...
常见的容器技术有哪些

常见的容器技术有哪些

容器技术是一种轻量级的软件封装方式&#xff0c;它将软件代码及其依赖项打包在一起&#xff0c;这样应用可以在任何支持容器的系统上无缝运行。它允许应用程序及其依赖项在一个隔离的环境中运行&#xff0c;这个环境被称为容器。容器技术有助于提高应用程序的可移植性、一致性…
阅读更多...
Vue3专栏项目 -- 一、第一个页面（上）

Vue3专栏项目 -- 一、第一个页面（上）

一、ColumnList 组件&#xff08;专栏列表组件&#xff09;编码&#xff1a; 该组件要接收一个数组&#xff0c;数组中是一个个专栏数据&#xff0c;数据中包括id、title、avator、description。所以我们定义一个泛型&#xff0c;泛型为id为number类型title为string类型如下这…
阅读更多...
初识C++ · 类和对象(下)

初识C++ · 类和对象(下)

目录 1 再谈构造函数 2 类中的隐式类型转换 3 Static成员 4 友元和内部类 5 匿名对象 6 编译器的一些优化 1 再谈构造函数 先看一段代码&#xff1a; class Date { public :Date(int year, int month, int day){_year year;_month month;_day day;} private:int _ye…
阅读更多...
Redis之Linux下的安装配置

Redis之Linux下的安装配置

Redis之Linux下的安装配置 Redis下载 Linux下下载源码安装配置 方式一 官网下载&#xff1a;https://redis.io/download ​ 其他版本下载&#xff1a;https://download.redis.io/releases/ 方式二&#xff08;推荐&#xff09; GitHub下载&#xff1a;https://github.com/r…
阅读更多...
基于ambari hdp的kafka用户授权读写权限

基于ambari hdp的kafka用户授权读写权限

基于ambari hdp的kafka用户授权读写权限 版本Kafka 2.0.0添加自定义配置修改admin密码重启kafka授权读取授权写入有效通配符部分举例 版本Kafka 2.0.0 添加自定义配置 authorizer.class.name kafka.security.auth.SimpleAclAuthorizer super.users User:admin allow.everyo…
阅读更多...
【强训笔记】day13

【强训笔记】day13

NO.1 代码实现&#xff1a; #include <iostream>#include<string>using namespace std;int n,k,t; string s;int func() {int ret0;for(int i0;i<n;i){char chs[i];if(chL) ret-1;else{if(i-1>0&&i-2>0&&s[i-1]W&&s[i-2]W) retk…
阅读更多...
Android 官网Ota介绍

Android 官网Ota介绍

构建 OTA 软件包 | Android 开源项目 | Android Open Source Project
阅读更多...
太阳能光伏在生活中的三大作用

太阳能光伏在生活中的三大作用

随着现在太阳能光伏的逐步发展&#xff0c;太阳能光伏已经越来越走近人们的生活&#xff0c;小编带大家盘点一下光伏在生活中的应用 一、发电 光伏的最初应用就是用来发电&#xff0c;以替代传统的化石燃料发电方式。光伏发电可以从根本上解决当今社会面临的能源短缺问题&…
阅读更多...
我的板子为什么测不了损耗

我的板子为什么测不了损耗

高速先生成员--周伟 最近我们珠海高速实验室正式对外开放了&#xff0c;我们也同步推出了关于高速信号测试、高速仪器的一些视频。 大家知道我们有仪器后&#xff0c;很多热心的小伙伴们就以为我们开挂了&#xff0c;什么都能测&#xff0c;然后就会来咨询我们&#xff0c;很多…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023