Сервер golang не отвечает при частых запросах к БД?

Question

[Роман Ракзин]

Есть функция для работы с БД

db := mysql.New("tcp", "", "127.0.0.1:3306", "root", "", "test")
    
        err := db.Connect()
        if err != nil {
            log.Println("Не удалось подключиться к базе данных")
        }
    
        rows, _, err := db.Query(Query,args...)
        if err != nil {
            log.Println("Не удалось выполнить запрос",Query,err)
        }
        
        return rows

Если идёт большое количество запросов-(на самом деле их можно 'наклацать' мышкой скажем со скоростью 10-15 в секунду) переходит в обработчик-'Не удалось подкл и выполнить запрос' и всё приложение висит около минуты.
После этого по непонятным причинам опять всё работает.
еррор написал read tcp 127.0.0.1:20673->127.0.0.1:3306: wsarecv: An established connection was aborted by the software in your host machine.
Подскажите пожалуйста- в чём тут дело и что можно сделать7

Answer 1

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

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

Comments

[Роман Ракзин]

Александр. я тоже так подумал и буду наверное делать так

Answer 2

[uvelichitel]

Попробуйте

db.SetMaxIdleConns(n int)
db.SetMaxOpenConns(n int)

для манипулирования доступным пулом соединений с DB

Comments

[Роман Ракзин]

а что нужно подставить в n? количество подключений?

[uvelichitel]

Роман Ракзин Да нужно пробовать. n здесь количество зарезервированных соединений с базой. Одно из них используется для каждого запроса.

[Роман Ракзин]

я использую godoc.org/github.com/ziutek/mymysql/mysql и он пишет (type mysql.Conn has no field or method SetMaxIdleConns

[uvelichitel]

Роман Ракзин Здаюсь. Я использую database/sql из stdlib и https://github.com/go-sql-driver/mysql/ в качестве драйвера. Мне кажется так идиоматичней)) Просто с вашим драйвером плохо знаком, но общая идея зарезервировать достаточно подключений.

[Роман Ракзин]

я перекомпилил вместе с defer db.Close() и сейчас вроде такого нет. Походу просто забыл закрыть- накосячил. Но может и буду смотреть в сторону -один раз открыть соединение и потом его тягать