今天咱们一起来学习下gorm中的几个核心数据结构。通过了解gorm底层的数据结构，能够让我们了解gorm底层的实现，以便更好的使用gorm。...在gorm中主要有5个核心结构：DB、Config、Statment、Clause和Schema。接下来我们就详细的看下每种数据结构以及各结构之间的关系。...二、Config结构 Config结构是包含在DB结构内的。顾名思义，Config就是和数据库相关的一些配置。在gorm.Open函数中传入的，如上面我们对数据表命名的配置中禁用了表名的复数形式。...然后gorm再通过model结构体转换成对应的表的建表模式，并将其复制到Schema字段中。 Dest字段 Dest字段用来接收从数据表中查询的结果。...在gorm中，会通过对应名称的函数来组织对应的从句。
下面我们以gorm为例讲解一下,为什么，同时让大家熟悉一下gorm的是如何开启事务的。...GORM 默认会将单个的 create, update, delete操作封装在事务内进行处理，以确保数据的完整性。...我们以订单的支付流程为例： 订单表 package models import "github.com/jinzhu/gorm" type Order struct { gorm.Model...Balance float64 `gorm:"type:decimal(20,2)"` } 主要的业务逻辑 package main import ( "errors" "fmt"...： 0 支付成功的订单数： 10 综上所述，mysql在开启事务的情况下也不能防止刷单，还要加上for update 在gorm中，我们可以这样为SQL加上for update Set("gorm:query_option
序 本文主要研究一下gorm的DeletedAt advance-gorm-3-638.jpg DeletedAt gorm.io/gorm@v1.20.10/soft_delete.go type...DeleteClauses方法使用的是SoftDeleteDeleteClause SoftDeleteQueryClause gorm.io/gorm@v1.20.10/soft_delete.go...方法会追加DeletedAt为nil的查询条件 SoftDeleteDeleteClause gorm.io/gorm@v1.20.10/soft_delete.go type SoftDeleteDeleteClause...方法会回调这些interface的对应方法 小结 gorm的DeletedAt为sql.NullTime类型，它定义了QueryClauses方法，使用的是SoftDeleteQueryClause...doc gorm
序 本文主要研究一下gorm的DeletedAt DeletedAt gorm.io/gorm@v1.20.10/soft_delete.go type DeletedAt sql.NullTime...DeleteClauses方法使用的是SoftDeleteDeleteClause SoftDeleteQueryClause gorm.io/gorm@v1.20.10/soft_delete.go...方法会追加DeletedAt为nil的查询条件 SoftDeleteDeleteClause gorm.io/gorm@v1.20.10/soft_delete.go type SoftDeleteDeleteClause...方法会回调这些interface的对应方法 小结 gorm的DeletedAt为sql.NullTime类型，它定义了QueryClauses方法，使用的是SoftDeleteQueryClause，它的...doc gorm
序 本文主要研究一下gorm的logger OIP - 2021-01-10T234039.816.jpeg logger gorm.io/gorm@v1.20.10/logger/logger.go...、Info、Warn、Error、Trace方法 Session.Logger gorm.io/gorm@v1.20.10/gorm.go type Session struct { DryRun...c.processor.callbacks = append(c.processor.callbacks, c) return c.processor.compile() } callback的Remove...的logger提供了Interface接口，可以自己实现并全局设置或者在session级别设置；gorm默认的logger实现了logger.Interface接口定义的LogMode、Info、Warn...doc gorm
序 本文主要研究一下gorm的logger logger gorm.io/gorm@v1.20.10/logger/logger.go type logger struct { Writer...、Info、Warn、Error、Trace方法 Session.Logger gorm.io/gorm@v1.20.10/gorm.go type Session struct { DryRun...c.processor.callbacks = append(c.processor.callbacks, c) return c.processor.compile() } callback的Remove...的logger提供了Interface接口，可以自己实现并全局设置或者在session级别设置；gorm默认的logger实现了logger.Interface接口定义的LogMode、Info、Warn...doc gorm
序 本文主要研究一下gorm的Transaction Transaction gorm.io/gorm@v1.20.10/finisher_api.go // Transaction start a transaction...方法针对非TxCommitter类型的db.Statement.ConnPool执行db.Begin，之后注册defer针对panicked或者err的执行tx.Rollback()，执行fc之后，判断...= nil { t.Error(err) } } 小结 gorm的DB提供了Transaction方法，相当于一个事务模板，自动commit或者rollback，它提供了func...(tx *gorm.DB) error参数用于自定义事务内的数据库操作。...doc gorm
序 本文主要研究一下gorm的Unscoped OIP - 2021-01-15T231557.840.jpeg Unscoped gorm.io/gorm@v1.20.11/chainable_api.go...方法在db.Statement.Unscoped为false的时候才追加db.Statement.Schema.DeleteClauses DeleteClauses gorm.io/gorm@v1.20.11...= nil { panic(err) } } 小结 gorm的Unscoped方法设置tx.Statement.Unscoped为true；针对软删除会追加SoftDeleteDeleteClause...，即设置deleted_at为指定的时间戳；而callbacks的Delete方法在db.Statement.Unscoped为false的时候才追加db.Statement.Schema.DeleteClauses...，而Unscoped则执行的是物理删除。
序 本文主要研究一下gorm的OnConflict u=1258358460,1662352287&fm=26&gp=0.jpg OnConflict gorm.io/gorm@v1.20.11/clause...Column{Name: value}, Value: Column{Table: "excluded", Name: value}} } return assignments } 的DoUpdates...属性是Set类型，Set类型实际是Assignment数组；其Build方法会组装assignment的sql 实例 func onConflictDemo(db *gorm.DB) { entities...的OnConflict定义了Columns、Where、OnConstraint、DoNothing、DoUpdates、UpdateAll属性；Build方法会根据这些属性拼装sql，如果是DoNothing...doc gorm
序 本文主要研究一下gorm的IsolationLevel IsolationLevel /usr/local/go/src/database/sql/sql.go // IsolationLevel...的Transaction方法提供了*sql.TxOptions参数，可以用于设置Isolation，它最后传递给具体的driver BeginTx github.com/go-sql-driver/mysql...、LevelRepeatableRead、LevelSnapshot、LevelSerializable、LevelLinearizable；gorm的Transaction方法提供了*sql.TxOptions...参数，可以用于设置Isolation，它最后传递给具体的driver；BeginTx会判断若指定的隔离级别不是default则会执行mapIsolationLevel映射到mysql支持的隔离级别，然后执行...doc gorm
序 本文主要研究一下gorm的Transaction u=836865041,2825096190&fm=26&gp=0.jpg Transaction gorm.io/gorm@v1.20.10/...方法针对非TxCommitter类型的db.Statement.ConnPool执行db.Begin，之后注册defer针对panicked或者err的执行tx.Rollback()，执行fc之后，判断...= nil { t.Error(err) } } 小结 gorm的DB提供了Transaction方法，相当于一个事务模板，自动commit或者rollback，它提供了func...(tx *gorm.DB) error参数用于自定义事务内的数据库操作。...doc gorm
序 本文主要研究一下gorm的prometheus Plugin gorm.io/gorm@v1.20.10/interfaces.go // Plugin GORM plugin interface.../gorm@v1.20.10/gorm.go func (db *DB) Use(plugin Plugin) (err error) { name := plugin.Name() if...的Use方法用于启动一个plugin，它会执行plugin.Initialize(db) 实例 db.Use(prometheus.New(prometheus.Config{...的Plugin接口定义了Name、Initialize方法；gorm的Use方法用于启动一个plugin，它会执行plugin.Initialize(db)；Prometheus实现了Plugin接口定义了...doc gorm
序 本文主要研究一下gorm的Locking OIP - 2021-01-18T234935.279.jpeg Locking gorm.io/gorm@v1.20.11/clause/locking.go...doc gorm
序 本文主要研究一下gorm的CreateInBatches CreateInBatches gorm.io/gorm@v1.20.11/finisher_api.go // CreateInBatches...其rowsAffected是每个批次的rowsAffected的累加 AddError gorm.io/gorm@v1.20.11/gorm.go // AddError add error to db...的CreateInBatches允许用户自定义batchSize，它会根据batchSize来分配进行create，但是他们是在同一个事务的，其rowsAffected是每个批次的rowsAffected...的累加。...doc gorm
序 本文主要研究一下gorm的Locking Locking gorm.io/gorm@v1.20.11/clause/locking.go type Locking struct { Strength...doc gorm
我们能定义的所有hook接口可以在gorm/callbacks/interface.go中查到 //gorm/callbacks/interface.go type BeforeCreateInterface...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机制在源码中是如何实现的？...我们以Create为例，说明一下hook的实现方式。 gorm中对库表的操作，都是基于callback机制的（对于callback，稍后会专门写一篇来讲）。...gorm@v1.21.9/callbacks/create.go中定义 所以，对一次Create操作，其核心流程如下: ?
序 本文主要研究一下gorm的IsolationLevel zbiz2beo07ccmj1cuyqd.png IsolationLevel /usr/local/go/src/database/sql...的Transaction方法提供了*sql.TxOptions参数，可以用于设置Isolation，它最后传递给具体的driver BeginTx github.com/go-sql-driver/...、LevelRepeatableRead、LevelSnapshot、LevelSerializable、LevelLinearizable；gorm的Transaction方法提供了*sql.TxOptions...参数，可以用于设置Isolation，它最后传递给具体的driver；BeginTx会判断若指定的隔离级别不是default则会执行mapIsolationLevel映射到mysql支持的隔离级别，然后执行...doc gorm
序 本文主要研究一下gorm的prometheus u=3843080822,546178080&fm=26&gp=0.jpg Plugin gorm.io/gorm@v1.20.10/interfaces.go.../gorm@v1.20.10/gorm.go func (db *DB) Use(plugin Plugin) (err error) { name := plugin.Name() if...的Use方法用于启动一个plugin，它会执行plugin.Initialize(db) 实例 db.Use(prometheus.New(prometheus.Config{...的Plugin接口定义了Name、Initialize方法；gorm的Use方法用于启动一个plugin，它会执行plugin.Initialize(db)；Prometheus实现了Plugin接口定义了...doc gorm
序 本文主要研究一下gorm的OnConflict OnConflict gorm.io/gorm@v1.20.11/clause/on_conflict.go type OnConflict struct...Column{Name: value}, Value: Column{Table: "excluded", Name: value}} } return assignments } 的DoUpdates...属性是Set类型，Set类型实际是Assignment数组；其Build方法会组装assignment的sql 实例 func onConflictDemo(db *gorm.DB) { entities...的OnConflict定义了Columns、Where、OnConstraint、DoNothing、DoUpdates、UpdateAll属性；Build方法会根据这些属性拼装sql，如果是DoNothing...doc gorm
序 本文主要研究一下gorm的GroupBy OIP - 2021-01-19T235758.765.jpeg GroupBy gorm.io/gorm@v1.20.11/clause/group_by.go...checkBuildClauses(t, result.Clauses, result.Result, result.Vars) }) } } 小结 gorm...的GroupBy定义了Columns和Having属性，其Build方法遍历Columns，最后针对Having在拼接Having子句。...doc gorm
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
腾讯会议
云直播
