Здравствуйте. Использую err := db.QueryRow(...).Scan(...) для INSERTов в базу. Но

Question

Здравствуйте. Использую err := db.QueryRow(...).Scan(...) для INSERTов в базу. Но

не понимаю как мгновенно после инсертов закрыть коннекшн? У меня коннекшены утекают мгновенно когда многопоточно пихаю в базу данные.

#backend #go #programming #russian

0

21.11.2020

8 ответов

8 просмотров

🅺🆁🅴🅻 🅰🅸🅵🅾🅻🅸🅽 Автор вопроса

Anton
На каждый запрос создаешь новое соединение?

Ну хотелось бы в данном случае. Иначе у меня быстро запросы плодятся

0

21.11.2020

Anton

🅺🆁🅴🅻 🅰🅸🅵🅾🅻🅸🅽
Ну хотелось бы в данном случае. Иначе у меня быстр...

db.Close() не пробовал? Закроет соединение, если запросов нет. Но, по моему, с логикой в проекте что то не так. если надо на каждый запрос открывать соединение.

0

22.11.2020

🅺🆁🅴🅻 🅰🅸🅵🅾🅻🅸🅽 Автор вопроса

Anton
db.Close() не пробовал? Закроет соединение, если з...

Знаете, покумекал и решил что да, с логикой что-то не то. На свежую голову перепишу.

0

22.11.2020

Anton

🅺🆁🅴🅻 🅰🅸🅵🅾🅻🅸🅽
Знаете, покумекал и решил что да, с логикой что-то...

Если нет возможности подряд пулять кучу инсертов, можно их выполнить в транзакции, там все быстро выполнится и экономно по ресурсам для бд

0

22.11.2020

🅺🆁🅴🅻 🅰🅸🅵🅾🅻🅸🅽 Автор вопроса

Anton
Если нет возможности подряд пулять кучу инсертов, ...

Дело в том что выполняю эти запросы в транзакции. Но почему-то соединения все равно плодятся. Если в pgbouncer выбираю session, то все норм. Если transaction то соединения не закрываются и висят.

0

22.11.2020

Алексей Долгов

🅺🆁🅴🅻 🅰🅸🅵🅾🅻🅸🅽
Дело в том что выполняю эти запросы в транзакции. ...

в pgbouncer в режиме transaction pooling две транзакции могут быть выполнены в разных соединениях, но id транзакции действителен только в рамках одного соединения. если session то каждой сессии выдается одно соединение и закрепляется за ней на всё время жизни. таким образом все транзакции будут выполнены в рамках одного соединения

0

22.11.2020

🅺🆁🅴🅻 🅰🅸🅵🅾🅻🅸🅽 Автор вопроса

Алексей Долгов
в pgbouncer в режиме transaction pooling две транз...

Спасибо за разъяснения. Тут дело в кривости моих рук, поэтому проблема была только в том что я сам же в хендлере в цикле плодил транзакции, да еще и в несколько потоков. Логику поменял, теперь всё отлично.

0

22.11.2020

Anton · Accepted Answer

Anton

На каждый запрос создаешь новое соединение?

0

21.11.2020

170 похожих чатов

Здравствуйте. Использую err := db.QueryRow(...).Scan(...) для INSERTов в базу. Но

8 ответов

Похожие вопросы