.. rst-class:: core-header, orm-addin
So far we've covered :class:`_sql.Insert`, so that we can get some data into our database, and then spent a lot of time on :class:`_sql.Select` which handles the broad range of usage patterns used for retrieving data from the database. In this section we will cover the :class:`_sql.Update` and :class:`_sql.Delete` constructs, which are used to modify existing rows as well as delete existing rows. This section will cover these constructs from a Core-centric perspective.
ORM Readers - As was the case mentioned at :ref:`tutorial_core_insert`, the :class:`_sql.Update` and :class:`_sql.Delete` operations when used with the ORM are usually invoked internally from the :class:`_orm.Session` object as part of the :term:`unit of work` process.
However, unlike :class:`_sql.Insert`, the :class:`_sql.Update` and :class:`_sql.Delete` constructs can also be used directly with the ORM, using a pattern known as "ORM-enabled update and delete"; for this reason, familiarity with these constructs is useful for ORM use. Both styles of use are discussed in the sections :ref:`tutorial_orm_updating` and :ref:`tutorial_orm_deleting`.
The :func:`_sql.update` function generates a new instance of :class:`_sql.Update` which represents an UPDATE statement in SQL, that will update existing data in a table.
Like the :func:`_sql.insert` construct, there is a "traditional" form of :func:`_sql.update`, which emits UPDATE against a single table at a time and does not return any rows. However some backends support an UPDATE statement that may modify multiple tables at once, and the UPDATE statement also supports RETURNING such that columns contained in matched rows may be returned in the result set.
A basic UPDATE looks like:
>>> from sqlalchemy import update
>>> stmt = (
... update(user_table)
... .where(user_table.c.name == "patrick")
... .values(fullname="Patrick the Star")
... )
>>> print(stmt)
{printsql}UPDATE user_account SET fullname=:fullname WHERE user_account.name = :name_1
The :meth:`_sql.Update.values` method controls the contents of the SET elements of the UPDATE statement. This is the same method shared by the :class:`_sql.Insert` construct. Parameters can normally be passed using the column names as keyword arguments.
UPDATE supports all the major SQL forms of UPDATE, including updates against expressions, where we can make use of :class:`_schema.Column` expressions:
>>> stmt = update(user_table).values(fullname="Username: " + user_table.c.name)
>>> print(stmt)
{printsql}UPDATE user_account SET fullname=(:name_1 || user_account.name)
To support UPDATE in an "executemany" context, where many parameter sets will be invoked against the same statement, the :func:`_sql.bindparam` construct may be used to set up bound parameters; these replace the places that literal values would normally go:
>>> from sqlalchemy import bindparam
>>> stmt = (
... update(user_table)
... .where(user_table.c.name == bindparam("oldname"))
... .values(name=bindparam("newname"))
... )
>>> with engine.begin() as conn:
... conn.execute(
... stmt,
... [
... {"oldname": "jack", "newname": "ed"},
... {"oldname": "wendy", "newname": "mary"},
... {"oldname": "jim", "newname": "jake"},
... ],
... )
{execsql}BEGIN (implicit)
UPDATE user_account SET name=? WHERE user_account.name = ?
[...] [('ed', 'jack'), ('mary', 'wendy'), ('jake', 'jim')]
<sqlalchemy.engine.cursor.CursorResult object at 0x...>
COMMIT{stop}
Other techniques which may be applied to UPDATE include:
An UPDATE statement can make use of rows in other tables by using a :ref:`correlated subquery <tutorial_scalar_subquery>`. A subquery may be used anywhere a column expression might be placed:
>>> scalar_subq = (
... select(address_table.c.email_address)
... .where(address_table.c.user_id == user_table.c.id)
... .order_by(address_table.c.id)
... .limit(1)
... .scalar_subquery()
... )
>>> update_stmt = update(user_table).values(fullname=scalar_subq)
>>> print(update_stmt)
{printsql}UPDATE user_account SET fullname=(SELECT address.email_address
FROM address
WHERE address.user_id = user_account.id ORDER BY address.id
LIMIT :param_1)
Some databases such as PostgreSQL, MSSQL and MySQL support a syntax UPDATE...FROM
where additional tables may be stated directly in a special FROM clause. This
syntax will be generated implicitly when additional tables are located in the
WHERE clause of the statement:
>>> update_stmt = (
... update(user_table)
... .where(user_table.c.id == address_table.c.user_id)
... .where(address_table.c.email_address == "patrick@aol.com")
... .values(fullname="Pat")
... )
>>> print(update_stmt)
{printsql}UPDATE user_account SET fullname=:fullname FROM address
WHERE user_account.id = address.user_id AND address.email_address = :email_address_1
There is also a MySQL specific syntax that can UPDATE multiple tables. This requires we refer to :class:`_schema.Table` objects in the VALUES clause in order to refer to additional tables:
>>> update_stmt = (
... update(user_table)
... .where(user_table.c.id == address_table.c.user_id)
... .where(address_table.c.email_address == "patrick@aol.com")
... .values(
... {
... user_table.c.fullname: "Pat",
... address_table.c.email_address: "pat@aol.com",
... }
... )
... )
>>> from sqlalchemy.dialects import mysql
>>> print(update_stmt.compile(dialect=mysql.dialect()))
{printsql}UPDATE user_account, address
SET address.email_address=%s, user_account.fullname=%s
WHERE user_account.id = address.user_id AND address.email_address = %s
UPDATE...FROM can also be
combined with the :class:`_sql.Values` construct
on backends such as PostgreSQL, to create a single UPDATE statement that updates
multiple rows at once against the named form of VALUES:
>>> from sqlalchemy import Values
>>> values = Values(
... user_table.c.id,
... user_table.c.name,
... name="my_values",
... ).data([(1, "new_name"), (2, "another_name"), ("3", "name_name")])
>>> update_stmt = (
... user_table.update().values(name=values.c.name).where(user_table.c.id == values.c.id)
... )
>>> from sqlalchemy.dialects import postgresql
>>> print(update_stmt.compile(dialect=postgresql.dialect()))
{printsql}UPDATE user_account
SET name=my_values.name
FROM (VALUES
(%(param_1)s::INTEGER, %(param_2)s::VARCHAR),
(%(param_3)s::INTEGER, %(param_4)s::VARCHAR),
(%(param_5)s::INTEGER, %(param_6)s::VARCHAR)) AS my_values (id, name)
WHERE user_account.id = my_values.id
Another MySQL-only behavior is that the order of parameters in the SET clause of an UPDATE actually impacts the evaluation of each expression. For this use case, the :meth:`_sql.Update.ordered_values` method accepts a sequence of tuples so that this order may be controlled [2]:
>>> update_stmt = update(some_table).ordered_values(
... (some_table.c.y, 20), (some_table.c.x, some_table.c.y + 10)
... )
>>> print(update_stmt)
{printsql}UPDATE some_table SET y=:y, x=(some_table.y + :y_1)
| [2] | While Python dictionaries are guaranteed to be insert ordered as of Python 3.7, the :meth:`_sql.Update.ordered_values` method still provides an additional measure of clarity of intent when it is essential that the SET clause of a MySQL UPDATE statement proceed in a specific way. |
The :func:`_sql.delete` function generates a new instance of :class:`_sql.Delete` which represents a DELETE statement in SQL, that will delete rows from a table.
The :func:`_sql.delete` statement from an API perspective is very similar to that of the :func:`_sql.update` construct, traditionally returning no rows but allowing for a RETURNING variant on some database backends.
>>> from sqlalchemy import delete
>>> stmt = delete(user_table).where(user_table.c.name == "patrick")
>>> print(stmt)
{printsql}DELETE FROM user_account WHERE user_account.name = :name_1
Like :class:`_sql.Update`, :class:`_sql.Delete` supports the use of correlated
subqueries in the WHERE clause as well as backend-specific multiple table
syntaxes, such as DELETE FROM..USING on MySQL:
>>> delete_stmt = (
... delete(user_table)
... .where(user_table.c.id == address_table.c.user_id)
... .where(address_table.c.email_address == "patrick@aol.com")
... )
>>> from sqlalchemy.dialects import mysql
>>> print(delete_stmt.compile(dialect=mysql.dialect()))
{printsql}DELETE FROM user_account USING user_account, address
WHERE user_account.id = address.user_id AND address.email_address = %s
Both :class:`_sql.Update` and :class:`_sql.Delete` support the ability to return the number of rows matched after the statement proceeds, for statements that are invoked using Core :class:`_engine.Connection`, i.e. :meth:`_engine.Connection.execute`. Per the caveats mentioned below, this value is available from the :attr:`_engine.CursorResult.rowcount` attribute:
>>> with engine.begin() as conn:
... result = conn.execute(
... update(user_table)
... .values(fullname="Patrick McStar")
... .where(user_table.c.name == "patrick")
... )
... print(result.rowcount)
{execsql}BEGIN (implicit)
UPDATE user_account SET fullname=? WHERE user_account.name = ?
[...] ('Patrick McStar', 'patrick'){stop}
1
{execsql}COMMIT{stop}
Tip
The :class:`_engine.CursorResult` class is a subclass of
:class:`_engine.Result` which contains additional attributes that are
specific to the DBAPI cursor object. An instance of this subclass is
returned when a statement is invoked via the
:meth:`_engine.Connection.execute` method. When using the ORM, the
:meth:`_orm.Session.execute` method will normally not return this type
of object, unless the given query uses only Core :class:`.Table` objects
directly.
Facts about :attr:`_engine.CursorResult.rowcount`:
- The value returned is the number of rows matched by the WHERE clause of the statement. It does not matter if the row were actually modified or not.
- :attr:`_engine.CursorResult.rowcount` is not necessarily available for an UPDATE or DELETE statement that uses RETURNING, or for one that uses an :ref:`executemany <tutorial_multiple_parameters>` execution. The availability depends on the DBAPI module in use.
- In any case where the DBAPI does not determine the rowcount for some type
of statement, the returned value will be
-1. - SQLAlchemy pre-memoizes the DBAPIs
cursor.rowcountvalue before the cursor is closed, as some DBAPIs don't support accessing this attribute after the fact. In order to pre-memoizecursor.rowcountfor a statement that is not UPDATE or DELETE, such as INSERT or SELECT, the :paramref:`_engine.Connection.execution_options.preserve_rowcount` execution option may be used. - Some drivers, particularly third party dialects for non-relational databases, may not support :attr:`_engine.CursorResult.rowcount` at all. The :attr:`_engine.CursorResult.supports_sane_rowcount` cursor attribute will indicate this.
- "rowcount" is used by the ORM :term:`unit of work` process to validate that an UPDATE or DELETE statement matched the expected number of rows, and is also essential for the ORM versioning feature documented at :ref:`mapper_version_counter`.
Like the :class:`_sql.Insert` construct, :class:`_sql.Update` and :class:`_sql.Delete` also support the RETURNING clause which is added by using the :meth:`_sql.Update.returning` and :meth:`_sql.Delete.returning` methods. When these methods are used on a backend that supports RETURNING, selected columns from all rows that match the WHERE criteria of the statement will be returned in the :class:`_engine.Result` object as rows that can be iterated:
>>> update_stmt = (
... update(user_table)
... .where(user_table.c.name == "patrick")
... .values(fullname="Patrick the Star")
... .returning(user_table.c.id, user_table.c.name)
... )
>>> print(update_stmt)
{printsql}UPDATE user_account SET fullname=:fullname
WHERE user_account.name = :name_1
RETURNING user_account.id, user_account.name{stop}
>>> delete_stmt = (
... delete(user_table)
... .where(user_table.c.name == "patrick")
... .returning(user_table.c.id, user_table.c.name)
... )
>>> print(delete_stmt)
{printsql}DELETE FROM user_account
WHERE user_account.name = :name_1
RETURNING user_account.id, user_account.name{stop}
.. seealso::
API documentation for UPDATE / DELETE:
* :class:`_sql.Update`
* :class:`_sql.Delete`
ORM-enabled UPDATE and DELETE:
:ref:`orm_expression_update_delete` - in the :ref:`queryguide_toplevel`