- 编写要求登录的装饰器
from functools import wraps
def loginFirst(func): #参数是函数
@wraps(func)
def wrapper(*args, ** kwargs): #定义个函数将其返回
#要求登录
return func(*args, ** kwargs)
return wrapper #返回一个函数
- 应用装饰器,要求在发布前进行登录,登录后可发布。
@app.route('/question/',methods=['GET','POST'])
@loginFirst
def question():
- 建立发布内容的对象关系映射。
class Question(db.Model):
- 完成发布函数。
保存到数据库。
重定向到首页。
from flask import Flask, render_template, request, redirect, url_for,session from flask_sqlalchemy import SQLAlchemy import config from functools import wraps from datetime import datetime app = Flask(__name__) app.config.from_object(config) db = SQLAlchemy(app) class User(db.Model): __tablename__ = 'user' id = db.Column(db.Integer, primary_key=TabError, autoincrement=True) username = db.Column(db.String(20), nullable=False) password = db.Column(db.String(20), nullable=False) # nickname = db.Column(db.String(20)) class Post(db.Model): __tablename__='post' id = db.Column(db.Integer, primary_key=TabError, autoincrement=True) title = db.Column(db.String(100),nullable=False) detail = db.Column(db.Text,nullable=False) creat_time = db.Column(db.DateTime, default=datetime.now) author_id = db.Column(db.Integer, db.ForeignKey('user.id')) author = db.relationship('User', backref=db.backref('post')) db.create_all() # 查询删除 # user = User.query.filter(User.username == 'lin').first() # db.session.delete(user) # db.session.commit() # 修改 # user = User.query.filter(User.username == 'lin').first() # user.password = '1234' # print(user.username,user.password) # db.session.commit() # 增加 # user = User(username = 'lin',password = 'lin') # db.session.add(user) # db.session.commit() db.create_all() @app.route('/') def jianshu(): return render_template('jianshu.html') @app.route("/login/", methods=['GET', 'POST']) def login(): if request.method == 'GET': return render_template('login.html') else: username = request.form.get('username') password = request.form.get('password') user = User.query.filter(User.username == username).first() if user: session['user'] = username session.permanent = True return redirect(url_for('jianshu')) else: return 'error username or password' @app.route("/enroll/", methods=['GET', 'POST']) def enroll(): if request.method == 'GET': return render_template('enroll.html') else: username = request.form.get('username') password = request.form.get('password') user = User.query.filter(User.username == username).first() if user: return 'username exited' else: user = User(username=username, password=password) db.session.add(user) db.session.commit() return redirect(url_for('login')) @app.context_processor def mycontext(): usern = session.get('user') if usern: return {'username':usern} else: return {} @app.route('/logout/') def logout(): session.clear() return redirect(url_for('jianshu')) def loginFirst(func): @wraps(func) def wrapper(*args, **kwargs): if session.get('user'): return func(*args, **kwargs) else: return redirect(url_for('login')) return wrapper @app.route("/post/",methods=['GET','POST']) @loginFirst def post(): if request.method=='GET': return render_template('post.html') else: title=request.form.get('title') detail=request.form.get('detail') author_id=User.query.filter(User.username==session.get('user')).first().id post=Post(title=title,detail=detail,author_id=author_id) db.session.add(post) db.session.commit() return redirect(url_for('jianshu')) if __name__ == '__main__': app.run(debug=True)