Fix: joinedload_all was depreciated in sqlalchemy 1.2 and removed in 1.4

This commit is contained in:
Amritanshu Agrawal 2021-04-03 07:54:00 +05:30
parent ef826d30c7
commit f1be068d0b
8 changed files with 16 additions and 16 deletions

View File

@ -9,7 +9,7 @@ import brewman.schemas.account as schemas
from fastapi import APIRouter, Depends, HTTPException, Security, status from fastapi import APIRouter, Depends, HTTPException, Security, status
from sqlalchemy import func from sqlalchemy import func
from sqlalchemy.exc import SQLAlchemyError from sqlalchemy.exc import SQLAlchemyError
from sqlalchemy.orm import Session, joinedload_all from sqlalchemy.orm import Session, joinedload
from ..core.security import get_current_active_user as get_user from ..core.security import get_current_active_user as get_user
from ..db.session import SessionLocal from ..db.session import SessionLocal
@ -220,7 +220,7 @@ def delete_with_data(account: Account, db: Session) -> None:
suspense_account = db.query(Account).filter(Account.id == Account.suspense()).first() suspense_account = db.query(Account).filter(Account.id == Account.suspense()).first()
query: List[Voucher] = ( query: List[Voucher] = (
db.query(Voucher) db.query(Voucher)
.options(joinedload_all(Voucher.journals, Journal.account, innerjoin=True)) .options(joinedload(Voucher.journals, innerjoin=True).joinedload(Journal.account, innerjoin=True))
.filter(Voucher.journals.any(Journal.account_id == account.id)) .filter(Voucher.journals.any(Journal.account_id == account.id))
.all() .all()
) )

View File

@ -8,7 +8,7 @@ import brewman.schemas.employee as schemas
from fastapi import APIRouter, Depends, HTTPException, Security, status from fastapi import APIRouter, Depends, HTTPException, Security, status
from sqlalchemy import desc from sqlalchemy import desc
from sqlalchemy.exc import SQLAlchemyError from sqlalchemy.exc import SQLAlchemyError
from sqlalchemy.orm import Session, joinedload_all from sqlalchemy.orm import Session, joinedload
from ..core.security import get_current_active_user as get_user from ..core.security import get_current_active_user as get_user
from ..db.session import SessionLocal from ..db.session import SessionLocal
@ -215,7 +215,7 @@ def delete_with_data(employee: Employee, db: Session):
suspense_account = db.query(Account).filter(Account.id == Account.suspense()).first() suspense_account = db.query(Account).filter(Account.id == Account.suspense()).first()
query = ( query = (
db.query(Voucher) db.query(Voucher)
.options(joinedload_all(Voucher.journals, Journal.account, innerjoin=True)) .options(joinedload(Voucher.journals, innerjoin=True).joinedload(Journal.account, innerjoin=True))
.filter(Voucher.journals.any(Journal.account_id == employee.id)) .filter(Voucher.journals.any(Journal.account_id == employee.id))
.all() .all()
) )

View File

@ -7,7 +7,7 @@ import brewman.schemas.product as schemas
from fastapi import APIRouter, Depends, HTTPException, Security, status from fastapi import APIRouter, Depends, HTTPException, Security, status
from sqlalchemy import desc from sqlalchemy import desc
from sqlalchemy.exc import SQLAlchemyError from sqlalchemy.exc import SQLAlchemyError
from sqlalchemy.orm import Session, joinedload_all from sqlalchemy.orm import Session, joinedload
from ..core.security import get_current_active_user as get_user from ..core.security import get_current_active_user as get_user
from ..db.session import SessionLocal from ..db.session import SessionLocal
@ -231,7 +231,7 @@ def delete_with_data(product: Product, db: Session) -> None:
suspense_batch = db.query(Batch).filter(Batch.id == Batch.suspense()).first() suspense_batch = db.query(Batch).filter(Batch.id == Batch.suspense()).first()
query = ( query = (
db.query(Voucher) db.query(Voucher)
.options(joinedload_all(Voucher.inventories, Inventory.product, innerjoin=True)) .options(joinedload(Voucher.inventories, innerjoin=True).joinedload(Inventory.product, innerjoin=True))
.filter(Voucher.inventories.any(Inventory.product_id == product.id)) .filter(Voucher.inventories.any(Inventory.product_id == product.id))
.all() .all()
) )

View File

