这个问题经常难道新手一下,因为大部分教程里(包括经典的《Flask
成都创新互联专注于田林企业网站建设,响应式网站,商城开发。田林网站建设公司,为田林等地区提供建站服务。全流程按需网站策划,专业设计,全程项目跟踪,成都创新互联专业和态度为您提供的服务
Web开发》一书),告诉了我们如何使用flask-sqlalchemy操作sqlite,但在生产环境(线上网站)上,我们肯定是使用MySQL或其
他,而大部分的教程里,又告诉我们flask-sqlalchemy使用MySQL的方式是:
mysql://username:password@server/db
结果我们照葫芦画瓢的来一下,发现压根不行,写好的网站一跟数据库沾边就报错。
Python和MySQL是「两个国家的人」,他们互不相通,因而需要一个中间代理,让双方互通有无,跟翻译一样(这比喻不准确,但足够你明白意思就行)。翻译又有很多选择,不同的翻译各有特色。
题
主解决问题选择的翻译是「flask-mysqldb」,其背后的主子是「MySQL-python」。恩,说到这里你应该知道,「flask-xxx」
这样的包都是对背后主子进行了适合Flask封装的插件,跟包子皮一样,里面的馅才是重点,「flask-mysqldb」的馅是「MySQL-
python」。
而我要推荐的是另一个翻译:PyMySQL,这玩意的好处是可以做异步(「MySQL-python」也可以,个人口味罢了),简而言之,网站访问量大了就需要考虑异步,现在别管这是啥子。这玩意的安装方式是:
pip install PyMySQL
之后,数据库连接由:
mysql://username:password@server/db
改为
mysql+pymysql://username:password@server/db
就可以了。
用 Flask-SQLAlchemy(SQLAlchemy ORM 模块的 Flask 定制版)。这个在定义 schema、连接数据库、增删改查方面都给你提供极大的便利。
这个对象就包含 sqlalchemy 和 sqlalchemy.orm 中的所有函数和助手。此外它还提供一个名为 Model 的类,用于作为声明模型时的 delarative 基类:
from flask import Flask
from flask.ext.sqlalchemy import SQLAlchemy
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:////tmp/test.db'
db = SQLAlchemy(app)
class User(db.Model):
id = db.Column(db.Integer, primary_key=True)
username = db.Column(db.String(80), unique=True)
email = db.Column(db.String(120), unique=True)
def __init__(self, username, email):
self.username = username
self.email = email
def __repr__(self):
return 'User %r' % self.username
python3下用flask-sqlalchemy对mysql数据库操作案例:
from flask import Flask
from flask.ext.sqlalchemy import SQLAlchemy
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://username:password@localhost/db_name'
db = SQLAlchemy(app)
class User(db.Model):
id = db.Column(db.Integer, primary_key=True)
username = db.Column(db.String(80), unique=True)
email = db.Column(db.String(120), unique=True)
def __init__(self, username, email):
self.username = username
self.email = email
def __repr__(self):
return 'User %r' % self.username
admin = User('admin', 'admin@example.com')
db.create_all() # In case user table doesn't exists already. Else remove it.
db.session.add(admin)
db.session.commit() # This is needed to write the changes to database
User.query.all()
User.query.filter_by(username='admin').first()
用flask+mysql实现用户的注册和登录:
一个简单的用户注册和登录的页面,就两个部分。
涉及到数据库,存储用户数据(注册),读出用户数据(登录验证)。搞清楚如何用python连接和操作数据库即可,还有了解sql数据库语句,sqlite和mysql差不多的,看几眼多试几下就了解了。
网站程序,前端如何发送表单,后端获取用户发送的请求,和数据库中数据验证是否能够登录,然后登录后如何保存用户登录信息,就是使用的cookie,不过在flask中是session(其实session也是cookie,flask把它封装了下,成了加密的cookie)。
举例如下:
from functools import wrapsdef authorize(fn):
@wraps(fn)
def wrapper(*args, **kwds):
user = session.get('logged_in', None)
if user:
return fn(user=user)
else:
return redirect(url_for('signin',next=request.path))
return wrapper@app.route('/home')@authorizedef home(**kwds):
username = kwds['user']
return render_template('index.html' ,username=username)#加密存储密码import osimport hashlibdef encrypt_password(password, salt=None):
if not salt:
salt = os.urandom(16).encode('hex') # length 32
result = password
for i in range(3):
result = hashlib.sha256(password + salt).hexdigest()[::2] #length 32
return result, salt#简单的错误处理class loginError(Exception):
def __init__(self, value):
self.value = value
def __str__(self):
return repr(self.value)# 注册登录(下面的代码没有实际运行过)# 连接数据库我是使用的是 mysql.connector # 写法和常用的MySQL-python稍有所不同# 下面没有连接数据库的代码@app.route('/register/', methods=['GET','POST'])def request():
if request.method == 'GET':
return render_template("register.html")
if request.method == 'POST':
# 这里最好需要验证用户输入,我就不写了
u = request.form['username']
p,s = encrypt_password(request.form['password'])
g.db.cursor.execute('INSERT INTO users (name,password,salt) VALUES (%s,%s,%s)',(u,p,s,)
g.db.commit()
return redirect(url_for('signin'))@app.route('/signin/', methods=['GET','POST'])def signin():
if request.method == 'GET':
referrer = request.args.get('next','/')
return render_template("login.html",next=referrer)
if request.method == 'POST':
u = request.form['username']
p = request.form['password']
n = request.form['next']
try:
g.db.cursor.execute('SELECT `name` FROM users WHERE name = %s',(u,))
if not g.db.cursor.fetchone():
raise loginError(u'错误的用户名或者密码!')
g.db.cursor.execute('SELECT `salt`,`password` FROM users WHERE name = %s',(u,))
salt,password = g.db.cursor.fetchone()
if encrypt_password(p,salt)[0] == password:
session['logged_in'] = u
return redirect(next)
else:
raise loginError(u'错误的用户名或者密码!')
except loginError as e:
return render_template('login.html', next=next,error=e.value)@app.route('/signout/', methods=['POST'])def signout():
session.pop('logged_in', None)
return redirect(url_for('home'))
名称栏目:flask整合nosql,flask框架
浏览地址:https://www.cdcxhl.com/article12/dsijodc.html
成都网站建设公司_创新互联,为您提供静态网站、、外贸网站建设、网站营销、微信公众号、关键词优化
声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联