开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

gorm exec使用原始sql从insert transaction返回ID

是指在使用gorm库进行数据库操作时，通过执行原始的SQL语句来实现插入事务并返回插入记录的ID。

在gorm中，可以使用Exec方法执行原始的SQL语句。对于插入操作，可以使用INSERT INTO语句来插入数据，并通过RETURNING子句来返回插入记录的ID。

以下是一个示例代码：

type User struct {
    ID   uint
    Name string
}

func CreateUser(db *gorm.DB, user *User) (uint, error) {
    var id uint
    err := db.Exec("INSERT INTO users (name) VALUES (?) RETURNING id", user.Name).Scan(&id).Error
    if err != nil {
        return 0, err
    }
    return id, nil
}

在上述代码中，我们定义了一个User结构体，其中包含了ID和Name字段。CreateUser函数接收一个db参数，表示gorm的数据库连接对象，以及一个user参数，表示要插入的用户数据。

在CreateUser函数中，我们使用Exec方法执行原始的SQL语句。通过RETURNING id子句，我们可以在插入数据的同时返回插入记录的ID。使用Scan方法将返回的ID值赋给id变量。

最后，我们将插入记录的ID和可能发生的错误作为结果返回。

这种方式可以在需要使用原始SQL语句进行数据库操作时，实现插入事务并返回插入记录的ID。在实际应用中，可以根据具体的业务需求和数据库类型进行相应的调整和优化。

腾讯云相关产品和产品介绍链接地址：

云数据库 TencentDB：https://cloud.tencent.com/product/cdb
云服务器 CVM：https://cloud.tencent.com/product/cvm
云原生应用引擎 TKE：https://cloud.tencent.com/product/tke
人工智能平台 AI Lab：https://cloud.tencent.com/product/ai
物联网平台 IoT Hub：https://cloud.tencent.com/product/iothub
移动开发平台 MSDK：https://cloud.tencent.com/product/msdk
云存储 COS：https://cloud.tencent.com/product/cos
区块链服务 BaaS：https://cloud.tencent.com/product/baas
元宇宙服务 Meta Universe：https://cloud.tencent.com/product/meta-universe

请注意，以上链接仅供参考，具体产品选择应根据实际需求进行评估和决策。

页面内容是否对你有帮助？

有帮助

没帮助

相关·内容

Gorm-原生 SQL 查询和执行（二）

原生SQL事务Gorm还支持使用原生SQL语句执行事务操作。在Gorm中执行事务的方法是Transaction。...例如，以下代码执行了一个简单的事务操作：db.Transaction(func(tx *gorm.DB) error { // 原生SQL查询 rows, err := tx.Raw("SELECT..., user.Name) } // 原生SQL执行 result := tx.Exec("UPDATE users SET name = ?...在事务中，我们可以执行多个原生SQL查询和执行操作。如果事务中任何一个操作返回错误，整个事务操作将会被回滚。如果所有操作都成功执行，事务将会被提交。...需要注意的是，在使用原生SQL查询和执行时，我们也需要遵循Gorm的其他安全性建议，如使用预编译语句、避免拼接SQL语句等。

1.4K0 0

Gorm实战，轻松掌握数据库增删改查技巧！

SQL Server // INSERT INTO `users` *** ON DUPLICATE KEY UPDATE ***; MySQL // 使用SQL语句 db.Clauses(clause.OnConflict...SQL 表达式更新 GORM 允许使用 SQL 表达式更新列，例如： // user 的 ID 是 `1` db.First(&student) db.Model(&student).Update..., "%灰太狼%") 阻止全局删除如果在没有任何条件的情况下执行批量删除，GORM 不会执行该操作，并返回 ErrMissingWhereClause错误对此，你必须加一些条件，或者使用原生 SQL...RETURNING id, name", "小欣同学", 12).Scan(&users) fmt.Println(users) Exec 原生 SQL db.Exec("DROP TABLE users...in same db tcp connection (not in a transaction) db.Connection(func(tx *gorm.DB) error { tx.Exec("

3.3K2 0

从零实现ORM框架GeoORM-databasesql基础-01

Go 语言中使用比较广泛 ORM 框架是 gorm 和 xorm。...IF EXISTS User;") _, _ = db.Exec("CREATE TABLE User(Name text);") result, err := db.Exec("INSERT...返回一个 sql.DB 实例的指针。 Exec() 用于执行 SQL 语句，如果是查询语句，不会返回相关的记录。...所以查询语句通常使用 Query() 和 QueryRow()，前者可以返回多条记录，后者只返回一条记录。...return s } Session 结构体目前只包含三个成员变量，第一个是 db *sql.DB，即使用 sql.Open()方法连接数据库成功之后返回的指针。

4831 0

DatabaseSQL与GORM实践

作者张金柱老师介绍了Go语言原生database/sql的实现原理和使用方式，并且进一步给出了自己设计GORM框架的出发点和一些实现细节。...这里留意上图我给出的一些注释，它们来自源码包中的对应方法的注释，以sql.Open()方法为例，它说了Open方法可能只是会校验参数的语法而非真正建立连接，为了验证数据源的有效性可以用Ping方法，并且第二个红框中介绍到返回的...) } return nil } 1.4 插入这里要说明一下，下面的插入、更新、删除使用到的API是同一个：db.Exec，args参数是任意个占位参数。...where id = ?" ret, err := db.Exec(sqlStr, 20, 3) if err !...GORM文档已经十分清爽完备，最终决定不再笔记中二次赘述。小结 GORM还是原生database/sql，都是在应用程序层面，向用户隐藏了底层连接数据库，操作数据库的实现细节。

