1

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

Сделал себе контекстный хелпер поверх aiomysql для упрощения работы с бд (хочу держать все запросы в руках, без орм)

Используется так:

async with DbHelper() as db:
    query = 'SELECT * FROM test_db WHERE test_var1 = %s AND test_var2'
    data = test_var1, test_var2
    db.fetchone(query, data)

Так вот, при проверке юнит-тестами aiomysql ругается на незакрытое соединение:

/Library/Frameworks/Python.framework/Versions/3.6/lib/python3.6/site-packages/aiomysql/connection.py:801: ResourceWarning: Unclosed connection ResourceWarning)

При __aexit__ я проверяю, открыто ли оно и закрываю его.

Что ещё этой шайтан-машине надо - не пойму.

Код хелпера тут: https://github.com/Olegt0rr/DbHelper/blob/master/aiodb.py

Код юниттеста тут: https://gist.github.com/Olegt0rr/4dbfc2f933d027d3ccad875482d954bf

Ради интереса попробовал тетировать тот же самый код без asyncio (pymysql + unittest) - предупреждений нет.

5
  • @andreymal, в коде разве не видно, что я проверяю не только курсор, но и соединение? (строка 139)
    – Oleg
    30 окт 2017 в 13:08
  • Моя невнимательность, проглядел
    – andreymal
    30 окт 2017 в 13:23
  • Хм, а вы в методе connect не прерываете цикл while после успешного подключения что ли? Или я опять что-то проглядел?)
    – andreymal
    30 окт 2017 в 13:39
  • @andreymal, вероятно в этом и есть проблема. Чуть позже попробую исправить, напишу о результатах. Спасибо!
    – Oleg
    31 окт 2017 в 8:50
  • @andreymal, да, дописал break в блок else - лишние соединения перестали создаваться! Благодарю!
    – Oleg
    31 окт 2017 в 10:51

1 ответ 1

1

@andreymal нашёл ошибку в методе, инициирующем соединение.

Т.к. использовался цикл while, необходимо было прервать цикл в случае успешного создания соединения. В блок try else была добавлена команда break. Проблема больше не воспроизводится.

Спасибо!

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.