Подключение к базе данных Python Закрыть

Соединения имеют метод close, как указано в PEP-249 ( Спецификация API базы данных Python v2.0):

import pyodbc
conn = pyodbc.connect('DRIVER=MySQL ODBC 5.1 driver;SERVER=localhost;DATABASE=spt;UID=who;PWD=testest') 

csr = conn.cursor()  
csr.close()
conn.close()     #<--- Close the connection

Поскольку pyodbc соединение и курсор оба являются менеджерами контекста, в настоящее время было бы удобнее (и предпочтительнее) записать это как:

import pyodbc
conn = pyodbc.connect('DRIVER=MySQL ODBC 5.1 driver;SERVER=localhost;DATABASE=spt;UID=who;PWD=testest') 
with conn:
    crs = conn.cursor()
    do_stuff
    # conn.commit() will automatically be called when Python leaves the outer `with` statement
    # Neither crs.close() nor conn.close() will be called upon leaving the `with` statement!! 

Подробнее см. https://github.com/mkleehammer/pyodbc/issues/43. почему conn.close() не вызывается.

Обратите внимание, что в отличие от исходного кода, это приводит к вызову conn.commit(). Используйте внешний оператор with, чтобы контролировать, когда вы хотите, чтобы commit вызывался.

Также обратите внимание, что независимо от того, используете ли вы операторы with, согласно документам ,

Соединения автоматически закрываются при удалении (как правило, когда они выходят за рамки), поэтому обычно вам не нужно вызывать [conn.close()], но вы можете явно закрыть соединение, если хотите.

и аналогично для курсоров (выделено мной):

Курсоры автоматически закрываются при удалении (обычно когда они выходят за пределы области видимости), поэтому вызов [csr.close()] обычно не требуется.

Вы можете обернуть все соединение в менеджере контекста, как показано ниже:

from contextlib import contextmanager
import pyodbc
import sys

@contextmanager
def open_db_connection(connection_string, commit=False):
    connection = pyodbc.connect(connection_string)
    cursor = connection.cursor()
    try:
        yield cursor
    except pyodbc.DatabaseError as err:
        error, = err.args
        sys.stderr.write(error.message)
        cursor.execute("ROLLBACK")
        raise err
    else:
        if commit:
            cursor.execute("COMMIT")
        else:
            cursor.execute("ROLLBACK")
    finally:
        connection.close()

Затем сделайте что-то подобное там, где вам нужно подключение к базе данных:

with open_db_connection("...") as cursor:
    # Your code here

Соединение закроется, когда вы покинете блок with. Это также приведет к откату транзакции, если произойдет исключение или если вы не открыли блок с помощью with open_db_connection("...", commit=True).

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

import pyodbc
pyodbc.pooling = False
conn = pyodbc.connect('DRIVER=MySQL ODBC 5.1 driver;SERVER=localhost;DATABASE=spt;UID=who;PWD=testest') 

csr = conn.cursor()  
csr.close()
del csr

Согласно документации pyodbc, подключения к серверу SQL по умолчанию не закрываются. Некоторые драйверы баз данных не закрывают соединения при вызове close(), чтобы сократить число обращений к серверу.

Чтобы закрыть соединение при вызове close(), вы должны установить для пула значение False:

import pyodbc

pyodbc.pooling = False

Вы можете определить класс БД, как показано ниже. Кроме того, как предложил andrewf, используйте диспетчер контекста для доступа к курсору. Я бы определил его как функцию-член. Таким образом, он сохраняет соединение открытым для нескольких транзакций из кода приложения и избавляет от ненужных повторных подключений к серверу.

import pyodbc

class MS_DB():
    """ Collection of helper methods to query the MS SQL Server database.
    """

    def __init__(self, username, password, host, port=1433, initial_db='dev_db'):
        self.username = username
        self._password = password
        self.host = host
        self.port = str(port)
        self.db = initial_db
        conn_str = 'DRIVER=DRIVER=ODBC Driver 13 for SQL Server;SERVER='+ \
                    self.host + ';PORT='+ self.port +';DATABASE='+ \
                    self.db +';UID='+ self.username +';PWD='+ \ 
                    self._password +';'
        print('Connected to DB:', conn_str)
        self._connection = pyodbc.connect(conn_str)        
        pyodbc.pooling = False

    def __repr__(self):
        return f"MS-SQLServer('{self.username}', <password hidden>, '{self.host}', '{self.port}', '{self.db}')"

    def __str__(self):
        return f"MS-SQLServer Module for STP on {self.host}"

    def __del__(self):
        self._connection.close()
        print("Connection closed.")

    @contextmanager
    def cursor(self, commit: bool = False):
        """
        A context manager style of using a DB cursor for database operations. 
        This function should be used for any database queries or operations that 
        need to be done. 

        :param commit:
        A boolean value that says whether to commit any database changes to the database. Defaults to False.
        :type commit: bool
        """
        cursor = self._connection.cursor()
        try:
            yield cursor
        except pyodbc.DatabaseError as err:
            print("DatabaseError {} ".format(err))
            cursor.rollback()
            raise err
        else:
            if commit:
                cursor.commit()
        finally:
            cursor.close()

ms_db = MS_DB(username='my_user', password='my_secret', host='hostname')
with ms_db.cursor() as cursor:
        cursor.execute("SELECT @@version;")
        print(cur.fetchall())

Наиболее распространенный способ обработки соединений, если язык не имеет самозакрывающейся конструкции, такой как Using в .NET, тогда вы должны использовать попытку -> finally, чтобы закрыть объекты. Возможно, у pyodbc есть какая-то форма автоматического закрытия, но вот код, который я делаю на всякий случай:

conn = cursor = None
try:
    conn = pyodbc.connect('DRIVER=MySQL ODBC 5.1 driver;SERVER=localhost;DATABASE=spt;UID=who;PWD=testest') 

    cursor = conn.cursor()  

    # ... do stuff ...

finally:
    try: cursor.close()
    except: pass
    try: conn.close()
    except: pass