modelUserOperations.py 892 B

12345678910111213141516171819202122
  1. from utils.rdbmsUtil.databaseUtil import sql_operation
  2. from utils.rdbmsUtil.modelUser import User
  3. from sqlalchemy.sql import text
  4. from sqlalchemy.orm import Session
  5. def sqlOfUpdate(name, age):
  6. return "Update users SET age= :age WHERE name= :name"
  7. class UserOperations:
  8. @sql_operation("INSERT INTO users (name, age,companyid) VALUES (:name, :age,:companyid) ON CONFLICT (id) DO UPDATE SET name=:name,age = :age,companyid=:companyid", entity_type='user', batch=True)
  9. def upsert_users(self, session: Session, users):
  10. pass
  11. @sql_operation("SELECT * FROM users WHERE name = :name and age= :age", entity_type='user')
  12. def get_user(self, session: Session, *, name, age): # 使用 * 来强制之后的参数必须为关键字参数
  13. pass
  14. @sql_operation(sqlOfUpdate, entity_type='user')
  15. def update(self, session: Session, *, name, age):
  16. pass