Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SetMaxOpenConns (0.05 sec)

  1. tests/prepared_stmt_test.go

    	AssertEqual(t, len(conn.Stmts.Keys()), 0)
    
    }
    
    func TestPreparedStmtDeadlock(t *testing.T) {
    	tx, err := OpenTestConnection(&gorm.Config{})
    	AssertEqual(t, err, nil)
    
    	sqlDB, _ := tx.DB()
    	sqlDB.SetMaxOpenConns(1)
    
    	tx = tx.Session(&gorm.Session{PrepareStmt: true})
    
    	wg := sync.WaitGroup{}
    	for i := 0; i < 100; i++ {
    		wg.Add(1)
    		go func() {
    			user := User{Name: "jinzhu"}
    			tx.Create(&user)
    
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 8K bytes
    - Viewed (0)
  2. internal/event/target/postgresql.go

    	db, err := sql.Open("postgres", target.connString)
    	if err != nil {
    		return err
    	}
    	target.db = db
    
    	if args.MaxOpenConnections > 0 {
    		// Set the maximum connections limit
    		target.db.SetMaxOpenConns(args.MaxOpenConnections)
    	}
    
    	err = target.db.Ping()
    	if err != nil {
    		if !xnet.IsConnRefusedErr(err) && !xnet.IsConnResetErr(err) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  3. internal/event/target/mysql.go

    		target.loggerOnce(context.Background(), err, target.ID().String())
    		return err
    	}
    	target.db = db
    
    	if args.MaxOpenConnections > 0 {
    		// Set the maximum connections limit
    		target.db.SetMaxOpenConns(args.MaxOpenConnections)
    	}
    
    	err = target.db.Ping()
    	if err != nil {
    		if !xnet.IsConnRefusedErr(err) && !xnet.IsConnResetErr(err) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 11.6K bytes
    - Viewed (0)
Back to top