当前位置：首页 > ops >正文

MySQL事务的一些奇奇怪怪知识

ops 2025/8/21 21:35:35

Gorm事务有error却不返回会发生什么

Gorm包是大家比较高频使用。正常的用法是，如果有失败返回error，整体rollback，如果不返回error则commit。下面是Transaction的源码：

// Transaction start a transaction as a block, return error will rollback, otherwise to commit. Transaction executes an
// arbitrary number of commands in fc within a transaction. On success the changes are committed; if an error occurs
// they are rolled back.
func (db *DB) Transaction(fc func(tx *DB) error, opts ...*sql.TxOptions) (err error) {panicked := trueif committer, ok := db.Statement.ConnPool.(TxCommitter); ok && committer != nil {// nested transactionif !db.DisableNestedTransaction {err = db.SavePoint(fmt.Sprintf("sp%p", fc)).Errorif err != nil {return}defer func() {// Make sure to rollback when panic, Block error or Commit errorif panicked || err != nil {db.RollbackTo(fmt.Sprintf("sp%p", fc))}}()}err = fc(db.Session(&Session{NewDB: db.clone == 1}))} else {tx := db.Begin(opts...)if tx.Error != nil {return tx.Error}defer func() {// Make sure to rollback when panic, Block error or Commit errorif panicked || err != nil {tx.Rollback()}}()if err = fc(tx); err == nil {panicked = falsereturn tx.Commit().Error}}panicked = falsereturn
}

神奇用法

但如果我瞎搞呢？如果有error我仍然返回nil，会发生什么？

err := db.Transaction(func(tx *gorm.DB) error {var err errorisInserted, err = d.TxCreate(tx, record)if err != nil {return nil}err = d.TxUpdate(tx, opt)if err != nil {return errors.Wrap(err, "failed to update")}return nil})

解释

这种情况下，本质看MySQL自身的设计。事务具有原子性，理论上应该要么全部成功，要么全部失败。但如果在一条语句失败后执行COMMIT，MySQL 会尽力提交已成功执行的语句。例如：

START TRANSACTION;
INSERT INTO test (id, value) VALUES (2, 'data3'); 
INSERT INTO test (id, value) VALUES (3, 'data4'); 
-- 故意让这条语句失败（假设id冲突）
INSERT INTO test (id, value) VALUES (2, 'data5'); 
COMMIT;

在上述例子中，前两条INSERT语句可能已经成功执行并修改了数据库，而第三条失败。执行COMMIT后，前两条语句的修改会被永久保存到数据库中，而失败的语句不会回滚整个事务。

其实十分不建议这么用。数据库状态可能会出现部分操作生效，部分未生效的情况，破坏了事务的原子性。这可能导致数据不一致问题，例如业务逻辑上要求某些数据必须同时存在或不存在，但由于这种部分提交的情况，无法保证这种一致性。

MySQL表数据时间的记录时刻

假设数据库是这样的

CREATE TABLE `conversation_new_message` (`id` bigint unsigned NOT NULL AUTO_INCREMENT COMMENT 'ID',`conversation_new_id` bigint unsigned NOT NULL COMMENT '自增id',`message` json DEFAULT NULL COMMENT 'conversation history, a json map',`turn` bigint NOT NULL COMMENT '轮数',`created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',`updated_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '上一次更新时间',PRIMARY KEY (`id`),
) ENGINE=InnoDB