sqlalchemy操作sqlite代码

import sqlite3
from sqlalchemy import create_engine, Table, Column, Integer, String, MetaData

# 创建连接
engine = create_engine('sqlite:///example.db', echo=True)

# 创建表
metadata = MetaData()
user_table = Table('user', metadata,
Column('id', Integer, primary_key=True),
Column('name', String),
Column('age', Integer),
)
metadata.create_all(engine)

# 插入数据
conn = engine.connect()
conn.execute(user_table.insert(), [
{'name': 'Alice', 'age': 21},
{'name': 'Bob', 'age': 22},
{'name': 'Charlie', 'age': 23}
])

# 查询数据
query = user_table.select()
result = conn.execute(query)

for row in result:
print(row)

相关问题

使用SQLAlchemy连接SQLite数据库

SQLAlchemy是一个强大的Python ORM (Object-Relational Mapping) 框架，它允许开发者通过Python代码操作SQL数据库，而无需直接编写SQL查询。连接SQLite数据库到SQLAlchemy的过程相对简单，以下是基本步骤：

1. 安装SQLAlchemy：首先需要安装 SQLAlchemy 和 sqlite3 库，可以使用 pip 进行安装：

   pip install sqlalchemy

2. 导入库并创建引擎：在 Python 中，你需要导入 `create_engine` 函数来创建数据库引擎。SQLite 数据库通常只需要一个文件名作为参数：

   from sqlalchemy import create_engine

   engine = create_engine('sqlite:///example.db')

上面的代码将创建一个指向名为 "example.db" 的SQLite数据库的连接。

3. 创建映射模型：根据SQLite表结构，你可以定义 SQLAlchemy 类型的模型来表示数据库中的表。例如，如果有一个用户表：

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

   Base = declarative_base()

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

4. 创建表：使用 `Base.metadata.create_all(engine)` 来根据模型创建或更新数据库表：

   Base.metadata.create_all(engine)

5. 执行CRUD操作：现在你可以使用 Session 对象（`from sqlalchemy.orm import sessionmaker`）来进行增删改查操作，如获取、插入、更新和删除数据：

   Session = sessionmaker(bind=engine)
   session = Session()
   
   # 插入数据
   new_user = User(name='Alice', email='alice@example.com')
   session.add(new_user)
   session.commit()

   # 查询数据
   users = session.query(User).all()

如何使用SQLAlchemy连接sqlite数据库

使用SQLAlchemy连接sqlite数据库可以按照以下步骤进行：

1. 安装SQLAlchemy：可以使用pip命令进行安装，如下所示：

   pip install SQLAlchemy

2. 导入SQLAlchemy模块：

   from sqlalchemy import create_engine

3. 创建一个sqlite数据库连接：

   engine = create_engine('sqlite:///example.db', echo=True)

其中，'example.db'是你要连接的sqlite数据库文件的文件名。

4. 创建一个数据库会话：

   from sqlalchemy.orm import sessionmaker

   Session = sessionmaker(bind=engine)
   session = Session()

这样就可以使用session对象来进行数据库操作了。

完整的示例代码如下所示：

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

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

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

# 查询数据库中的数据
result = session.execute('SELECT * FROM users')
for row in result:
    print(row)

# 关闭数据库会话
session.close()