当前位置:   article > 正文

sqlalchemy的增删,插入更新_sqlalchemy更新行

sqlalchemy更新行

1.连接数据库

  1. from sqlalchemy import create_engine
  2. # 连接数据库
  3. engine = create_engine('mysql+pymysql://username:password@localhost/dbname')
  4. # 进行一些数据库操作
  5. # ...
  6. # 关闭连接
  7. engine.dispose()
  • mysql:数据库类型;
  • pymysql:MySQL数据库驱动;
  • username:数据库用户名;
  • password:数据库密码;
  • localhost:数据库主机名;
  • dbname:数据库名。
  • 2.查询数据

    SQLAlchemy提供了两种查询数据的方式:基于SQL语句的查询和基于ORM的查询。

  • 基于SQL语句的查询

  1. from sqlalchemy import create_engine
  2. # 连接数据库
  3. engine = create_engine('mysql+pymysql://username:password@localhost/dbname')
  4. # 执行查询语句
  5. result = engine.execute("SELECT * FROM employees")
  6. # 处理查询结果
  7. for row in result:
  8. print(row)
  9. # 关闭连接
  10. engine.dispose()

  1. from sqlalchemy import create_engine
  2. # 连接数据库
  3. engine = create_engine('mysql+pymysql://username:password@localhost/dbname')
  4. # 构造插入语句
  5. sql = "INSERT INTO employees(name, age, salary) VALUES (%s, %s, %s)"
  6. params = ("Tom", 25, 5000)
  7. # 执行插入语句
  8. engine.execute(sql, params)
  9. # 关闭连接
  10. engine.dispose()
更新数据

更新数据可以通过如下步骤完成:

  1. 创建 对象,并查询要更新的记录
  1. from sqlalchemy.orm import Session
  2. from myapp.models import User # 假设这里有一个 User 模型
  3. session = Session()
  4. # 查询要更新的记录
  5. user = session.query(User).filter_by(id=1).first()
  1. 修改要更新的属性
  1. # 修改属性
  2. user.name = "new_name"
  3. user.age = 30
  1. 提交更改
  1. # 提交更改
  2. session.commit()

完整代码如下:

  1. from sqlalchemy.orm import Session
  2. from myapp.models import User # 假设这里有一个 User 模型
  3. session = Session()
  4. # 查询要更新的记录
  5. user = session.query(User).filter_by(id=1).first()
  6. # 修改属性
  7. user.name = "new_name"
  8. user.age = 30
  9. # 提交更改
  10. session.commit()
删除数据

删除数据也可以通过如下步骤完成:

  1. 创建 session 对象,并查询要删除的记录
  1. from sqlalchemy.orm import Session
  2. from myapp.models import User # 假设这里有一个 User 模型
  3. session = Session()
  4. # 查询要删除的记录
  5. user = session.query(User).filter_by(id=1).first()
  1. 调用 session.delete 方法删除记录
  1. # 删除记录
  2. session.delete(user)
  1. 提交更改
  1. # 提交更改
  2. session.commit()
  1. from sqlalchemy.orm import Session
  2. from myapp.models import User # 假设这里有一个 User 模型
  3. session = Session()
  4. # 查询要删除的记录
  5. user = session.query(User).filter_by(id=1).first()
  6. # 删除记录
  7. session.delete(user)
  8. # 提交更改
  9. session.commit()

完整代码如上:

作者转载,仅供参考,原文如下

简单易用,灵活强大:用SQLAlchemy实现Python操作数据库_sqlalchemy 执行sql-CSDN博客

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小丑西瓜9/article/detail/613240
推荐阅读
相关标签
  

闽ICP备14008679号