vlambda博客
学习文章列表

from flask import Flaskimport pymysql
app = Flask(__name__)
# 连接本地Mysql数据库conn = pymysql.connect( host='localhost', port=3306, user='root', # 用户名 password='root', # 密码 database='wuao', # 数据库的名字 charset='utf8')
cursor = conn.cursor() # 获取游标
# 注:user为表名try: # 增： sql = "insert into user(uid,username,password,email) values ('1','hanhan','123456','[email protected]')" # 改: # sql = "update user set password='654321' where name='hanhan'" # 删: # sql = "delete from user where username='hanhan'" cursor.execute(sql) # 执行单条SQL语句 conn.commit() #提交事务
 # 这个时候我们会发现，双引号内都是sql语句，其余功能我就不多写了， # 会sql语句的朋友可以轻轻松松的使用这种方法，对你的数据库进行任何操作  sql = "select *from user" # 全连接的SQL语句，要查询user表中所有的数据
 cursor.execute(sql) # 执行单条SQL语句 results = cursor.fetchall() # 接受全部的返回结果行 print(results)except Exception as e: # 抛出异常 print(e)

conn.rollback() # 事务回滚，如果产生异常，退回到执行sql语句之前cursor.close() # 关闭游标conn.close() # 关闭数据库游标
@app.route('/')def conn(): r=results #将数据库信息显示在前端 return str(r)
if __name__ == '__main__': app.run(debug=True)COPY

from flask import Flaskimport pymysqlfrom flask_migrate import Migratefrom flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
app.config['SECRET_KEY'] = '123'
#依次对应的是用户名 密码 数据库名称app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:root@localhost/yiban'#动态追踪修改设置，如未设置只会提示警告app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True#查询时会显示原始SQL语句app.config['SQLALCHEMY_ECHO'] = True
# 初始化一个对象db = SQLAlchemy(app)
# 测试数据库是否连接成功# db.create_all()
pymysql.install_as_MySQLdb()migrate = Migrate(app, db)# db.init_app(app) #初始化数据库接受文件pymysql.install_as_MySQLdb()
class User(db.Model): #创建一个User类 __tablename__ = 'user' #表名
 id = db.Column(db.Integer, primary_key=True,autoincrement=True,default=1) #整型，主键，自增长，默认值为1
 username = db.Column(db.String(50), nullable=False) # 用户名不能为空
 password = db.Column(db.String(50), nullable=False) # 密码不能为空
# db.create_all() #创建表，对象映射，在增删改查时可去掉
# 增：user1=User(id=1,username='hanhan',password='123456')db.session.add(user1) #将user1加入数据库
# 查:# 一条:user1=User.query.filter_by(id=1).first() #方法1# user1=User.query.filter(User.id==1).first() #方法2print(user1.username) #查找id=1的对象,输出它的用户名
# 一种:result=User.query.filter_by(password='123456').all() #方法1# result=User.query.filter(User.password=='123456').all() #方法2for i in result: print(i.username) #查找password为123456的所有对象,输出它们的名字
# 改:#以查为前提user1.username='han++' #将 user1 的 username 由 hanhan 变为 han++
# 删:#以查为前提# db.session.delete(user1) #删除对象user1
db.session.commit() #提交事务
if __name__ == '__main__': app.run(debug=True)