Skip to content

Commit bc689db

Browse files
committed
Add refresh call after create and update to make sure eager relationships are loaded
1 parent 8be0f68 commit bc689db

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

fastapi_users_db_sqlalchemy/__init__.py

+2
Original file line numberDiff line numberDiff line change
@@ -142,13 +142,15 @@ async def create(self, create_dict: Dict[str, Any]) -> UP:
142142
user = self.user_table(**create_dict)
143143
self.session.add(user)
144144
await self.session.commit()
145+
await self.session.refresh(user)
145146
return user
146147

147148
async def update(self, user: UP, update_dict: Dict[str, Any]) -> UP:
148149
for key, value in update_dict.items():
149150
setattr(user, key, value)
150151
self.session.add(user)
151152
await self.session.commit()
153+
await self.session.refresh(user)
152154
return user
153155

154156
async def delete(self, user: UP) -> None:

fastapi_users_db_sqlalchemy/access_token.py

+2
Original file line numberDiff line numberDiff line change
@@ -73,13 +73,15 @@ async def create(self, create_dict: Dict[str, Any]) -> AP:
7373
access_token = self.access_token_table(**create_dict)
7474
self.session.add(access_token)
7575
await self.session.commit()
76+
await self.session.refresh(access_token)
7677
return access_token
7778

7879
async def update(self, access_token: AP, update_dict: Dict[str, Any]) -> AP:
7980
for key, value in update_dict.items():
8081
setattr(access_token, key, value)
8182
self.session.add(access_token)
8283
await self.session.commit()
84+
await self.session.refresh(access_token)
8385
return access_token
8486

8587
async def delete(self, access_token: AP) -> None:

0 commit comments

Comments
 (0)