Function buildConfigSecret

server/server.go:2105–2146

buildConfigSecret builds a CREATE SECRET statement with explicit credentials

(dlCfg DuckLakeConfig)

		expectedNames[i] = ix.name
	}
	checkCtx, checkCancel := context.WithTimeout(context.Background(), 5*time.Second)
	var present int
	err = pgDB.QueryRowContext(checkCtx, "SELECT count(*) FROM pg_indexes WHERE indexname = ANY($1)", expectedNames).Scan(&present)
	checkCancel()
	if err == nil && present == len(duckLakeMetadataIndexes) {
		duckLakeIndexDone.Store(true)
		slog.Info("DuckLake metadata indexes already present; skipped ensure.", "verified", present, "total", len(duckLakeMetadataIndexes))
		return
	}

	// Slow path: create any missing indexes.
	// Use a generous timeout — CREATE INDEX on large tables (e.g., ducklake_file_column_stats
	// at 1.2 GB) can take minutes on first run.
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Minute)
	defer cancel()

	if err := pgDB.PingContext(ctx); err != nil {
		slog.Warn("Failed to connect to DuckLake metadata store for index creation.", "error", err)
		return
	}

	created := 0
	for _, ix := range duckLakeMetadataIndexes {
		if _, err := pgDB.ExecContext(ctx, ix.stmt); err != nil {
			slog.Warn("Failed to create DuckLake metadata index.", "statement", ix.stmt, "error", err)
			// Continue — create as many indexes as possible
		} else {
			created++
		}
	}

	if created == len(duckLakeMetadataIndexes) {
		duckLakeIndexDone.Store(true)
	}
	slog.Info("Ensured DuckLake metadata indexes.", "created_or_verified", created, "total", len(duckLakeMetadataIndexes))
}

// setDuckLakeDefault sets the DuckLake catalog as the default so all queries use it.
// This should be called AFTER creating per-connection views in memory.main.
func setDuckLakeDefault(db *sql.DB) error {
	if _, err := db.Exec("USE ducklake"); err != nil {
		return fmt.Errorf("failed to set DuckLake as default catalog: %w", err)
	}
	slog.Info("Set DuckLake as default catalog.")
	return nil