Method executeQueries

pkg/management/postgres/initdb.go:433–471

executeQueries run the set of queries in the provided database connection

(sqlUser *sql.DB, queries []string)

// executeQueries run the set of queries in the provided database connection
func (info InitInfo) executeQueries(sqlUser *sql.DB, queries []string) error {
	if len(queries) == 0 {
		log.Debug("No queries to execute")
		return nil
	}

	// The pool pins search_path to pg_catalog. User-authored init scripts
	// expect the standard `"$user", public` resolution, so we set that
	// once at the start of the batch on a dedicated *sql.Conn and reset
	// at the end. Any user SET inside the script persists across
	// statements within the same batch, matching PostgreSQL's default
	// session semantics.
	ctx := context.Background()
	conn, err := sqlUser.Conn(ctx)
	if err != nil {
		return fmt.Errorf("acquiring dedicated connection for init queries: %w", err)
	}
	defer func() {
		// Reset in a defer so the pin is restored even if a query fails;
		// pooled pgx connections keep session GUCs across reuse.
		if _, resetErr := conn.ExecContext(ctx, `RESET search_path`); resetErr != nil {
			log.Error(resetErr, "while resetting search_path after init queries")
		}
		_ = conn.Close()
	}()

	if _, err := conn.ExecContext(ctx, `SET search_path TO "$user", public`); err != nil {
		return fmt.Errorf("setting search_path before init queries: %w", err)
	}

	for _, sqlQuery := range queries {
		log.Debug("Executing query", "sqlQuery", sqlQuery)
		if _, err := conn.ExecContext(ctx, sqlQuery); err != nil {
			return err
		}
	}

	return nil
}

// Bootstrap creates and configures this new PostgreSQL instance
func (info InitInfo) Bootstrap(ctx context.Context) error {