当前位置： 首页 > news >正文

网站备案是免费的吗宁波正规品牌网站设计

news 2025/9/16 18:09:16
网站备案是免费的吗,宁波正规品牌网站设计,建设企业银行网站多少,兰陵建设局网站上次发布《多种方式访问mysql的对比分析》一文后，有读者留言，说SQLAlchemy的使用方法没讲清楚，只有一段简短的介绍，演示代码也比较模糊，SQLAlchemy在实际项目运用非常广泛，由于其支持 ORM 模型，…

上次发布《多种方式访问mysql的对比分析》一文后，有读者留言，说SQLAlchemy的使用方法没讲清楚，只有一段简短的介绍，演示代码也比较模糊，SQLAlchemy在实际项目运用非常广泛，由于其支持 ORM 模型，能够将表映射为类，让你用Python类的方式来操作数据库，而不需要直接写SQL语句，是面向对象访问数据库不可或缺的一个库，根据需求设计数据库结构和操作逻辑，可以大大提高开发效率和代码可维护性。今天风云将该库的详细使用方法重新整理了，发出来，供大家参考，欢迎留言讨论。

为什么还要用SQLAlchemy呢？原因有几个：
1.简洁：SQLAlchemy让你用Python代码来操作数据库，代码更简洁，也更容易理解。
2.安全：它能帮助你避免SQL注入等安全问题，让你的数据库更安全。
3.灵活：SQLAlchemy支持多种数据库（比如MySQL、PostgreSQL、SQLite等），你只需要改一下配置，就能在不同的数据库之间切换。

SQLAlchemy 包括两个核心组件：

  • SQLAlchemy Core：提供底层 SQL 构造和数据库连接。
  • SQLAlchemy ORM：实现面向对象的 ORM 映射。

1. 安装 SQLAlchemy

使用 pip 安装：

pip install sqlalchemy

2. 数据库连接

使用 create_engine 创建数据库连接：

from sqlalchemy import create_engine

# 替换为实际的数据库 URL

engine = create_engine('sqlite:///example.db')  # SQLite 示例

# MySQL 示例: 'mysql+pymysql://user:password@host/dbname'

3. 使用 SQLAlchemy Core

3.1 创建表

使用 MetaData 和 Table 定义表结构：

from sqlalchemy import Table, Column, Integer, String, MetaData,create_engineengine = create_engine('sqlite:///example.db')  # SQLite 示例数据库
metadata = MetaData() # 元数据对象users = Table(  # 创建表'users', metadata,  # 表名Column('id', Integer, primary_key=True),  # id字段Column('name', String(50)),  # name字段Column('age', Integer) # age字段
)metadata.create_all(engine)  # 创建表

3.2 插入数据

使用 insert() 插入数据：

from sqlalchemy import insertwith engine.connect() as conn:  # 连接数据库stmt = insert(users).values(name='Alice', age=30)  # 插入数据conn.execute(stmt)  # 执行插入语句

3.3 查询数据

使用 select() 查询：

from sqlalchemy import selectwith engine.connect() as conn:  # 连接数据库stmt = select(users)  # 查询数据result = conn.execute(stmt)  # 执行查询语句for row in result:  # 遍历结果print(row)

4. 使用 SQLAlchemy ORM

4.1 定义模型

使用 ORM 的 declarative_base 定义模型：

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, StringBase = declarative_base()  # 创建基类class User(Base):  # 创建User类__tablename__ = 'users'  # 表名id = Column(Integer, primary_key=True)  # id字段name = Column(String(50)) # name字段age = Column(Integer) # age字段

4.2 创建表

创建表结构：

Base.metadata.create_all(engine)

4.3 创建会话

使用 sessionmaker 创建会话：

from sqlalchemy.orm import sessionmakerSession = sessionmaker(bind=engine) # 创建Session会话类
session = Session()

4.4 增删改查

插入数据

new_user = User(name='Bob', age=25) # 创建新用户session.add(new_user)# 添加新用户到sessionsession.commit() # 提交事务

查询数据

users = session.query(User).all()  # 查询所有用户
for user in users:  # 遍历查询结果print(user.name, user.age)

更新数据

user = session.query(User).filter_by(name='Bob').first() # 查询用户
user.age = 26session.commit() # 提交事务

删除数据

user = session.query(User).filter_by(name='Bob').first() # 查询具体用户，定位到第一条记录session.delete(user) # 删除用户
session.commit() # 提交事务

5. 使用关系映射

定义一对多关系：

from sqlalchemy import ForeignKeyfrom sqlalchemy.orm import relationshipclass Post(Base):__tablename__ = 'posts'  # 表名id = Column(Integer, primary_key=True) # id字段title = Column(String(100)) # title字段user_id = Column(Integer, ForeignKey('users.id')) # 定义外键user = relationship('User', back_populates='posts') # 关联关系User.posts = relationship('Post', order_by=Post.id, back_populates='user') # 关联关系# 插入关联数据：
user = User(name='Charlie')post1 = Post(title='Post 1', user=user)post2 = Post(title='Post 2', user=user)session.add(user) # 添加关联数据session.add_all([post1, post2]) # 添加所有关联session.commit() # 提交事务#查询关联数据：
user = session.query(User).filter_by(name='Charlie').first() # 查询关联数据for post in user.posts: # 遍历关联数据print(post.title)

6. 使用事务

手动管理事务：

from sqlalchemy.exc import SQLAlchemyErrortry:with session.begin():  # 开启事务user = User(name='Dave', age=40) # 创建新用户session.add(user) # 添加新用户到session
except SQLAlchemyError as e: # 如果发生异常，回滚事务print(f"Transaction failed: {e}")session.rollback() # 回滚事务

