最近项目的两次版本迭代中，根据业务需求的变化，需要对数据库进行更新，两次分别使用了不同的方式进行更新。
第一种：使用python的MySQLdb模块利用原生的sql语句进行更新
import MySQLdb#主机名HOST = '127.0.0.1'#用户名USER = "root"#密码PASSWD = "123456"#数据库名DB = "db_name"# 打开数据库连接db=MySQLdb.connect(HOST,USER,PASSWD,DB)# 获取操作游标cursor=db.cursor()if __name__ == '__main__': if cursor: command_a = "update tables_one set status=5 where status=0" # 使用execute方法执行SQL语句 cursor.execute(command_a) # 提交到数据库执行 db.commit() command2 = "select field from tables_one where id =12" ret2 = cursor.execute(command2) # 获取所有记录列表 ret2=cursor.fetchall() for item in ret2: command3 = "insert into tables_two(name) values (%s);" % (item[0]) fin=cursor.execute(command3) db.commit() # 关闭数据库连接 db.close()
登录后复制
数据库查询三种方式
fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
fetchall():接收全部的返回结果行.
立即学习“Python免费学习笔记（深入）”；
rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。
第二种：使用python的框架flask和sqlalchemy进行更新
# -*- coding:utf-8 -*-from flask import Flaskfrom flask_sqlalchemy import SQLAlchemyfrom sqlalchemy.sql import textHOST = '127.0.0.1'USER = "root"PASSWD = "123456"DB = "carrier_test"CHARTSET = "utf8"app = Flask(__name__,instance_relative_config = True)#链接数据库路径app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://%s:%s@127.0.0.1:3306/%s?charset=%s' %(USER,PASSWD,DB,CHARTSET)#如果设置成 True (默认情况)，Flask-SQLAlchemy 将会追踪对象的修改并且发送信号。这需要额外的内存， 如果不必要的可以禁用它。app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True#如果设置成 True，SQLAlchemy 将会记录所有 发到标准输出(stderr)的语句，这对调试很有帮助。app.config['SQLALCHEMY_ECHO'] = False# 数据库连接池的大小。默认是数据库引擎的默认值 （通常是 5）。app.config['SQLALCHEMY_POOL_SIZE'] = 6db = SQLAlchemy(app)class Table_one(db.Model): __tablename__ = 'table_one' id = db.Column('id', db.Integer, primary_key=True, autoincrement=True) com_name = db.Column('com_name', db.String(30), nullable=False) com_about = db.Column('com_about', db.String(200), nullable=False) def __repr__(self): return '' % self.com_nameclass Table_two(db.Model): __tablename__ = 'table_two' id = db.Column('id', db.Integer, primary_key=True, autoincrement=True) reason = db.Column('reason', db.String(128), nullable=True) create_time = db.Column('create_time', db.TIMESTAMP, server_default=text('now()')) status = db.Column('status', db.Integer, nullable=False, default=0) def __repr__(self): return '登录后复制
两种方式对比：
1.在实际项目中，数据库的更新 需要用到很多相关函数进行数据的收集，判断是否满足条件等，而这些相关函数在项目中都是用 Sqlalchemy进行数据相关操作，比如第二种方法里的db_commit_all()函数
2.使用第二种方法，直接复制这些函数到脚本中即可，如果使用第一种方法，则需要重写相关函数，增加开发时间，浪费精力。
3.如果项目中是使用flask进行开发，推荐使用第二种方法进行数据库更新。
以上就是python中可以使用两种方法实现更新数据库脚本的示例的详细内容，更多请关注【创想鸟】其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至253000106@qq.com举报，一经查实，本站将立刻删除。
发布者：PHP中文网，转转请注明出处：https://www.chuangxiangniao.com/p/2267615.html
