Function waitForMySQL

internal/sqltest/native/mysql.go:164–190

(ctx context.Context, uri string, timeout time.Duration)

}

func waitForMySQL(ctx context.Context, uri string, timeout time.Duration) error {
	deadline := time.Now().Add(timeout)
	ticker := time.NewTicker(500 * time.Millisecond)
	defer ticker.Stop()

	// Make an immediate first attempt before waiting for the ticker
	if err := tryMySQLConnection(ctx, uri); err == nil {
		return nil
	}

	var lastErr error
	for {
		select {
		case <-ctx.Done():
			return fmt.Errorf("context cancelled: %w (last error: %v)", ctx.Err(), lastErr)
		case <-ticker.C:
			if time.Now().After(deadline) {
				return fmt.Errorf("timeout waiting for MySQL (last error: %v)", lastErr)
			}
			if err := tryMySQLConnection(ctx, uri); err != nil {
				lastErr = err
				continue
			}
			return nil
		}
	}
}

func tryMySQLConnection(ctx context.Context, uri string) error {
	db, err := sql.Open("mysql", uri)