diff options
| author | Mike Bayer <mike_mp@zzzcomputing.com> | 2022-03-21 17:47:34 -0400 |
|---|---|---|
| committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2022-03-21 17:48:00 -0400 |
| commit | 714557378324f656bcf08cff37d6fad34f3ed646 (patch) | |
| tree | a1b8626be49dcf582b37c87b3755733973eff16c /examples/sharding/separate_databases.py | |
| parent | 0b11385a0517ef9f63ce73b713d4d1e335c9addd (diff) | |
| download | sqlalchemy-714557378324f656bcf08cff37d6fad34f3ed646.tar.gz | |
use begin() for settting up first PK
Change-Id: I227bbb46fbcbae1f60d3f5bb4dd2b9f41ca3dd0c
(cherry picked from commit 257f67b180cadf4ca0df0d1facf27d55c98df676)
Diffstat (limited to 'examples/sharding/separate_databases.py')
| -rw-r--r-- | examples/sharding/separate_databases.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/sharding/separate_databases.py b/examples/sharding/separate_databases.py index accbfd79b..9818656c3 100644 --- a/examples/sharding/separate_databases.py +++ b/examples/sharding/separate_databases.py @@ -56,7 +56,7 @@ ids = Table("ids", Base.metadata, Column("nextid", Integer, nullable=False)) def id_generator(ctx): # in reality, might want to use a separate transaction for this. - with db1.connect() as conn: + with db1.begin() as conn: nextid = conn.scalar(ids.select().with_for_update()) conn.execute(ids.update().values({ids.c.nextid: ids.c.nextid + 1})) return nextid |