Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for Commit (0.33 sec)

  1. tests/transaction_test.go

    	user := User{Name: "transaction"}
    	if err := tx.Save(&user).Error; err != nil {
    		t.Fatalf("No error should raise")
    	}
    
    	if err := tx.Commit().Error; err != nil {
    		t.Fatalf("Commit should not raise error")
    	}
    
    	if err := tx.Rollback().Error; err == nil {
    		t.Fatalf("Rollback after commit should raise error")
    	}
    }
    
    func TestTransactionWithSavePoint(t *testing.T) {
    	tx := DB.Begin()
    
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Sat Jun 10 13:05:19 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  2. prepare_stmt.go

    	PreparedStmtDB *PreparedStmtDB
    }
    
    func (db *PreparedStmtTX) GetDBConn() (*sql.DB, error) {
    	return db.PreparedStmtDB.GetDBConn()
    }
    
    func (tx *PreparedStmtTX) Commit() error {
    	if tx.Tx != nil && !reflect.ValueOf(tx.Tx).IsNil() {
    		return tx.Tx.Commit()
    	}
    	return ErrInvalidTransaction
    }
    
    func (tx *PreparedStmtTX) Rollback() error {
    	if tx.Tx != nil && !reflect.ValueOf(tx.Tx).IsNil() {
    		return tx.Tx.Rollback()
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Thu Mar 28 08:47:39 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  3. callbacks/callbacks.go

    	createCallback.Register("gorm:save_after_associations", SaveAfterAssociations(true))
    	createCallback.Register("gorm:after_create", AfterCreate)
    	createCallback.Match(enableTransaction).Register("gorm:commit_or_rollback_transaction", CommitOrRollbackTransaction)
    	createCallback.Clauses = config.CreateClauses
    
    	queryCallback := db.Callback().Query()
    	queryCallback.Register("gorm:query", Query)
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Wed Oct 27 23:56:55 GMT 2021
    - 3.3K bytes
    - Viewed (0)
  4. interfaces.go

    }
    
    // ConnPoolBeginner conn pool beginner
    type ConnPoolBeginner interface {
    	BeginTx(ctx context.Context, opts *sql.TxOptions) (ConnPool, error)
    }
    
    // TxCommitter tx committer
    type TxCommitter interface {
    	Commit() error
    	Rollback() error
    }
    
    // Tx sql.Tx interface
    type Tx interface {
    	ConnPool
    	TxCommitter
    	StmtContext(ctx context.Context, stmt *sql.Stmt) *sql.Stmt
    }
    
    // Valuer gorm valuer interface
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Sat Aug 19 13:33:31 GMT 2023
    - 2.2K bytes
    - Viewed (0)
  5. tests/update_test.go

    	}
    }
    
    func TestOmitWithUpdate(t *testing.T) {
    	user := *GetUser("omit_update", Config{Account: true, Pets: 3, Toys: 3, Company: true, Manager: true, Team: 3, Languages: 3, Friends: 4})
    	DB.Create(&user)
    
    	var result User
    	DB.First(&result, user.ID)
    
    	user2 := *GetUser("omit_update_new", Config{Account: true, Pets: 3, Toys: 3, Company: true, Manager: true, Team: 3, Languages: 3, Friends: 4})
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Mon Dec 04 03:50:58 GMT 2023
    - 30.3K bytes
    - Viewed (0)
  6. tests/associations_has_one_test.go

    	}
    
    	AssertAssociationCount(t, user2, "Account", 0, "after clear")
    }
    
    func TestHasOneAssociationWithSelect(t *testing.T) {
    	user := *GetUser("hasone", Config{Account: true})
    
    	DB.Omit("Account.Number").Create(&user)
    
    	AssertAssociationCount(t, user, "Account", 1, "")
    
    	var account Account
    	DB.Model(&user).Association("Account").Find(&account)
    	if account.Number != "" {
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Thu Jan 06 07:02:53 GMT 2022
    - 6.8K bytes
    - Viewed (0)
  7. tests/prepared_stmt_test.go

    	}
    
    	if err := tx.Create(&User{Name: "zzjin"}).Error; err != nil {
    		tx.Rollback()
    		t.Errorf("Failed to run one transaction, got error %v\n", err)
    	}
    
    	if err := tx.Commit().Error; err != nil {
    		t.Errorf("Failed to commit transaction, got error %v\n", err)
    	}
    
    	if result := db.Where("name=?", "zzjin").Delete(&User{}); result.Error != nil || result.RowsAffected != 1 {
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Thu Mar 21 07:55:43 GMT 2024
    - 4K bytes
    - Viewed (0)
  8. callbacks/associations.go

    		tx = tx.Set("gorm:update_track_time", true)
    	}
    
    	if len(selects) > 0 {
    		tx = tx.Select(selects)
    	} else if restricted && len(omits) == 0 {
    		tx = tx.Omit(clause.Associations)
    	}
    
    	if len(omits) > 0 {
    		tx = tx.Omit(omits...)
    	}
    
    	return db.AddError(tx.Create(values).Error)
    }
    
    // check association values has been saved
    // if values kind is Struct, check it has been saved
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Tue Apr 11 03:06:13 GMT 2023
    - 14.3K bytes
    - Viewed (0)
  9. chainable_api.go

    			}
    		}
    	default:
    		tx.AddError(fmt.Errorf("unsupported select args %v %v", query, args))
    	}
    
    	return
    }
    
    // Omit specify fields that you want to ignore when creating, updating and querying
    func (db *DB) Omit(columns ...string) (tx *DB) {
    	tx = db.getInstance()
    
    	if len(columns) == 1 && strings.ContainsRune(columns[0], ',') {
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Wed Apr 17 03:38:55 GMT 2024
    - 14.3K bytes
    - Viewed (1)
  10. finisher_api.go

    	}
    
    	if err != nil {
    		tx.AddError(err)
    	}
    
    	return tx
    }
    
    // Commit commits the changes in a transaction
    func (db *DB) Commit() *DB {
    	if committer, ok := db.Statement.ConnPool.(TxCommitter); ok && committer != nil && !reflect.ValueOf(committer).IsNil() {
    		db.AddError(committer.Commit())
    	} else {
    		db.AddError(ErrInvalidTransaction)
    	}
    	return db
    }
    
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Fri Jan 12 08:42:21 GMT 2024
    - 22.7K bytes
    - Viewed (0)
Back to top