Function openSQLiteDatabaseWithPragmas

internal/store/sqlite.go:46–82

(
	ctx context.Context,
	path string,
	pragmas []string,
	initialize func(context.Context, *sql.DB) error,
)

}

func openSQLiteDatabaseWithPragmas(
	ctx context.Context,
	path string,
	pragmas []string,
	initialize func(context.Context, *sql.DB) error,
) (*sql.DB, error) {
	cleanPath := strings.TrimSpace(path)
	if cleanPath == "" {
		return nil, errors.New("store: database path is required")
	}
	if err := os.MkdirAll(filepath.Dir(cleanPath), 0o755); err != nil {
		return nil, fmt.Errorf("store: create database directory for %q: %w", cleanPath, err)
	}

	db, err := openSQLiteDatabaseOnce(ctx, cleanPath, initialize, pragmas...)
	if err == nil {
		return db, nil
	}
	if !ShouldRecoverSQLite(err) {
		return nil, err
	}
	if _, statErr := os.Stat(cleanPath); statErr != nil {
		return nil, err
	}
	if _, recoverErr := recoverSQLiteDatabase(cleanPath); recoverErr != nil {
		return nil, errors.Join(err, fmt.Errorf("store: recover sqlite database %q: %w", cleanPath, recoverErr))
	}

	db, reopenErr := openSQLiteDatabaseOnce(ctx, cleanPath, initialize, pragmas...)
	if reopenErr != nil {
		return nil, errors.Join(
			err,
			fmt.Errorf("store: reopen sqlite database %q after recovery: %w", cleanPath, reopenErr),
		)
	}
	return db, nil
}

func openSQLiteDatabaseOnce(
	ctx context.Context,