Python 数据库连接与ORM详解

2023-09-29 01:08:09

Python 数据库连接与ORM详解

1. 什么是ORM？

ORM（Object-Relational Mapping，对象关系映射）是一种技术，它允许你使用对象来表示和操作数据库中的数据。它在对象和关系数据库之间建立了一个抽象层，使得你可以使用对象的方式来操作数据库。ORM框架会在底层自动为你处理SQL查询，简化了数据库操作的复杂性。

2. SQLAlchemy是什么？

SQLAlchemy是一个关系型数据库框架，它提供了高层的ORM和底层的原生数据库的操作。它是一个非常流行的数据库框架，支持多种数据库，包括MySQL、PostgreSQL、Oracle等。

3. Flask-SQLAlchemy是什么？

Flask-SQLAlchemy是一个简化了SQLalchemy操作的flask拓展。它将SQLalchemy的ORM集成到了flask中，使得flask应用程序可以很方便地使用SQLalchemy来连接和操作数据库。

4. 如何使用SQLAlchemy连接数据库？

首先，我们需要创建一个SQLAlchemy引擎，然后创建一个会话，最后创建一个模型来表示数据库中的数据。

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

# 创建SQLAlchemy引擎
engine = create_engine('mysql+pymysql://username:password@host:port/database_name')

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

# 创建模型
class User(Base):
    __tablename__ = 'user'

    id = Column(Integer, primary_key=True)
    name = Column(String(50), nullable=False)
    email = Column(String(100), unique=True)

# 创建表
Base.metadata.create_all(engine)

5. 如何使用SQLAlchemy操作数据库？

我们可以使用会话对象来操作数据库。会话对象提供了许多方法来增删改查数据。

# 添加数据
user = User(name='John Doe', email='johndoe@example.com')
session.add(user)

# 提交事务
session.commit()

# 查询数据
users = session.query(User).all()
for user in users:
    print(user.name)

# 更新数据
user = session.query(User).get(1)
user.name = 'Jane Doe'
session.commit()

# 删除数据
session.delete(user)
session.commit()

6. 如何使用Flask-SQLAlchemy连接数据库？

首先，我们需要在flask应用程序中初始化Flask-SQLAlchemy，然后创建一个模型来表示数据库中的数据。

from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

# 初始化Flask-SQLAlchemy
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://username:password@host:port/database_name'
db = SQLAlchemy(app)

# 创建模型
class User(db.Model):
    __tablename__ = 'user'

    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(50), nullable=False)
    email = db.Column(db.String(100), unique=True)

# 创建表
db.create_all()

7. 如何使用Flask-SQLAlchemy操作数据库？

我们可以使用db对象来操作数据库。db对象提供了许多方法来增删改查数据。

# 添加数据
user = User(name='John Doe', email='johndoe@example.com')
db.session.add(user)

# 提交事务
db.session.commit()

# 查询数据
users = User.query.all()
for user in users:
    print(user.name)

# 更新数据
user = User.query.get(1)
user.name = 'Jane Doe'
db.session.commit()

# 删除数据
db.session.delete(user)
db.session.commit()