使用sqlalchemy连接MySQL
时间: 2024-09-24 13:16:55 浏览: 40
SQLAlchemy是一个强大的ORM(对象关系映射)库,它允许你在Python中使用面向对象的方式来操作数据库,包括MySQL。以下是使用SQLAlchemy连接MySQL的一般步骤:
首先,你需要安装SQLAlchemy库(如果还没有安装):
```bash
pip install SQLAlchemy
```
接下来,设置数据库连接信息:
```python
from sqlalchemy import create_engine
# 定义数据库URL,其中"mysql+pymysql://"需要替换为你的MySQL服务器地址、用户名、密码和数据库名
url = 'mysql+pymysql://{username}:{password}@{host}/{dbname}'
engine = create_engine(url.format(username='your_username', password='your_password', host='localhost', dbname='your_dbname'))
```
现在你可以使用`engine`创建连接并执行SQL查询:
```python
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
class YourModel(Base): # 假设有一个名为User的模型
__tablename__ = 'users'
id = Column(Integer, primary_key=True)
name = Column(String)
# 创建Session对象
Session = sessionmaker(bind=engine)
session = Session()
# 查询示例
query = session.query(YourModel).filter_by(name='John Doe')
result = query.first()
# 插入示例
new_user = YourModel(name='Alice')
session.add(new_user)
session.commit()
```
在这个例子中,你可以定义模型(如`YourModel`)来对应MySQL表结构,并通过`Session`对象进行CRUD(Create, Read, Update, Delete)操作。
阅读全文