Работа с транзакциями и DBAPI¶

Получение строк¶

Сначала мы проиллюстрируем объект Result более подробно, используя строки, которые мы вставили ранее, выполнив текстовый оператор SELECT на созданной нами таблице:

>>> with engine.connect() as conn:
...     result = conn.execute(text("SELECT x, y FROM some_table"))
...     for row in result:
...         print(f"x: {row.x}  y: {row.y}")
BEGIN (implicit)
SELECT x, y FROM some_table
[...] ()
x: 1  y: 1
x: 2  y: 4
x: 6  y: 8
x: 9  y: 10
ROLLBACK

Выше, строка «SELECT», которую мы выполнили, выбрала все строки из нашей таблицы. Возвращаемый объект называется Result и представляет собой итерируемый объект строк результата.

Result имеет множество методов для получения и преобразования строк, например, метод Result.all(), показанный ранее, который возвращает список всех объектов Row. Он также реализует интерфейс итератора Python, так что мы можем выполнять итерацию над коллекцией объектов Row напрямую.

Сами объекты Row предназначены для работы как Python named tuples. Ниже мы проиллюстрируем различные способы доступа к строкам.

• Присвоение кортежа - Это наиболее Python-идиоматический стиль, который заключается в позиционном присвоении переменных каждой строке по мере их получения:

  result = conn.execute(text("select x, y from some_table"))
  
  for x, y in result:
      # ...

• Интегральный индекс - Кортежи - это последовательности Python, поэтому доступ к обычным целым числам тоже возможен:

  result = conn.execute(text("select x, y from some_table"))
  
    for row in result:
        x = row[0]

• Имя атрибута - Поскольку это именованные кортежи Python, кортежи имеют динамические имена атрибутов, соответствующие именам каждого столбца. Эти имена обычно являются именами, которые оператор SQL присваивает столбцам в каждой строке. Хотя обычно они достаточно предсказуемы и могут управляться метками, в менее определенных случаях они могут быть подвержены специфическому для базы данных поведению:

  result = conn.execute(text("select x, y from some_table"))
  
  for row in result:
      y = row.y
  
      # illustrate use with Python f-strings
      print(f"Row: {row.x} {y}")

• Доступ к отображению - Чтобы получать строки как объекты Python отображения, что по сути является версией интерфейса Python к общему объекту dict только для чтения, Result может быть преобразован в объект MappingResult с помощью модификатора Result.mappings(); это объект результата, который выдает словареподобные объекты RowMapping, а не объекты Row:

  result = conn.execute(text("select x, y from some_table"))
  
  for dict_row in result.mappings():
      x = dict_row["x"]
      y = dict_row["y"]

Параметры отправки¶

Операторы SQL обычно сопровождаются данными, которые должны быть переданы вместе с самим оператором, как мы видели ранее в примере INSERT. Поэтому метод Connection.execute() также принимает параметры, которые обозначаются как bound parameters. В качестве элементарного примера можно привести случай, когда мы хотим ограничить наш оператор SELECT только теми строками, которые соответствуют определенному критерию, например, строками, в которых значение «y» больше определенного значения, передаваемого в функцию.

Чтобы добиться этого, чтобы SQL-оператор оставался фиксированным, а драйвер мог правильно санировать значение, мы добавляем критерий WHERE к нашему оператору, который называет новый параметр «y»; конструкция text() принимает их, используя формат двоеточия «:y». Фактическое значение для «:y» затем передается в качестве второго аргумента в Connection.execute() в виде словаря:

>>> with engine.connect() as conn:
...     result = conn.execute(text("SELECT x, y FROM some_table WHERE y > :y"), {"y": 2})
...     for row in result:
...         print(f"x: {row.x}  y: {row.y}")
BEGIN (implicit)
SELECT x, y FROM some_table WHERE y > ?
[...] (2,)
x: 2  y: 4
x: 6  y: 8
x: 9  y: 10
ROLLBACK

В протоколируемом выводе SQL видно, что связанный параметр :y был преобразован в знак вопроса при отправке в базу данных SQLite. Это происходит потому, что драйвер базы данных SQLite использует формат под названием «qmark parameter style», который является одним из шести различных форматов, разрешенных спецификацией DBAPI. SQLAlchemy абстрагирует эти форматы только в один, который является «именованным» форматом с использованием двоеточия.