sqlalchemy写入mysql的实例,sql=‘’然后继续
时间: 2024-09-30 21:06:29 浏览: 27
在Python中,我们可以使用SQLAlchemy库将数据插入MySQL数据库。首先,你需要安装`SQLAlchemy`和`mysql-connector-python`。以下是一个基本的示例,展示如何连接到MySQL数据库并执行写操作:
```python
from sqlalchemy import create_engine, Table, MetaData, select, insert
from sqlalchemy.ext.declarative import declarative_base
# 配置数据库连接信息
DATABASE_URL = 'mysql+pymysql://username:password@localhost/dbname'
engine = create_engine(DATABASE_URL)
# 声明ORM模型(如果你还没有创建)
Base = declarative_base()
class YourModel(Base):
__tablename__ = 'your_table_name' # 表名
id = Column(Integer, primary_key=True)
column1 = Column(String)
column2 = Column(Integer) # 确保列名与数据库表中的字段匹配
# 创建元数据对象
metadata = MetaData(bind=engine)
# 定义SQL语句(假设你想插入一行数据)
sql = """
INSERT INTO your_table_name (column1, column2)
VALUES ('value1', 123)
"""
# 使用Session来执行插入操作(如果还没创建Session,需要先创建)
with engine.begin() as connection:
table = Table(YourModel.__tablename__, metadata, autoload_with=connection)
stmt = insert(table).values(column1='value1', column2=123)
result = connection.execute(stmt)
print(f"插入记录成功,返回值:{result.rowcount}")
# 提交事务(如果需要的话)
connection.commit()
阅读全文