4303 0

【Golang】快速复习指南QuickReview（十一）——数据库访问(MySql为例)

sql.Open():仅仅是配置连接，但并不真正连接，需要两个参数：数据库驱动名称数据库连接字符串返回一个执行sql.DB这个struct的指针:*sql.DB 这个指针才是我们操作数据库的关键钥匙...包中只有一个方法:Exec,这里就省略delete操作，实际业务上很少使用物理删除。...插入 func Insert() error { // _, err := db.Exec("INSERT INTO notifypush(AppName,Target,PushType,DeviceType...= nil { log.Fatalln(err.Error()) } defer stmt.Close() _, err = stmt.Exec("insert-app", 1, 2, 3,...\sqltest.exe #运行 5.ORM 5.1 GORM GORM是GoLang中最出色的ORM框架，支持MySQL、PostgreSQL、Sqlite、SQL Server，功能非常强大，也可以直接执行

6702 0

Gorm 实践指南

执行性能， GORM 支持自动的 Prepared Statement 缓冲，启用后，由 Gorm 生成的 SQL 或者 RAW SQL 都会进行预处理并缓存，Prepare Statement 可与数据库事务协同工作...临时性开启 // 临时性开启，后续该 tx 的 SQL 执行都会使用 Prepared Statement 模式 tx := db.Session(&Session{PrepareStmt: true...user2") // rollback user2 }) tx.Transaction(func(tx2 *gorm.DB) error { tx.Create(&user3)...gorm:"->;<-:create"` // 允许读和写 Name string `gorm:"->:false;<-:create"` // 仅创建（禁止从 db 读） Name string...results { // 批量处理数据 } // 批量更新数据，在使用 Save 处理批量数据时，会使用 Insert OnConflict DoNothing 模式

2.2K2 0

一文入门gorm和xorm的基本操作（CRUD）

} 使用db.AutoMigrate(User{})方法从结构体生成数据库表连接设置 sqlDB, _ := db.DB() // SetMaxIdleConns 设置空闲连接池中连接的最大数量...IN (10, 11); } xorm的CRUD操作 xorm的特性支持Struct和数据库表之间的灵活映射，并支持自动同步事务支持同时支持原始SQL语句和ORM操作的混合执行使用连写来简化调用...(3).Delete(&user1) fmt.Println(n1) } 执行一个sql语句 engine.Exec("update user set age = ?..."}) n, _ = engine.Insert(users) } //查询 func query() { //使用sql语句查询 results, _ := engine.Query...使用方式不同：gorm 支持链式调用和原生 SQL，而 xorm 和 gorm 都支持链式调用和模板语言。

4855 0

组件分享之后端组件——对其GORM增加多数据库支持功能的组件dbresolver

dbresolver，它支持以下功能：多个来源，副本读/写分离基于工作表/结构的自动连接切换手动连接切换源/副本负载均衡适用于原始 SQL 事务具体使用如下： import ( "gorm.io...DB.Table("users").Rows() // replicas `db5` DB.Model(&User{}).Find(&AdvancedUser{}) // replicas `db5` DB.Exec...sources: db6 or db7 DB.Clauses(dbresolver.Use("secondary"), dbresolver.Write).First(&user) 事务 // Start transaction...based on default replicas db tx := DB.Clauses(dbresolver.Read).Begin() // Start transaction based on...default sources db tx := DB.Clauses(dbresolver.Write).Begin() // Start transaction based on `secondary

5263 0

gorm hook使用中的问题及核心源码解读

本文针对的是gorm V2版本。hook官方文档可以点击这里，本文旨在对官方文档作一些补充说明。下文中所有的DB均指gorm.Open返回的DB对象。...type User struct { ID int64 Name string Age int32 IsAdmin bool IsValid bool LoginTime time.Time...("invalid Age or Name") } return nil } 但是如果多Model上有同样的逻辑（比如插入数据后记录日志），若使用hook实现，只能在每个Model上分别实现，或者考虑改用...Save方法的作用，源码中的注释是这样说的：Save update value in database, if the value doesn’t have primary key, will insert..., 12).Delete(&User{}) 在现在的DB上定义一个不同配置的Session，用这个session来执行sql即可。 6. hook机制在源码中是如何实现的？

