博客

如何在Python中使用SQLAlchemy操作SQLite数据库？

  • Post category:Python

当我们需要在Python中操作SQLite数据库时，可以使用SQLAlchemy库进行操作。以下是如何在Python中使用SQLAlchemy库操作SQLite数据库的完整使用攻略，包括连接数据库、创建表、插入数据、查询数据等步骤。同时，提供示例以便更好理解如何在Python中使用SQLAlchemy库操作SQLite数据库。

步骤1：安装SQLAlchemy库

在Python中，我们使用SQLAlchemy库操作SQLite数据库。以下是安装SQLAlchemy库的基本语法：

pip install sqlalchemy

在上面的语法，我们使用pip命令安装SQLAlchemy库。

步骤2：连接SQLite数据库

Python中，我们可以使用SQLAlchemy库连接SQLite数据库。以下是连接SQLite数据库的基本语法：

from sqlalchemy import create_engine

# 连接SQLite数据库
engine = create_engine('sqlite:///example.db', echo=True)

在上面的语法中，我们使用create_engine方法连接到SQLite数据库。在create_engine方法中，我们需要指定数据库文件的路径。

步骤3：创建表

在Python中，我们可以使用SQLAlchemy库创建。以下是创建表的基本语法：

from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base

# 连接SQLite数据库
engine = create_engine('sqlite:///example.db', echo=True)

# 创建基类
Base = declarative_base()

# 创建表
class User(Base):
    __tablename__ = 'users'

    id = Column(Integer, primary_key=True)
    name = Column(String)
    age = Column(Integer)

    def __repr__(self):
        return f"<User(name='{self.name}', age={self.age})>"

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

在上面的语法中，我们使用Column方法创建表的列。接着，我们使用declarative_base方法创建基类。然后，我们使用基类创建表。在表的定义中，我们需要指定表名和列名。

步骤4：插入数据

在Python中，我们可以使用SQLAlchemy库插入数据到SQLite数据库。以下是插入数据的基本语法：

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

# 连接SQLite数据库
engine = create_engine('sqlite:///example.db', echo=True)

# 创建基类
Base = declarative_base()

# 创建表
class User(Base):
    __tablename__ = 'users'

    id = Column(Integer, primary_key=True)
    name = Column(String)
    age = Column(Integer)

    def __repr__(self):
        return f"<User(name='{self.name}', age={self.age})>"

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

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

# 插入数据
user1 = User(name='John', age=30)
user2 = User(name='Jane', age=25)
session.add(user1)
session.add(user2)
session.commit()

在上面的语法中，我们使用sessionmaker方法创建Session。然后，我们使用add方法添加数据到Session中。接着，我们使用commit方法提交事务。

步骤5：查询数据

在Python中，我们可以使用SQLAlchemy库查询数据从SQLite数据库。以下是查询数据的基本语法：

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

# 连接SQLite数据库
engine = create_engine('sqlite:///example.db', echo=True)

# 创建基类
Base = declarative_base()

# 创建表
class User(Base):
    __tablename__ = 'users'

    id = Column(Integer, primary_key=True)
    name = Column(String)
    age = Column(Integer)

    def __repr__(self):
        return f"<User(name='{self.name}', age={self.age})>"

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

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

# 查询数据
users = session.query(User).filter(User.age > 25).all()
for user in users:
    print(user)

在上面的语法中，我们使用query方法查询数据。接着，我们使用filter方法过滤数据。最后，我们使用all`方法获取所有数据。

示例1

在这个示例中，我们使用SQLAlchemy库连接SQLite数据库，并创建users表。然后，我们插入两条数据到users表中。接着，我们查询users表age大于25的数据。

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

# 连接SQLite数据库
engine = create_engine('sqlite:///example.db', echo=True)

# 创建基类
Base = declarative_base()

# 创建表
class User(Base):
    __tablename__ = 'users'

    id = Column(Integer, primary_key=True)
    name = Column(String)
    age = Column(Integer)

    def __repr__(self):
        return f"<User(name='{self.name}', age={self.age})>"

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

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

# 插入数据
user1 = User(name='John', age=30)
user2 = User(name='Jane', age=25)
session.add(user1)
session.add(user2)
session.commit()

# 查询数据
users = session.query(User).filter(User.age > 25).all()
for user in users:
    print(user)

在上面的代码中，我们首先使用create_engine方法连接到SQLite数据库。然后，我们使用declarative_base方法创建基类。接着，我们使用基类创建表。在表的定义中，我们需要指定表名和列名。然后，我们使用sessionmaker方法创建Session。接着，我们使用add方法添加数据到Session中。然后，我们使用commit方法提交事务。接着，我们使用query方法查询数据。最后，我们使用filter方法过滤数据，并使用all方法获取所有数据。

示例2

在这个示例中，我们使用SQLAlchemy库连接SQLite数据库，并创建books表。然后，我们插入三条数据到books表中。接着，我们查询books表中的所有数据。

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

# 连接SQLite数据库
engine = create_engine('sqlite:///example.db', echo=True)

# 创建基类
Base = declarative_base()

# 创建表
class Book(Base):
    __tablename__ = 'books'

    id = Column(Integer, primary_key=True)
    title = Column(String)
    author = Column(String)
    year = Column(Integer)

    def __repr__(self):
        return f"<Book(title='{self.title}', author='{self.author}', year={self.year})>"

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

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

# 插入数据
book1 = Book(title='The Great Gatsby', author='F. Scott Fitzgerald', year=1925)
book2 = Book(title='To Kill a Mockingbird', author='Harper Lee', year=1960)
book3 = Book(title='1984', author='George Orwell', year=1949)
session.add(book1)
session.add(book2)
session.add(book3)
session.commit()

# 查询数据
books = session.query(Book).all()
for book in books:
    print(book)

在上面的代码中，我们首先使用create_engine方法连接到SQLite数据库。然后，我们使用declarative_base方法创建基类。接着，我们使用基类创建表。在表的定义中，我们需要指定表名和列名。然后，我们使用sessionmaker方法创建Session。接着，我们使用add方法添加数据到Session中。然后，我们使用commit方法提交事务。接着，我们使用query方法查询数据。最后，我们使用all方法获取所有数据，并使用for循环遍历数据，并打印每一行数据。

以上是如何在Python中使用SQLAlchemy库操作SQLite数据库完整使用攻略包括连接数据库、创建表插入数据、查询数据等步骤。同时，提供了两个示例以便更好理解如何在Python中使用SQLAlchemy库操作SQLite数据库。

Tags: ,