Как правильно устанавливать соединение с БД?

Question

[dodrator]

Я использую pgx pool. В офф документации написан этот код:

func main() {
	dbpool, err := pgxpool.New(context.Background(), os.Getenv("DATABASE_URL"))
	if err != nil {
		fmt.Fprintf(os.Stderr, "Unable to create connection pool: %v\n", err)
		os.Exit(1)
	}
	defer dbpool.Close()

	var greeting string
	err = dbpool.QueryRow(context.Background(), "select 'Hello, world!'").Scan(&greeting)
	if err != nil {
		fmt.Fprintf(os.Stderr, "QueryRow failed: %v\n", err)
		os.Exit(1)
	}

	fmt.Println(greeting)
}

Как работают с БД в продакшене, насколько этот пример взаимодействия с БД соответствует реальности? Судя по примеру, мне просто нужно использовать этот код везде, где я провожу операции с БД. Если я делаю запись в базу, то создаю/закрываю соединение таким образов в функции, которая проводит эту запись, вставляю sql код и готово. Тоже самое с чтением из базы или может есть какие-то паттерны для работы с БД в go, а пример в документации для наивных? Например, в Java были репозитории с методами типа findUserBy(Id,Username и так далее) и их учили использовать с самого начала

Comments

[Александр Павлюк]

Нет, этот код нужно использовать только при старте вашего приложения. Пул коннектов к базе создается один раз и потом используется все время работы приложения.

[dodrator]

Александр Павлюк, а как это достигается? Мне на ум приходит идея close вынести в отдельную функцию, чтобы сразу не закрывать соединение после того как функция отработает операцию, но, в этом случае, когда закрывать соединение не понятно. Дальше наверно надо делиться переменной dbpool с другими пакетами? Для этого наверно создать структуру, куда внести переменную *pgx.pool и использовать DI

[Everything_is_not_so_bad]

dodrator, нужно создать колбэки onStart, onClose при открытии и закрытии приложения

[Александр Павлюк]

dodrator, Close нужно выносить в обработчик, который отвечает за graceful shutdown вашего сервиса.
Пул передается в другие пакеты с помощью DI, все верно.

Answer 1

[DollyPapper]

Если вы будете пул создавать каждый раз при запросе в каждой функции, то какой тогда смысл от пула? Пул в go это своего рода синглтон, он создается один раз и далее распространяется по всему приложению. Очевидно, что если каждый раз будет новый инстанс пула, то никакой защиты от переполнения коннектов мы не получим. Итого: пул создается один раз, далее во всех остальные части программы он передается как вам удобно, через DI напрямую в фукнцию, в конструктор обьекта или еще как.

Answer 2

[calculator212]

Например, в Java были репозитории с методами типа findUserBy(Id,Username и так далее)

Вероятно использовалась ORM, в го они тоже есть. Но советовал бы вам попробовать пописать запросы в ручную, т.к. это довольно часто встречается можете для начала почитать гайд