from table_create import T3
from __init__ import PostgresqlPool
from sqlalchemy import insert, select, delete, update, or_, and_

db = PostgresqlPool()

# 增加数据 -- core + orm的 方式 可获取改的数据条数
# with db.session_scope() as session:
#     sql = insert(T3).values([
#         {"name": "testt"},
#         {"name": "testb"},
#         {"name": "testa"},
#         {"name": "tesqa"},
#     ])
#     result = session.execute(sql)
#     session.commit()
#     print(f"修改数据：", result.rowcount, "条")

# 删除数据 core + orm的 方式
# with db.session_scope() as session:
#     sql = delete(T3).where(
#         and_(
#             T3.id == 1,
#             T3.name == "testt"
#         )
#     )
#     result = session.execute(sql)
#     session.commit()
#     print(f"修改数据：", result.rowcount, "条")
# 修改数据 core + orm的 方式
# with  db.session_scope() as session:
#     sql = update(T3).where(T3.name=="tesqa").values(name="asdhjkasdg")
#     result = session.execute(sql)
#     session.commit()
#     print(f"修改数据：", result.rowcount, "条")
# 查询数据 core + orm的 方式，通过count查询数据条数
with db.session_scope() as session:
    sql = select(T3.name).where(T3.name!="tesqa")
    result = session.execute(sql)
    print(f"查询到的数据",result.fetchall())