Connect: примеры (PYTHON)

Короткие примеры использования

Создание базы данных в памяти:

import sqlite3
conn = sqlite3.connect(':memory:')
print(type(conn))

<class 'sqlite3.Connection'>

Подключение к файлу с установленным временем ожидания:

conn = sqlite3.connect('my_db.db', timeout=10.0)
print(conn.timeout)

10.0

Использование URI для подключения с режимом 'чтение-запись':

conn = sqlite3.connect('file:my_db.db?mode=rw', uri=True)
print(conn)

<sqlite3.Connection object at 0x...>

Отключение проверки на использование в одном потоке:

conn = sqlite3.connect('my_db.db', check_same_thread=False)
# Теперь соединение можно передавать между потоками (с осторожностью)

Похожие функции в Python

В экосистеме Python существуют другие функции и методы для установки соединений с базами данных.

• psycopg2.connect() и mysql.connector.connect(): Функции для подключения к PostgreSQL и MySQL соответственно. Они имеют специфичные для своих СУБД параметры (хост, порт, пользователь, пароль). Используются при работе с соответствующими серверами баз данных.
• SQLAlchemy create_engine(): Функция ORM и инструментария SQLAlchemy создает объект движка, который управляет пулом соединений. Предпочтительна в крупных приложениях для абстракции от конкретной СУБД и управления ресурсами соединений.

Выбор зависит от типа базы данных и архитектуры приложения. sqlite3.connect оптимальна для простых встроенных или прототипных решений с SQLite.

Альтернативы в других языках

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

PHP (PDO):

// Подключение к SQLite
$conn = new PDO('sqlite:/path/to/database.db');
// Подключение к MySQL
$conn = new PDO('mysql:host=localhost;dbname=test', $user, $pass);

JavaScript (Node.js, библиотека sqlite3):

const sqlite3 = require('sqlite3').verbose();
let db = new sqlite3.Database(':memory:', (err) => {
  if (err) console.error(err.message);
  console.log('Connected.');
});

Java (JDBC):

// Для SQLite требуется драйвер
Connection conn = DriverManager.getConnection("jdbc:sqlite:sample.db");
// Для MySQL
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/test", "user", "password");

C# (System.Data.SQLite):

using (var conn = new SQLiteConnection("Data Source=database.db"))
{
    conn.Open();
    // Работа с БД
}

Основное отличие от Python - часто необходимость явно указывать драйвер или провайдер данных, а также более сложная строка подключения для сетевых СУБД.

Типичные ошибки

Работа с функцией connect может приводить к ошибкам, связанным с путями файлов, многопоточностью и закрытием соединений.

Ошибка доступа к файлу:

import sqlite3
try:
    conn = sqlite3.connect('/readonly/path/db.db')
except sqlite3.OperationalError as e:
    print(f"Ошибка: {e}")

Ошибка: unable to open database file

Использование соединения из другого потока (при check_same_thread=True):

import sqlite3
import threading

def worker(conn):
    try:
        conn.execute("SELECT 1")
    except sqlite3.ProgrammingError as e:
        print(f"Ошибка: {e}")

conn = sqlite3.connect(':memory:')
th = threading.Thread(target=worker, args=(conn,))
th.start()
th.join()

Ошибка: SQLite objects created in a thread can only be used in that same thread.

Неявное закрытие соединения при использовании контекстного менеджера:

import sqlite3
with sqlite3.connect(':memory:') as conn:
    cursor = conn.cursor()
    cursor.execute("CREATE TABLE test (id INTEGER)")
# Соединение автоматически закроется здесь, попытка использовать его вызовет ошибку.
try:
    conn.execute("SELECT 1")
except sqlite3.ProgrammingError as e:
    print(f"Ошибка: {e}")

Ошибка: Cannot operate on a closed database.

Изменения в последних версиях

В модуле sqlite3 изменения, затрагивающие функцию connect, были незначительными.

• Начиная с Python 3.7, параметр isolation_level по умолчанию стал None (автокоммит) при использовании контекстного менеджера с соединением.
• В Python 3.10 были улучшены сообщения об ошибках для некоторых операций с базой данных.
• В Python 3.13 добавлена поддержка обработчиков для адаптации типов Python в SQLite, что влияет на параметр detect_types.

Значительных изменений в сигнатуре функции connect в последних версиях не происходило.

Расширенные примеры использования

Пример с включенным преобразованием типов для распознавания дат:

import sqlite3
import datetime

def adapt_date(date_obj):
    return date_obj.isoformat()

def convert_date(bytes_val):
    return datetime.date.fromisoformat(bytes_val.decode())

sqlite3.register_adapter(datetime.date, adapt_date)
sqlite3.register_converter("DATE", convert_date)

conn = sqlite3.connect(':memory:', detect_types=sqlite3.PARSE_DECLTYPES)
cursor = conn.cursor()
cursor.execute("CREATE TABLE events (id INTEGER, day DATE)")

today = datetime.date.today()
cursor.execute("INSERT INTO events VALUES (?, ?)", (1, today))
conn.commit()

cursor.execute("SELECT day FROM events WHERE id=1")
row = cursor.fetchone()
print(f"Извлеченная дата: {row[0]}, тип: {type(row[0])}")

Извлеченная дата: 2023-10-26, тип: <class 'datetime.date'>

Создание нескольких соединений для работы с разными базами и ATTACH:

import sqlite3

main_conn = sqlite3.connect('main.db')
main_conn.execute("CREATE TABLE IF NOT EXISTS main_tbl (x INTEGER)")

aux_conn = sqlite3.connect('aux.db')
aux_conn.execute("CREATE TABLE IF NOT EXISTS aux_tbl (y TEXT)")
aux_conn.close()

# Присоединение второй базы к первому соединению
main_conn.execute("ATTACH DATABASE 'aux.db' AS aux_schema")
cursor = main_conn.cursor()
cursor.execute("SELECT name FROM aux_schema.sqlite_master WHERE type='table'")
print(cursor.fetchall())
main_conn.close()

[('aux_tbl',)]

Использование пользовательской фабрики для создания соединения с дополнительной логикой:

import sqlite3

class LoggingConnection(sqlite3.Connection):
    def execute(self, sql, parameters=()):
        print(f"Выполняется: {sql} с параметрами {parameters}")
        return super().execute(sql, parameters)

# Передача фабрики в connect
conn = sqlite3.connect(':memory:', factory=LoggingConnection)
conn.execute("CREATE TABLE test (a, b)")
conn.execute("INSERT INTO test VALUES (?, ?)", (10, 'text'))

Выполняется: CREATE TABLE test (a, b) с параметрами ()
Выполняется: INSERT INTO test VALUES (?, ?) с параметрами (10, 'text')