sqlalchemy mysql select 的时候加锁

在 SQLAlchemy 中，您可以使用 `with_for_update()` 方法为 SELECT 语句添加 `FOR UPDATE` 选项，从而对查询结果进行加锁。

以下是一个示例：

```python
from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base

# 连接 MySQL 数据库
engine = create_engine('mysql+pymysql://username:password@host:port/database_name')

# 创建会话工厂
Session = sessionmaker(bind=engine)

# 创建会话对象
session = Session()

# 定义 ORM 模型
Base = declarative_base()

class User(Base):
__tablename__ = 'users'
id = Column(Integer, primary_key=True)
name = Column(String(50))
age = Column(Integer)

# 加锁查询
user = session.query(User).filter_by(name='John').with_for_update().first()

# 处理查询结果
if user:
user.age += 1
session.commit()
```

在上述示例中，我们创建了一个会话对象，定义了一个 `User` ORM 模型，并执行了一个加锁查询，对符合条件的记录进行了加锁。查询结果是一个 `User` 对象，您可以对其进行修改并提交事务。