Go Web开发【xorm 框架】

2024-05-01 08:04
文章标签 go 开发 web 框架 xorm

本文主要是介绍Go Web开发【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)}

这篇关于Go Web开发【xorm 框架】的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/951143

相关文章

这15个Vue指令,让你的项目开发爽到爆

1. V-Hotkey 仓库地址: github.com/Dafrok/v-ho… Demo: 戳这里 https://dafrok.github.io/v-hotkey 安装: npm install --save v-hotkey 这个指令可以给组件绑定一个或多个快捷键。你想要通过按下 Escape 键后隐藏某个组件,按住 Control 和回车键再显示它吗?小菜一碟: <template

Hadoop企业开发案例调优场景

需求 (1)需求:从1G数据中,统计每个单词出现次数。服务器3台,每台配置4G内存,4核CPU,4线程。 (2)需求分析: 1G / 128m = 8个MapTask;1个ReduceTask;1个mrAppMaster 平均每个节点运行10个 / 3台 ≈ 3个任务(4    3    3) HDFS参数调优 (1)修改:hadoop-env.sh export HDFS_NAMENOD

嵌入式QT开发:构建高效智能的嵌入式系统

摘要: 本文深入探讨了嵌入式 QT 相关的各个方面。从 QT 框架的基础架构和核心概念出发,详细阐述了其在嵌入式环境中的优势与特点。文中分析了嵌入式 QT 的开发环境搭建过程,包括交叉编译工具链的配置等关键步骤。进一步探讨了嵌入式 QT 的界面设计与开发,涵盖了从基本控件的使用到复杂界面布局的构建。同时也深入研究了信号与槽机制在嵌入式系统中的应用,以及嵌入式 QT 与硬件设备的交互,包括输入输出设

OpenHarmony鸿蒙开发( Beta5.0)无感配网详解

1、简介 无感配网是指在设备联网过程中无需输入热点相关账号信息,即可快速实现设备配网,是一种兼顾高效性、可靠性和安全性的配网方式。 2、配网原理 2.1 通信原理 手机和智能设备之间的信息传递,利用特有的NAN协议实现。利用手机和智能设备之间的WiFi 感知订阅、发布能力,实现了数字管家应用和设备之间的发现。在完成设备间的认证和响应后,即可发送相关配网数据。同时还支持与常规Sof

活用c4d官方开发文档查询代码

当你问AI助手比如豆包,如何用python禁止掉xpresso标签时候,它会提示到 这时候要用到两个东西。https://developers.maxon.net/论坛搜索和开发文档 比如这里我就在官方找到正确的id描述 然后我就把参数标签换过来

Java Web指的是什么

Java Web指的是使用Java技术进行Web开发的一种方式。Java在Web开发领域有着广泛的应用,主要通过Java EE(Enterprise Edition)平台来实现。  主要特点和技术包括: 1. Servlets和JSP:     Servlets 是Java编写的服务器端程序,用于处理客户端请求和生成动态网页内容。     JSP(JavaServer Pages)

Linux_kernel驱动开发11

一、改回nfs方式挂载根文件系统         在产品将要上线之前,需要制作不同类型格式的根文件系统         在产品研发阶段,我们还是需要使用nfs的方式挂载根文件系统         优点:可以直接在上位机中修改文件系统内容,延长EMMC的寿命         【1】重启上位机nfs服务         sudo service nfs-kernel-server resta

BUUCTF靶场[web][极客大挑战 2019]Http、[HCTF 2018]admin

目录   [web][极客大挑战 2019]Http 考点:Referer协议、UA协议、X-Forwarded-For协议 [web][HCTF 2018]admin 考点:弱密码字典爆破 四种方法:   [web][极客大挑战 2019]Http 考点:Referer协议、UA协议、X-Forwarded-For协议 访问环境 老规矩,我们先查看源代码

【区块链 + 人才服务】区块链集成开发平台 | FISCO BCOS应用案例

随着区块链技术的快速发展,越来越多的企业开始将其应用于实际业务中。然而,区块链技术的专业性使得其集成开发成为一项挑战。针对此,广东中创智慧科技有限公司基于国产开源联盟链 FISCO BCOS 推出了区块链集成开发平台。该平台基于区块链技术,提供一套全面的区块链开发工具和开发环境,支持开发者快速开发和部署区块链应用。此外,该平台还可以提供一套全面的区块链开发教程和文档,帮助开发者快速上手区块链开发。

cross-plateform 跨平台应用程序-03-如果只选择一个框架,应该选择哪一个?

跨平台系列 cross-plateform 跨平台应用程序-01-概览 cross-plateform 跨平台应用程序-02-有哪些主流技术栈? cross-plateform 跨平台应用程序-03-如果只选择一个框架,应该选择哪一个? cross-plateform 跨平台应用程序-04-React Native 介绍 cross-plateform 跨平台应用程序-05-Flutte