Соединения SQLAlchemy

Question

def get_engine(): 
    engine = create_engine('mysql+mysqlconnector://...my_conn_string...', echo=True) 
    return engine 

def generic_execute(sql): 
    db = get_engine() 
    connection = db.connect() 
    connection.execute(sql) 

Вышеприведенный код выполняет запрос правильно, но кажется, что он бесконечно вешает.

Как правильно «закрыть» или «убить» это соединение? Большое спасибо!

Answer 1

Как вы сказали, соединение должно быть закрыто, как указано в documentation. Таким образом, после того как вы сделали выполнения SQL запроса вам необходимо позвонить:

connection.close() 

Кроме того, если вы сделали с двигателем db вы можете позвонить db.dispose() очистить все.