@ -6,7 +6,7 @@ from typing import List
from fastapi import APIRouter, Depends, Security from fastapi import APIRouter, Depends, Security
from sqlalchemy import and_, distinct, func from sqlalchemy import and_, distinct, func
from sqlalchemy.orm import Session, aliased, joinedload_all from sqlalchemy.orm import Session, aliased, joinedload
from ..core.security import get_current_active_user as get_user from ..core.security import get_current_active_user as get_user
from ..db.session import SessionLocal from ..db.session import SessionLocal
@ -73,7 +73,7 @@ def save_starred(date_: date, db: Session):
vouchers = [] vouchers = []
query = ( query = (
db.query(Voucher) db.query(Voucher)
.options(joinedload_all(Voucher.journals, Journal.account, innerjoin=True)) .options(joinedload(Voucher.journals, innerjoin=True).joinedload(Journal.account, innerjoin=True))
.filter(Voucher.date < date_) .filter(Voucher.date < date_)
.filter(Voucher.journals.any(Journal.account_id.in_(accounts))) .filter(Voucher.journals.any(Journal.account_id.in_(accounts)))
.all() .all()

View File

@ -4,7 +4,7 @@ from typing import List
import brewman.schemas.daybook as schemas import brewman.schemas.daybook as schemas
from fastapi import APIRouter, Depends, Request, Security from fastapi import APIRouter, Depends, Request, Security
from sqlalchemy.orm import Session, joinedload_all from sqlalchemy.orm import Session, joinedload
from ...core.security import get_current_active_user as get_user from ...core.security import get_current_active_user as get_user
from ...core.session import get_finish_date, get_start_date, set_period from ...core.session import get_finish_date, get_start_date, set_period
@ -59,7 +59,7 @@ def build_report(start_date: date, finish_date: date, db: Session) -> List[schem
query = ( query = (
db.query(Voucher) db.query(Voucher)
.options(joinedload_all(Voucher.journals, Journal.account, innerjoin=True)) .options(joinedload(Voucher.journals, innerjoin=True).joinedload(Journal.account, innerjoin=True))
.filter(Voucher.date >= start_date) .filter(Voucher.date >= start_date)
.filter(Voucher.date <= finish_date) .filter(Voucher.date <= finish_date)
.filter(Voucher.type != VoucherType.by_name("Issue").id) .filter(Voucher.type != VoucherType.by_name("Issue").id)

View File

@ -6,7 +6,7 @@ from typing import List
import brewman.schemas.ledger as schemas import brewman.schemas.ledger as schemas
from fastapi import APIRouter, Depends, Request, Security from fastapi import APIRouter, Depends, Request, Security
from sqlalchemy.orm import Session, joinedload_all from sqlalchemy.orm import Session, joinedload
from sqlalchemy.sql.expression import func from sqlalchemy.sql.expression import func
from ...core.security import get_current_active_user as get_user from ...core.security import get_current_active_user as get_user
@ -73,7 +73,7 @@ def build_report(account_id: uuid.UUID, start_date: str, finish_date: str, db: S
query = ( query = (
db.query(Voucher) db.query(Voucher)
.options(joinedload_all(Voucher.journals, Journal.account, innerjoin=True)) .options(joinedload(Voucher.journals, innerjoin=True).joinedload(Journal.account, innerjoin=True))
.filter(Voucher.journals.any(Journal.account_id == account_id)) .filter(Voucher.journals.any(Journal.account_id == account_id))
.filter(Voucher.date >= datetime.datetime.strptime(start_date, "%d-%b-%Y")) .filter(Voucher.date >= datetime.datetime.strptime(start_date, "%d-%b-%Y"))
.filter(Voucher.date <= datetime.datetime.strptime(finish_date, "%d-%b-%Y")) .filter(Voucher.date <= datetime.datetime.strptime(finish_date, "%d-%b-%Y"))

View File

@ -2,7 +2,7 @@ import datetime
import uuid import uuid
from fastapi import APIRouter, Depends, Request, Security from fastapi import APIRouter, Depends, Request, Security
from sqlalchemy.orm import Session, joinedload_all from sqlalchemy.orm import Session, joinedload
from sqlalchemy.sql.expression import and_, func, or_ from sqlalchemy.sql.expression import and_, func, or_
from ...core.security import get_current_active_user as get_user from ...core.security import get_current_active_user as get_user
@ -68,7 +68,7 @@ def build_report(account_id, start_date, finish_date, db):
query = ( query = (
db.query(Voucher) db.query(Voucher)
.options(joinedload_all(Voucher.journals, Journal.account, innerjoin=True)) .options(joinedload(Voucher.journals, innerjoin=True).joinedload(Journal.account, innerjoin=True))
.filter(Voucher.journals.any(Journal.account_id == account_id)) .filter(Voucher.journals.any(Journal.account_id == account_id))
.filter( .filter(
or_( or_(

View File

@ -3,7 +3,7 @@ from typing import List
import brewman.schemas.unposted as schemas import brewman.schemas.unposted as schemas
from fastapi import APIRouter, Depends, Request, Security from fastapi import APIRouter, Depends, Request, Security
from sqlalchemy.orm import Session, joinedload_all from sqlalchemy.orm import Session, joinedload
from ...core.security import get_current_active_user as get_user from ...core.security import get_current_active_user as get_user
from ...db.session import SessionLocal from ...db.session import SessionLocal
@ -39,7 +39,7 @@ def build_report(db: Session) -> List[schemas.Unposted]:
query = ( query = (
db.query(Voucher) db.query(Voucher)
.options(joinedload_all(Voucher.journals, Journal.account, innerjoin=True)) .options(joinedload(Voucher.journals, innerjoin=True).joinedload(Journal.account, innerjoin=True))
.filter(Voucher.posted == False) # noqa: E712 .filter(Voucher.posted == False) # noqa: E712
.filter(Voucher.type != VoucherType.by_name("Issue").id) .filter(Voucher.type != VoucherType.by_name("Issue").id)
.order_by(Voucher.date) .order_by(Voucher.date)