Как правильно запускать хранимые процедуры?

Question

[dodrator]

Чтобы использовать написанную хранимку её нужно сначала запустить (сохранить в БД) в go коде, затем можно вызывать её по имени процедуры. Go код выглядит примерно так и он запускает sql file с созданием хранимки:

// execute stored sql function
	script, err := ioutil.ReadFile("path/to/procedure.sql")
	if err != nil {
		log.Fprintf(os.Stderr, "Error reading SQL script file: %v\n", err)
	}
	_, err = db.Exec(context.Background(), string(script))
	if err != nil {
		log.Fprintf(os.Stderr, "Error executing SQL script: %v\n", err)
	}

Если этот кусок кода вписать в go функцию, то она будет срабатывать при каждом вызове функции, хотя хранимка будет сохранена в БД после первого вызова, т.е последующие вызовы будут просто заменять уже существующую процедуру в БД. Мне интересно, важно ли то, чтобы код создания хранимки запускался единожды? Если да, то как этого достичь?

Answer 1

[Леонид Николаев]

либо добавить if not exists, но лучше почитать про goose (https://github.com/pressly/goose)

Comments

[dodrator]

интересная библиотека, наверно буду лучше её использовать вместо golang/migrate

[dodrator]

Леонид Николаев а этот способ может быть использован в продакшене?

[Леонид Николаев]

dodrator, мы используем. И, по-моему, это вообще чуть не стандарт. Там есть нюансы с хранимками,но он легко гуглится

Answer 2

[mayton2019]

Обычно в проекте заводят отдельный модуль. Версионный контроль для БД. Можно на базе
liquibase или flyway. Можно на базе каких-то Go-технологий.

Но суть такова. Хранимка устанавливается синхронно с обновлением версии комплекса. Как
часть установочного pipeline. И далее из кода ты ее просто вызываешь по имени.

Answer 3

[uvelichitel]

О каких хранимках идёт речь?
В postgres есть собственная метафора хранимок, скомпилированных и живущих на postgres сервере. В Go пакет стандартной библиотеки sql сделан кросс-sql-движковым и ближайший аналог это sql.Stmt https://pkg.go.dev/database/sql#Stmt (в документации есть примеры кода). Вы можете скомпилировать sql стейтмент единожды в контексте соединения или транзакции и использовать многократно и потоко-безопасно пока жив контекст. Это даёт выигрыш в производительности.
Если я правильно вопрос)
Наивный код

script, err := ioutil.ReadFile("path/to/procedure.sql")
if err != nil {
    log.Fprintf(os.Stderr, "Error reading SQL script file: %v\n", err)
}
stmt, err := db.PrepareContext(context.Background(), string(script)) //компилируем стейтмент как шаблон c плейсхолдерами аргументов
if err != nil {
	log.Fatal(err)
}
_, err = stmt.ExecContext(ctx, args) //применяем стейтмент к аргументам args... в контексте ctx
if err != nil {
    log.Fprintf(os.Stderr, "Error executing SQL script: %v\n", err)
}

Шаблон (path/to/procedure.sql) может выглядеть так
SELECT username FROM users WHERE id = ?
Вопросительный знак ? это плейсхолдер для аргумента

Comments

[dodrator]

Это похоже на то, что я хотел, но я имел ввиду такую хранимку:

CREATE PROCEDURE insert_data(a integer, b integer)
LANGUAGE SQL
AS $$
INSERT INTO tbl VALUES (a);
INSERT INTO tbl VALUES (b);
$$;

Там человек выше написал про библиотеку goose, которая инициализирует миграции и такие хранимки заодно, думаю это то, что я искал. Но про sql.Stmt я не знал, спасибо)

Answer 4

[d-stream]

"запуск", а правильнее - выполнение stored procedures - это действие, которое существенно отличается от их "установки" aka компиляции. В том числе это требует совершенно разных прав. Компиляция процедур/функций - требует повышенных прав.

А то что описано в переводе [и немного утрируя] звучит как: "исполняемая программа на go, которая генерит исходник на go, компилирует его и выполняет"

В общем случае так не делают в проде. На олимпиадах и вирусописательстве - возможно.

Comments

[dodrator]

вот я и хочу узнать как делать правильно

Answer 5

[darst]

Посмотрите вот этот метод sync.Once. Он позволяет выполнить код только один раз в запущенной программе.