7. 完整的封装类

最后，风云按惯例将此使用封装为一个完整的类，大家有需要有的自取

from sqlalchemy import create_engine, Column, Integer, String, exc
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmakerBase = declarative_base()  # 创建基类# 定义表模型
class User(Base):__tablename__ = 'users' # 表名id = Column(Integer, primary_key=True, autoincrement=True) # id字段name = Column(String(50), nullable=False) # name字段age = Column(Integer, nullable=False) # age字段class MySQLHandler:def __init__(self, user, password, host, database):"""初始化数据库连接和会话"""try:url = f'mysql+pymysql://{user}:{password}@{host}/{database}' # 创建数据库连接self.engine = create_engine(url, echo=False) # 数据库引擎Base.metadata.create_all(self.engine)  # 创建表self.Session = sessionmaker(bind=self.engine) # 创建会话except exc.SQLAlchemyError as e:print(f"Error initializing database: {e}")def add_user(self, name, age):"""添加用户"""session = self.Session() try:new_user = User(name=name, age=age) # 创建新用户session.add(new_user) # 添加新用户到sessionsession.commit() # 提交事务print(f"User {name} added successfully!")except exc.SQLAlchemyError as e: # 如果发生异常，回滚事务session.rollback() # 执行回滚print(f"Error adding user: {e}")finally:session.close() # 关闭会话def get_users(self):"""查询所有用户"""session = self.Session()try:users = session.query(User).all() # 查询所有用户return [{"id": user.id, "name": user.name, "age": user.age} for user in users]except exc.SQLAlchemyError as e: # 如果发生异常，返回空print(f"Error fetching users: {e}")return []finally:session.close()def update_user(self, user_id, name=None, age=None):"""更新用户信息"""session = self.Session()try:user = session.query(User).filter_by(id=user_id).first() # 查询用户if not user: # 如果用户不存在，返回print(f"User with ID {user_id} not found.")returnif name:user.name = nameif age:user.age = agesession.commit() # 提交事务print(f"User {user_id} updated successfully!")except exc.SQLAlchemyError as e: # 如果发生异常，回滚事务session.rollback()print(f"Error updating user: {e}")finally:session.close()def delete_user(self, user_id):"""删除用户"""session = self.Session()try:user = session.query(User).filter_by(id=user_id).first() # 查询用户if not user: # 如果用户不存在，返回print(f"User with ID {user_id} not found.")returnsession.delete(user) # 删除用户session.commit() # 提交事务print(f"User {user_id} deleted successfully!")except exc.SQLAlchemyError as e: # 如果发生异常，回滚事务session.rollback()print(f"Error deleting user: {e}")finally:session.close()def transaction_example(self):"""事务操作示例"""session = self.Session()try:user1 = User(name="Alice", age=30) # 创建2个新用户user2 = User(name="Bob", age=25) # 添加多个用户session.add(user1) # 添加新用户到sessionsession.add(user2)# 模拟事务中的错误# Uncomment the line below to raise an exception and trigger a rollback# raise ValueError("Simulated error!")session.commit() # 提交事务print("Transaction completed successfully!")except (exc.SQLAlchemyError, ValueError) as e: # 如果发生异常，回滚事务session.rollback()print(f"Transaction failed: {e}")finally:session.close()# 使用示例
if __name__ == "__main__":# 初始化数据库连接db_handler = MySQLHandler(user='root', password='password123', host='localhost', database='test_db')# 添加用户db_handler.add_user(name="John Doe", age=28)# 查询用户users = db_handler.get_users()print("Users:", users)# 更新用户db_handler.update_user(user_id=1, name="Jane Doe", age=32)# 删除用户db_handler.delete_user(user_id=1)# 事务示例db_handler.transaction_example()

http://www.yayakq.cn/news/311114/

相关文章：

  • 网站左侧导航栏设计怎么做销售网站
  • 黄龙云 加强网站建设施工企业工作环境
  • 烟台违建举报网站小型网站建设实训教程
  • 网站建设招标技术要求重庆做网站怎么做呀
  • 广州网站建设公司嘉御成都工业设计公司
  • 网站开发类型什么意思大公司 wordpress
  • 罗湖网站建设深圳信科织梦音乐网站
  • 24小时学会网站建设 百度云安徽安庆网站建设公司
  • 宝塔wordpress恢复新乡优化
  • 免费做国际网站哪里有培训班
  • 网站类网站建设商业网站设计方案模板
  • 多用户商城网站东营可以做网站的公司在哪
  • 百货商城网站建设国外网站怎么推广
  • html5商城网站模板福建省机关效能建设网站
  • 网站网页设计在哪找百度高级搜索
  • 行业论坛网站高校财务网站建设
  • 株洲网络营销推广哪家好太原seo排名收费
  • 网站建设自我介绍网页设计大赛作品欣赏
  • 哈尔滨网站建设q479185700惠舒城县住房和城乡建设局网站
  • 福建网站优化石家庄网站推广招聘
  • 西安旅游网站开发成全视频免费观看在线看第6季高清版
  • 小辰青岛网站建设定制类网站
  • 在哪几个网站里可以做淘客如何建网站并做推广
  • 苏州网络营销网站建设平台番禺建设局网站首页
  • 自适应网站案例wordpress调用文章id
  • 网站设计免费模板新版爱美眉网站源码
  • 哪个网站可以做淘宝代码网站功能怎么写
  • 网站设计中的用户体验网络营销师报考条件
  • 网站建设 顺德wordpress官使用方法
  • 建设校园网站怎么查看网站根目录