(self, async_session)
| 611 | |
| 612 | @async_test |
| 613 | async def test_flush(self, async_session): |
| 614 | User = self.classes.User |
| 615 | |
| 616 | async with async_session.begin(): |
| 617 | u1 = User(name="u1") |
| 618 | |
| 619 | async_session.add(u1) |
| 620 | |
| 621 | conn = await async_session.connection() |
| 622 | |
| 623 | eq_(await conn.scalar(select(func.count(User.id))), 0) |
| 624 | |
| 625 | await async_session.flush() |
| 626 | |
| 627 | eq_(await conn.scalar(select(func.count(User.id))), 1) |
| 628 | |
| 629 | @async_test |
| 630 | async def test_refresh(self, async_session): |