Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 48 for Tx (0.01 sec)

  1. tests/generics_test.go

    	ctx := context.Background()
    	tx := DB.Begin()
    	if tx.Error != nil {
    		t.Fatalf("failed to begin transaction: %v", tx.Error)
    	}
    
    	users := []User{{Name: "TestGenericsTransaction", Age: 18}, {Name: "TestGenericsTransaction2", Age: 18}}
    	err := gorm.G[User](tx).CreateInBatches(ctx, &users, 2)
    
    	count, err := gorm.G[User](tx).Where("name like ?", "TestGenericsTransaction%").Count(ctx, "*")
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Sep 04 13:13:16 UTC 2025
    - 28K bytes
    - Viewed (0)
  2. callbacks/helper.go

    				values.Values[i] = make([]interface{}, len(columns))
    			}
    
    			values.Values[i][idx] = v
    		}
    	}
    	return
    }
    
    func hasReturning(tx *gorm.DB, supportReturning bool) (bool, gorm.ScanMode) {
    	if supportReturning {
    		if c, ok := tx.Statement.Clauses["RETURNING"]; ok {
    			returning, _ := c.Expression.(clause.Returning)
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Apr 14 12:32:57 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  3. generics.go

    	})
    }
    
    func (c chainG[T]) Preload(association string, query func(db PreloadBuilder) error) ChainInterface[T] {
    	return c.with(func(db *DB) *DB {
    		return db.Preload(association, func(tx *DB) *DB {
    			q := preloadBuilder{db: tx.getInstance()}
    			if query != nil {
    				if err := query(&q); err != nil {
    					db.AddError(err)
    				}
    			}
    
    			relation, ok := db.Statement.Schema.Relationships.Relations[association]
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Sep 04 13:13:16 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  4. migrator/migrator.go

    			}
    
    			err = tx.Exec(createTableSQL, values...).Error
    			return err
    		}); err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    // DropTable drop table for values
    func (m Migrator) DropTable(values ...interface{}) error {
    	values = m.ReorderModels(values, false)
    	for i := len(values) - 1; i >= 0; i-- {
    		tx := m.DB.Session(&gorm.Session{})
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Jun 06 02:35:01 UTC 2025
    - 29.5K bytes
    - Viewed (0)
  5. tests/upsert_test.go

    	}
    	user := User{ID: 1, Name: "king"}
    	tx := DB.Session(&gorm.Session{DryRun: true}).Save(&user)
    
    	if err := tx.Error; err != nil {
    		t.Fatalf("failed to update user,missing where condition,err=%+v", err)
    	}
    
    	if !regexp.MustCompile("WHERE .id. = [^ ]+$").MatchString(tx.Statement.SQL.String()) {
    		t.Fatalf("invalid updating SQL, got %v", tx.Statement.SQL.String())
    	}
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Tue Jul 29 11:06:13 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  6. tests/soft_delete_test.go

    		t.Errorf("Failed, result.DeletedAt: %v is not same as expected.DeletedAt: %v", result.DeletedAt, expected.DeletedAt)
    	}
    }
    
    func TestDeletedAtOneOr(t *testing.T) {
    	actualSQL := DB.ToSQL(func(tx *gorm.DB) *gorm.DB {
    		return tx.Or("id = ?", 1).Find(&User{})
    	})
    
    	if !regexp.MustCompile(` WHERE id = 1 AND .users.\..deleted_at. IS NULL`).MatchString(actualSQL) {
    		t.Fatalf("invalid sql generated, got %v", actualSQL)
    	}
    }
    
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Wed Feb 01 06:40:55 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  7. tests/query_test.go

    		results    []User
    		totalBatch int
    	)
    
    	if result := DB.Table("users as u").Where("name = ?", users[0].Name).FindInBatches(&results, 2, func(tx *gorm.DB, batch int) error {
    		totalBatch += batch
    
    		if tx.RowsAffected != 2 {
    			t.Errorf("Incorrect affected rows, expects: 2, got %v", tx.RowsAffected)
    		}
    
    		if len(results) != 2 {
    			t.Errorf("Incorrect users length, expects: 2, got %v", len(results))
    		}
    
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Tue Jul 22 06:21:04 UTC 2025
    - 51K bytes
    - Viewed (0)
  8. cmd/perf-tests.go

    	if delta < 0 {
    		rx = 0
    		errStr = "network disconnection issues detected"
    	}
    
    	globalNetPerfRX.Reset()
    	return madmin.NetperfNodeResult{Endpoint: "", TX: r.n / uint64(duration.Seconds()), RX: uint64(rx / delta.Seconds()), Error: errStr}
    }
    
    func siteNetperf(ctx context.Context, duration time.Duration) madmin.SiteNetPerfNodeResult {
    	r := &netperfReader{eof: make(chan struct{})}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  9. docs/logging/README.md

      "event": "",
      "trigger": "incoming",
      "api": {
        "name": "PutObject",
        "bucket": "testbucket",
        "object": "hosts",
        "status": "OK",
        "statusCode": 200,
        "rx": 401,
        "tx": 0,
        "timeToResponse": "13309747ns",
        "timeToResponseInNS": "13309747"
      },
      "remotehost": "127.0.0.1",
      "requestID": "17CDC1F4D7E69123",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  10. tests/table_test.go

    func TestTableWithNamer(t *testing.T) {
    	db, _ := gorm.Open(tests.DummyDialector{}, &gorm.Config{
    		NamingStrategy: schema.NamingStrategy{
    			TablePrefix: "t_",
    		},
    	})
    
    	sql := db.ToSQL(func(tx *gorm.DB) *gorm.DB {
    		return tx.Model(&UserWithTableNamer{}).Find(&UserWithTableNamer{})
    	})
    
    	if !regexp.MustCompile("SELECT \\* FROM `t_users`").MatchString(sql) {
    		t.Errorf("Table with namer, got %v", sql)
    	}
    }
    
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Jul 21 02:46:58 UTC 2025
    - 12.7K bytes
    - Viewed (0)
Back to top