24 lines
692 B
Python
24 lines
692 B
Python
from typing import Sequence
|
|
|
|
from sqlalchemy import select
|
|
from sqlalchemy.ext.asyncio import AsyncSession
|
|
|
|
from models import IspConnection
|
|
from schemas.isp_connections import IspConnectionCreate
|
|
|
|
|
|
async def get_all_isp_connection(session: AsyncSession) -> Sequence[IspConnection]:
|
|
stmt = select(IspConnection).order_by(IspConnection.id)
|
|
result = await session.scalars(stmt)
|
|
return result.all()
|
|
|
|
|
|
async def create_isp_connection(
|
|
session: AsyncSession, isp_connection_scheme: IspConnectionCreate
|
|
) -> IspConnection:
|
|
isp_connection = IspConnection(**isp_connection_scheme.model_dump())
|
|
|
|
session.add(isp_connection)
|
|
await session.commit()
|
|
return isp_connection
|