5K1 0

GORM V2 几个最实用的功能和升级注意事项

还有一种是使用db.Raw 或者 db.Exec 执行手写的SQL来进行批量创建，我以前每次需要批量创建模型是都会手动在模型里定义一个BulkCreate方法 func BulkInsertOrderGoods..., ",")) err := DB().Exec(statement, valueArgs...).Error return err } 还得时刻注意，尽量让程序拼接SQL时不出错。...Name: "jinzhu3"}} db.Create(&users) for _, user := range users { user.ID // 1,2,3 } 或者是使用gorm.DB对象上的方法...Error 使用Find查询数据的时候，在V1版本里如果查不到数据会返回错误，所以很多人在代码里的下面这行判断会失效 if err !...= gorm.ErrRecordNotFound 但是使用 First、Last、Take 这些预期会返回结果的方法查询记录时，还会返回 ErrRecordNotFound。

2021 0

『No19: Gorm 上手指南』

大纲：原生database/sql 接口丰富的第三方驱动 gorm 的使用 1. 原生 database/sql 接口 Go 官方并没有提供数据库驱动，只定义了一些标准的接口。...In that case, the sql package // will not sanity check Exec or Query argument counts....NumInput() int // Exec executes a query that doesn't return rows, such // as an INSERT or UPDATE..., _ := sql.Open("mysql", "*****") 2. gorm 使用上述方法的缺点是使你代码内充斥着 SQL 语句。...image.png image.png 实际操作的SQL 语句： image.png 参考代码：参考代码使用的PostgreSQL 数据库，确保本机有服务启动先db 下的压缩包使用 pg_restore

2.7K1 0

分布式事务框架 seata-golang 接入指南

如果使用 dubbo-go 框架，dubbo-go 会从 context 中读取 attachment 将其序列化传递给服务端。...seata 通过代理数据源，对 sql 语句进行解析，来获取修改数据的修改前和修改后的数据，供 transaction coordinator 回滚时使用。..., {你的 sql driver 实例}) 如果你使用了 xorm 或者 gorm，则可从 xorm 对象或者 gorm 对象中取出 sql driver 实例，用上面的方法构造出 seata-golang...执行 sql 语句则使用该分支事务对象 tx 的 Exec 方法 func (tx *Tx) Exec(query string, args ...interface{}) (sql.Result, error...最后，整个分支事务是否成功提交，执行成功还是失败需要返回结果给调用方，也就是全局事务的发起方，transaction manager 会根据返回的结果决定是否提交或回滚整个全局事务。 ?

3.1K1 0

Go（五）不知道怎么用Gorm？

本文也不探究Gorm和其他框架的优劣比较，而是从使用者出发，一起来探讨Gorm在实际开发中的使用。...” 设置连接池 Gorm同样支持连接池，Gorm使用 database/sql 维护连接池分别使用SetMaxIdleConns，SetMaxOpenConns，SetConnMaxLifetime...Gorm去建立数据库连接了，但是有没有什么办法像Spring Boot一样从配置文件中获取连接参数呢，恰好第三章中讲到了怎么使用读取配置文件的方法，那何不利用起来呢？...匿名事务可使用db.Transaction匿名方法来表明多个操作在一个事务里面，返回err将回滚，返回nil将提交事务 func Transaction() error { db := config.GetDb...() err := db.Transaction(func(tx *gorm.DB) error { // 在事务中执行一些 db 操作（从这里开始，您应该使用 'tx' 而不是 'db'） if

2K1 1

手把手带你从0搭建一个Golang ORM框架（全）！

执行原生sql的增删改操作Exec go原生的sql代码，提供了Exec方法，用于增删改的操作，也就是本文开头的原生demo中的第一种方式： result, err := db.Exec("INSERT...,"lisi","dev","2020-08-04") 其实，你是可以不传后面的几个参数，不使用问号占位符的，第一个参数直接传完整的sql即可，像这样： result, err := db.Exec(...(id int64, err error) { result, err := e.Db.Exec(sql) e.Sql = sql if err !..., _ := result.RowsAffected() return rowsAffected, nil }} 我们通过判断sql是的语句是新增还是其他，因为新增的话一般情况是要返回自增ID的...这样，我们就可以很方便的调用原生的sql语句了： //result, err:= e.Exec("insert into userinfo(username,departname,created

1.3K3 0

Go语言 orm库之gorm

SQL 表达式、Context Valuer 进行 CRUD SQL 构建器，Upsert，数据库锁，Optimizer/Index/Comment Hint，命名参数，子查询复合主键，索引，约束...= nil { panic("failed to connect database") } //设置连接池 // 获取通用数据库对象 sql.DB ，然后使用其提供的功能...// 返回插入数据的主键 //result.Error // 返回 error //result.RowsAffected // 返回插入记录的条数...:1}) //事务 db.Transaction(func(tx *gorm.DB) error { // 在事务中执行一些 db 操作（从这里开始，您应该使用 'tx'...(func(tx *gorm.DB) error { tx.Create(&user1) tx.Transaction(func(tx2 *gorm.DB) error

1.2K2 0

Go 语言使用 XORM 操作 MySQL 的陷阱

01 介绍在 Go 语言开发中，大家为了方便，通常会选择使用 ORM 操作数据库，比如使用 XORM 或 GORM 操作 MySQL。...，我们插入一条数据，返回结果是影响行数和错误信息，而不是直接返回该条数据的自增 id。...res, err := engine.Exec(sql, "Python", 60, time.Now().Unix(), 2) if err !...Exec 方法执行原生 SQL 可以满足我们的需求。...读者朋友们在使用 XORM 或 GORM 操作 MySQL 时，还遇到过哪些陷阱，欢迎读者朋友们在留言区分享。

4322 0

golang源码分析：gorm

= nil { err = config.Dialector.Initialize(db) } } 我们常用的github.com/jinzhu/gorm是从官方fork...初始化连接后可以开始使用： // 根据主键查询第一条记录 db.First(&user) //// SELECT * FROM users ORDER BY id LIMIT 1; // 随机获取一条记录...所以，业务代码持有的总是最原始的db实例，即通过gorm.Open出来的db实例。...，并返回对应的Rows结果 if !...，执行的SQL语句都比较固定，而变化的往往是参数；从GORM的实现来看，每次执行都需要重新拼接一次SQL语句，是有不小的优化空间的，比如引入一定的cache。

2.5K2 0

基于sqlmock模拟数据库驱动编写Golang单元测试用例

的使用规范，定义了Tag表的结构信息。...package modelimport ( "time")// Tag 表type Tag struct { Id uint `gorm:"column:id;type...:int(11) unsigned;primary_key;AUTO_INCREMENT" json:"id"` TagName string `gorm:"column:tag_name...数据库连接关闭问题sql: database is closedsql: database is closed; invalid transaction通过db, mock, err := sqlmock.New...总结上面主要是，简单的介绍和示例了，通过sqlmock来对gorm打桩mock。从而更加简单和方便的来对使用到数据库操作的业务代码进行单测的编写。

6421 0

Go gorm

// 最后一次更新时间（由GORM自动管理） }约定主键：GORM 使用一个名为ID 的字段作为每个模型的默认主键。...GORM 将生成一条 SQL 来插入所有数据，以返回所有主键值，并触发 Hook 方法。当这些记录可以被分割成多个批次时，GORM会开启一个事务来处理它们。...// 1,2,3}查询查询单个对象GORM 提供了 First、Take、Last 方法，以便从数据库中检索单个对象。...对单个对象使用Find而不带limit，db.Find(&user)将会查询整个表并且只返回第一个对象，只是性能不高并且不确定的。...not found错误所以，在你想要使用例如 user 这样的变量从数据库中获取新值前，需要将例如 id 这样的主键设置为nil。

1131 0

go开发基本功-数据操作

/mysql" ) 3.连接到数据库：使用database/sql包的Open函数来连接到MySQL数据库： func main() { db, err := sql.Open("mysql"...// 插入数据 result, err := db.Exec("INSERT INTO users (name, age) VALUES (?, ?)"..., user.Name, user.Age) } // 删除数据 _, err = db.Exec("DELETE FROM users WHERE id=?"...使用步骤： 1.安装gorm库： go get -u gorm.io/gorm 2.导入必要的包 package main import ( "fmt" "gorm.io/driver...Name: %s, Age: %d\n", user.ID, user.Name, user.Age) } } ``` 这个多多练习，基础的使用是没有问题的，如何灵活使用，为自己所用才是关键。

2252 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