Как правильно сделать соединение с СУБД «MySQL» в глобальной переменной?

Question

[Vadim Rublev]

Как правильно сделать соединение с СУБД "MySQL" в глобальной переменной? Чтобы не соединяться с БД в каждом роуте/функции, а просто юзать один объект-соединение.
Понятно, что типа так:
db, err := sql.Open("mysql", "login:password@/nameDB") // Соединились с БД.
if err != nil {
// _обработчик_Ошибки_
return
}
defer db.Close() // Отложенное закрытие соединения-db.

Собственно, вопрос больше про закрытие, выходит...

Comments

[di]

так а в чем проблема?
я так например делаю - https://github.com/Delgus/reports/blob/master/cmd/...

[Vadim Rublev]

Проблема - как закрывать соединение?
Открываем его в начале модуля. И?... Оно постоянно открыто?...
Поюзал я его в одном роуте - надо же закрыть? Или не надо?

[Vadim Rublev]

Алгоритм пытаюсь понять...

[di]

Vadim Rublev, зачем его закрывать? Open - создает пулл соединений, они сами уничтожаются и переиспользуются в зависимости от настроек. Close закрывает весь пулл

[di]

Vadim Rublev, https://www.youtube.com/watch?v=PxNUZLSNg2o неплохое видео про конфигурацию соединений для прода

[Vadim Rublev]

Ладно. Посмотрю, погуглю...

[Vadim Rublev]

Спасибо за видео! Не знал таких нюансов. :) Я пока не настоящий сварщик. ))
И про http.Client годно! Недавно только со старшими товарищами обсуждал тему Go-клиента... Но как-то безрезультатно. )

[Vadim Rublev]

di, а зачем при открытии пула соединений отложенное закрытие-то указывается? - defer db.Close()
Не могу в толк взять.
Например, у меня Go-сервер (работающий постоянно, понятно), в котором открыт пул соединений (который должен быть открыт всегда, пока работает сервер). Смысл в db.Close()? Ещё и отложенном. После каких таких "завершений чего-то" этот пул должен быть закрыт? При остановке сервера, конечно, и пул закроется (как и всё содержимое модуля уничтожится).

...Или это тупо формальность? ТАК должно записываться - вот и записано?

[di]

Vadim Rublev, ну помимо go-сервера есть еще и ваш mysql,и ему надо сообщить что соединения закрыты, так как он может не закрыть соединения на своей стороне и продолжать держать ресурсы для них.

Ну конечно это чисто теоретически, на практике не экспериментировал с этим. Возможно что и без Close mysql сам "отстрелит" соединения. Хотя именно mysql я бы не очень доверял, эта СУБД потеряла мое доверие в последнее время, ну это уже мое личное мнение.

UPD: Close закрывает базу данных и предотвращает запуск новых запросов. Close ожидает завершения всех запросов, которые начали обработку на сервере
https://golang.org/pkg/database/sql/#DB.Close

[Vadim Rublev]

Понял. Спасибо!
Получается, что когда закрыто последнее соединение, срабатывает defer и весь пул закрывается? Далее, например через 10 сек., пытается открыться новое соединение (оно ж не знает, что пул закрыт), ...и?
Какой-то глубокий тут смысл, до которого я не могу добраться. ))
В какой момент срабатывает закрывающий defer?? Как и где определяется момент/потребность закрыть пул, ибо точно больше не будут открываться соединения?

Answer 1

[Александр Мелентьев]

Можно сделать следующим образом:
в отдельном пакете, пусть это будет database сделать следующее:

package database

import (
	"fmt"
	"github.com/jinzhu/gorm"
	_ "github.com/jinzhu/gorm/dialects/sqlite"
	"log"
	"os"
)

var db *gorm.DB // объявляем переменную для работы с БД

func init() {
	// при обращении к пакету database будет совершена попытка подключения к БД
	conn, err := gorm.Open("sqlite3", "database.db")
	if err != nil {
		log.Println(fmt.Sprintf("database error: %v", err))
	} else {
		log.Println("database connected")
	}
	// записываем результат соединения в ранее объявленную переменную
	db = conn
}

// Создаем глобальную функцию с результатом соединения, чтоб можно было работать с БД из любого пакета
func Connector() *gorm.DB {
	return db
}

Далее в main.go прописать следующее:

package main

import (
	"go-tmp/project/database"
	"log"
)

func main() {
	// объявляем анонимную функцию, которая закроет соединения с БД при завершении работы приложения
	defer func() {
		if err := database.Connector().Close(); err != nil {
			log.Println(err)
		}
	}()
}

Правильнее некуда :)

Comments

[Vadim Rublev]

Почитал тут: https://habr.com/ru/post/332122/ , поняв едва ли половину,
и сделал принципиально как тут: https://metanit.com/go/web/3.1.php , вот так (всё в одном пакете):

func main() {
// Открываем пул соединений (db).
var db, err = sql.Open("mysql", ConnectData)
	if err != nil {
		log.Println("Error creating database connection pool.")
	}
	defer db.Close()

// Открываем в нужном месте (например в роуте сервера) собственно соединение, используя пул-db.
http.HandleFunc("/login", func(w http.ResponseWriter, r *http.Request) {
    var row_search int
    var err = db.QueryRow(_запрос_кол-ва_определённых_строк_таблицы).Scan(&row_search)
    if err != nil {
	fmt.Println("Query error:", err)
	return
    }
    defer err.Close()
}
}

[Vadim Rublev]

Вот только с этим -
defer err.Close()
не пойму пока...
Правильно закрытие указал? Или надо было так:
defer row_search.Close() ?

[Александр Мелентьев]

Vadim Rublev, нужно всё разбивать по сущностям. Мэйн в данном случае энтрипойнт. Базу нужно выносить в отдельный пакет, чтоб не только в функции main можно было использовать соединение с базой.

[Александр Мелентьев]

Vadim Rublev, в данном случае defer не нужен.
P.S. - при объявлении переменных используется camel case

[Vadim Rublev]

> в данном случае defer не нужен.
Как так? Соединение открытым останется?...

[Александр Мелентьев]

Vadim Rublev, Вы ранее написали defer db.Close() - это закроет соединение. QueryRow нужно проверять на ошибку

[Vadim Rublev]

> Базу нужно выносить в отдельный пакет, чтоб не только в функции main можно было использовать соединение с базой.
Это да. В примере, по которому я сделал, есть это:
// Вытаскиваем пул_соединений из main() в публичную переменную.
var Database *sql.DB
func main() {
var db, err = sql.Open("mysql", connectData)
Database = db
}
Затем юзаем эту публичную_переменную-пул где надо.

Я просто пока так не сделал...

[Vadim Rublev]

> Вы ранее написали defer db.Close() - это закроет соединение.
Я думал это только пул закрывает. С предыдущим комментатором про это говорили...

> QueryRow нужно проверять на ошибку
Так проверено же. Не?.. )