使用SQLAlchemy创建存储过程

pip install sqlalchemy

from sqlalchemy import create_engine, MetaData, Table, Column, Integer, String, Sequence
from sqlalchemy.orm import mapper, sessionmaker
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.sql import text

# 创建数据库连接
engine = create_engine('mysql+pymysql://username:password@localhost:3306/dbname')
metadata = MetaData()

# 定义存储过程
proc = """
CREATE PROCEDURE `get_user_by_id` (IN `id` INT)
BEGIN
    SELECT * FROM users WHERE id = id;
END
"""

# 创建存储过程
with engine.connect() as conn:
    conn.execute(text(proc))

# 调用存储过程
with engine.connect() as conn:
    result = conn.execute('CALL get_user_by_id(%s)', 1)
    for row in result:
        print(row)