File tree 5 files changed +8
-9
lines changed
5 files changed +8
-9
lines changed Original file line number Diff line number Diff line change @@ -184,7 +184,7 @@ app = FastAPI()
184
184
# Database
185
185
sync_db = Database.create(" sqlite:///amisadmin.db?check_same_thread=False" )
186
186
187
- app.add_middleware(BaseHTTPMiddleware, dispatch = sync_db.asgi_dispatch )
187
+ app.add_middleware(sync_db.asgi_middleware )
188
188
189
189
190
190
@app.get (" /user/{id} " )
@@ -195,7 +195,7 @@ def get_user(id: int):
195
195
# AsyncDatabase
196
196
async_db = AsyncDatabase.create(" sqlite+aiosqlite:///amisadmin.db?check_same_thread=False" )
197
197
198
- app.add_middleware(BaseHTTPMiddleware, dispatch = async_db.asgi_dispatch )
198
+ app.add_middleware(async_db.asgi_middleware )
199
199
200
200
201
201
@app.get (" /user/{id} " )
Original file line number Diff line number Diff line change @@ -183,7 +183,7 @@ app = FastAPI()
183
183
# Database
184
184
sync_db = Database.create(" sqlite:///amisadmin.db?check_same_thread=False" )
185
185
186
- app.add_middleware(BaseHTTPMiddleware, dispatch = sync_db.asgi_dispatch )
186
+ app.add_middleware(sync_db.asgi_middleware )
187
187
188
188
189
189
@app.get (" /user/{id} " )
@@ -194,7 +194,7 @@ def get_user(id: int):
194
194
# AsyncDatabase
195
195
async_db = AsyncDatabase.create(" sqlite+aiosqlite:///amisadmin.db?check_same_thread=False" )
196
196
197
- app.add_middleware(BaseHTTPMiddleware, dispatch = async_db.asgi_dispatch )
197
+ app.add_middleware(async_db.asgi_middleware )
198
198
199
199
200
200
@app.get (" /user/{id} " )
Original file line number Diff line number Diff line change @@ -184,7 +184,7 @@ app = FastAPI()
184
184
# Database
185
185
sync_db = Database.create(" sqlite:///amisadmin.db?check_same_thread=False" )
186
186
187
- app.add_middleware(BaseHTTPMiddleware, dispatch = sync_db.asgi_dispatch )
187
+ app.add_middleware(sync_db.asgi_middleware )
188
188
189
189
190
190
@app.get (" /user/{id} " )
@@ -195,7 +195,7 @@ def get_user(id: int):
195
195
# AsyncDatabase
196
196
async_db = AsyncDatabase.create(" sqlite+aiosqlite:///amisadmin.db?check_same_thread=False" )
197
197
198
- app.add_middleware(BaseHTTPMiddleware, dispatch = async_db.asgi_dispatch )
198
+ app.add_middleware(async_db.asgi_middleware )
199
199
200
200
201
201
@app.get (" /user/{id} " )
Original file line number Diff line number Diff line change @@ -88,7 +88,7 @@ def session(self) -> AsyncSession:
88
88
Example:
89
89
```Python
90
90
app = FastAPI()
91
- app.add_middleware(BaseHTTPMiddleware, dispatch= db.asgi_dispatch )
91
+ app.add_middleware(db.asgi_middleware )
92
92
93
93
@app.get('/get_user')
94
94
async def get_user(id:int):
Original file line number Diff line number Diff line change 4
4
from sqlalchemy import select
5
5
from sqlalchemy .ext .asyncio import AsyncSession
6
6
from sqlalchemy .orm import Session
7
- from starlette .middleware .base import BaseHTTPMiddleware
8
7
from starlette .testclient import TestClient
9
8
10
9
from tests .conftest import User , async_db , sync_db
@@ -26,7 +25,7 @@ def test_sync_db_in_fastapi():
26
25
app = FastAPI ()
27
26
sub_app = FastAPI ()
28
27
app .mount ("/sub" , sub_app )
29
- app .add_middleware (BaseHTTPMiddleware , dispatch = sync_db .asgi_dispatch )
28
+ app .add_middleware (sync_db .asgi_middleware )
30
29
client = TestClient (app )
31
30
32
31
@app .get ("/users" )
You can’t perform that action at this time.
0 commit comments