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:47:34 -0400 |
| commit | 257f67b180cadf4ca0df0d1facf27d55c98df676 (patch) | |
| tree | 21f0ebd715c25dc08f5337c6ddc12d8416a10b8a /examples/sharding/separate_tables.py | |
| parent | 2a1afd32b82e103961f305b478d4cc6f6244cd00 (diff) | |
| download | sqlalchemy-257f67b180cadf4ca0df0d1facf27d55c98df676.tar.gz | |
use begin() for settting up first PK
Change-Id: I227bbb46fbcbae1f60d3f5bb4dd2b9f41ca3dd0c
Diffstat (limited to 'examples/sharding/separate_tables.py')
| -rw-r--r-- | examples/sharding/separate_tables.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/sharding/separate_tables.py b/examples/sharding/separate_tables.py index 4314e2233..0f6e2ffd8 100644 --- a/examples/sharding/separate_tables.py +++ b/examples/sharding/separate_tables.py @@ -70,7 +70,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 engine.connect() as conn: + with engine.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 |