Flask項目示例目錄

時間  2019-11-09
標籤 flask 項目 示例 目錄 欄目 Python 简体版
原文   原文鏈接

　　Flask不一樣於Django，Django在建立程序時自動獲得必要的目錄文件，而Flask則只有一個空文件夾，因此關於Flask項目的目錄咱們須要自行配置。css

　　首先利用pycharm建立一個項目，在根目錄下建立一個app文件夾（app文件）、一個utils文件夾（用於放數據庫鏈接池）、一個manage.py文件和一個settings.py文件。這裏我還建立了一個auth文件夾，寫了一個驗證登陸的py文件html

 

　　首先，咱們要在app文件夾下依次建立一下內容：python

    • 　　static文件夾：用於放靜態文件
    • 　　templates文件夾：用於放置html模板文件
    •         views文件夾：用於放置視圖函數
    •         __init__.py文件：註冊app到啓動文件，一下子咱們會在這裏大作文章
    •         models.py文件：用於放置建立表的類

　　在__init__.py中，須要作的是引入Flask-SQLAlchemy、建立app、設置配置文件、註冊藍圖和註冊組件mysql

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from flask import Flask

from auth.auth import Auth
from flask_session import Session

# 1. 引入Flask-SQLAlchemy
from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy()#實例化SQLAlchemy


from .views.account import account
from .views.main import main
from .views.user import user

# 3. 導入models中的表
from .models import *

#建立app
def create_app():
    app = Flask(__name__)
    app.debug = True
    app.secret_key = 'sdiusdfsdf'#自定義的session祕鑰
    # 設置配置文件
    app.config.from_object('settings.DevelopmentConfig')

    # 註冊藍圖
    app.register_blueprint(account)
    app.register_blueprint(user)
    app.register_blueprint(main)

    # 註冊組件
    # Session(app)
    Auth(app)

    # 2. 註冊 Flask-SQLAlchemy
    # 這個對象在其餘地方想要使用
    # SQLAlchemy(app)
    db.init_app(app)

    return app
#獲得了一個app
app文件夾下的_init__.py

 

　　而後，在啓動文件manage.py中導入建立的app，建立自定義命令後寫下runredis

#!/usr/bin/env python
# -*- coding:utf-8 -*-
"""
被斃掉了
    # 5. 建立和刪除表
    之後執行db.create_all()
    之後執行db.drop_all()
新第5步：
    安裝 pip3 install Flask-Migrate
"""


import os
from flask_script import Manager, Server
# 5.1 導入
from flask_migrate import Migrate, MigrateCommand
from app import create_app, db

app = create_app()
manager = Manager(app)
# 5.2 建立migrate示例
migrate = Migrate(app, db)


@manager.command
def custom(arg):
    """
    自定義命令
    python manage.py custom 123
    :param arg:
    :return:
    """
    print(arg)


@manager.option('-n', '--name', dest='name')
@manager.option('-u', '--url', dest='url')
def cmd(name, url):
    """
    自定義命令
    執行： python manage.py  cmd -n wupeiqi -u http://www.oldboyedu.com
    :param name:
    :param url:
    :return:
    """
    print(name, url)


@manager.command
def import_news(path):
    """
    批量導入
    :param name:
    :param url:
    :return:
    """
    import xlrd
    from xlrd.book import Book
    from xlrd.sheet import Sheet
    from xlrd.sheet import Cell
    workbook = xlrd.open_workbook(path)
    sheet_names = workbook.sheet_names()
    # sheet = workbook.sheet_by_name('工做表1')
    sheet = workbook.sheet_by_index(0)

    # 循環Excel文件的全部行
    for row in sheet.get_rows():
        # print(row)
        # 循環一行的全部列
        for col in row:
            # 獲取一個單元格中的值
            print(col.value, end=';')
        print('')



"""
# 數據庫遷移命名
    python manage.py db init
    python manage.py db migrate
    python manage.py db upgrade
"""
# 5.3 建立db命令，之後在數據庫操做的時候均可使用db
manager.add_command('db', MigrateCommand)



"""
# 自定義命令
    python manage.py runserver 
"""
manager.add_command("runserver", Server())



"""
生成當前環境的全部依賴： requirements.txt
    pip3 freeze > requirements.txt
    
生成當前程序的全部依賴： requirements.txt
    pip3 install pipreqs
    pipreqs ./
    
"""




if __name__ == "__main__":
    manager.run()
manage.py

 

　　接下來在settings.py文件中配置好相應的數據庫信息，在utils文件夾下建立文件，寫入數據庫鏈接池的內容sql

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import redis


class BaseConfig(object):
    SESSION_TYPE = 'redis'  # session類型爲redis
    SESSION_KEY_PREFIX = 'session:'  # 保存到session中的值的前綴
    SESSION_PERMANENT = False  # 若是設置爲True，則關閉瀏覽器session就失效。
    SESSION_USE_SIGNER = False  # 是否對發送到瀏覽器上 session:cookie值進行加密

    SQLALCHEMY_DATABASE_URI = "mysql+pymysql://root:123@127.0.0.1:3306/flask_cata?charset=utf8"
                                             #數據庫用戶名:密碼@host:port/數據庫名?編碼
    SQLALCHEMY_POOL_SIZE = 2
    SQLALCHEMY_POOL_TIMEOUT = 30
    SQLALCHEMY_POOL_RECYCLE = -1

    # 追蹤對象的修改而且發送信號
    SQLALCHEMY_TRACK_MODIFICATIONS = False


class ProductionConfig(BaseConfig):
    pass


class DevelopmentConfig(BaseConfig):
    pass


class TestingConfig(BaseConfig):
    pass
settings.py 
import time
import pymysql
import threading
from DBUtils.PooledDB import PooledDB, SharedDBConnection
POOL = PooledDB(
    creator=pymysql,  # 使用連接數據庫的模塊
    maxconnections=6,  # 鏈接池容許的最大鏈接數，0和None表示不限制鏈接數
    mincached=2,  # 初始化時，連接池中至少建立的空閒的連接，0表示不建立
    maxcached=5,  # 連接池中最多閒置的連接，0和None不限制
    maxshared=3,  # 連接池中最多共享的連接數量，0和None表示所有共享。PS: 無用，由於pymysql和MySQLdb等模塊的 threadsafety都爲1，全部值不管設置爲多少，_maxcached永遠爲0，因此永遠是全部連接都共享。
    blocking=True,  # 鏈接池中若是沒有可用鏈接後，是否阻塞等待。True，等待；False，不等待而後報錯
    maxusage=None,  # 一個連接最多被重複使用的次數，None表示無限制
    setsession=[],  # 開始會話前執行的命令列表。如：["set datestyle to ...", "set time zone ..."]
    ping=0,
    # ping MySQL服務端，檢查是否服務可用。# 如：0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
    # host='47.93.4.198',
    host='127.0.0.1',#本機host
    port=3306,#數據庫默認端口即3306
    user='root',#數據庫用戶名
    password='123',#數據庫密碼
    database='flask_cata',#數據庫名
    charset='utf8'
)
utils\pool\db_pool.py 
"""

# 方式一
# helper = SQLHelper()
# helper.open()
# result = helper.fetchone('select * from users where name=%s and pwd = %s',[request.form.get('user'),request.form.get('pwd'),])
# helper.close()
# 方式二：
# with SQLHelper() as helper:
#     result = helper.fetchone('select * from users where name=%s and pwd = %s',[request.form.get('user'),request.form.get('pwd'),])
# if result:
#     current_app.auth_manager.login(result['name'])
#     return redirect('/index')


"""

from utils.pool import db_pool
import pymysql


class SQLHelper(object):
    def __init__(self):
        self.conn = None
        self.cursor = None

    def open(self, cursor=pymysql.cursors.DictCursor):
        self.conn = db_pool.POOL.connection()
        self.cursor = self.conn.cursor(cursor=cursor)

    def close(self):
        self.cursor.close()
        self.conn.close()

    def fetchone(self, sql, params):
        cursor = self.cursor
        cursor.execute(sql, params)
        result = cursor.fetchone()

        return result

    def fetchall(self, sql, params):
        cursor = self.cursor
        cursor.execute(sql, params)
        result = cursor.fetchall()
        return result

    def __enter__(self):
        self.open()
        return self

    def __exit__(self, exc_type, exc_val, exc_tb):
        self.close()

        # with SQLHelper() as obj:
        #
        #     print(obj)
        #     print('正在執行')
utils\pool\sqlhelper.py

 

到這裏，程序的基本框架就設定好了。數據庫

接下來就是具體項目的內容，這裏舉一個簡單的栗子flask

　　在models.py中建立表瀏覽器

"""

# 方式一
# helper = SQLHelper()
# helper.open()
# result = helper.fetchone('select * from users where name=%s and pwd = %s',[request.form.get('user'),request.form.get('pwd'),])
# helper.close()
# 方式二：
# with SQLHelper() as helper:
#     result = helper.fetchone('select * from users where name=%s and pwd = %s',[request.form.get('user'),request.form.get('pwd'),])
# if result:
#     current_app.auth_manager.login(result['name'])
#     return redirect('/index')


"""

from utils.pool import db_pool
import pymysql


class SQLHelper(object):
    def __init__(self):
        self.conn = None
        self.cursor = None

    def open(self, cursor=pymysql.cursors.DictCursor):
        self.conn = db_pool.POOL.connection()
        self.cursor = self.conn.cursor(cursor=cursor)

    def close(self):
        self.cursor.close()
        self.conn.close()

    def fetchone(self, sql, params):
        cursor = self.cursor
        cursor.execute(sql, params)
        result = cursor.fetchone()

        return result

    def fetchall(self, sql, params):
        cursor = self.cursor
        cursor.execute(sql, params)
        result = cursor.fetchall()
        return result

    def __enter__(self):
        self.open()
        return self

    def __exit__(self, exc_type, exc_val, exc_tb):
        self.close()

        # with SQLHelper() as obj:
        #
        #     print(obj)
        #     print('正在執行')
models.py

 

　　經過python manage.py db init 　　   python manage.py db migrate 　　   python manage.py db upgrade三條命令進行數據庫遷移建立表，獲得migrations文件夾cookie

　　在views文件夾下建立視圖函數，並配置路由。在templates文件夾下建立模板html，在static下建立靜態文件，基本項目就成型了

views：

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from flask import Blueprint, request, render_template, redirect, session, current_app
from app import models
from app import db
from sqlalchemy import orm

account = Blueprint('account', __name__)


@account.route('/login', methods=['GET', 'POST'])
def login():
    if request.method == 'GET':

        """
        執行SQL
        方式一：
            result = db.session.query(models.User.id,models.User.name).all()
            db.session.remove()
        方式二：
            result = models.Users.query.all()
        """
        """
        示例：
            # 通配符
            ret = db.session.query(Users).filter(Users.name.like('e%')).all()
            ret = db.session.query(Users).filter(~Users.name.like('e%')).all()
            
            # 限制
            ret = db.session.query(Users)[1:2]
            
            # 排序
            ret = db.session.query(Users).order_by(Users.name.desc()).all()
            ret = db.session.query(Users).order_by(Users.name.desc(), Users.id.asc()).all()
            
            db.session.remove()
            

        """
        return render_template('login.html')
    else:
        return render_template('login.html')
account.py 
#!/usr/bin/env python
# -*- coding:utf-8 -*-
from flask import Blueprint, request, render_template, redirect

main = Blueprint('main', __name__)


@main.route('/index')
def index():
    # with SQLHelper() as helper:
    #     user_list = helper.fetchall('select * from users',[])

    return render_template('index.html')
main.py 
#!/usr/bin/env python
# -*- coding:utf-8 -*-
from flask import Blueprint

user = Blueprint('user', __name__)


@user.route('/users')
def users():
    return 'users'
user.py

templates:

{% extends 'layout.html' %}

{% block title %}首頁{% endblock %}

{% block body %}
<table>
    <h1>歡迎登陸：{{ session.get('user') }}</h1>
    <ul>
        {% for row in user_list %}
        <li>{{ row }}</li>
        {% endfor %}
    </ul>
</table>
{% endblock %}
index.html 
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>{% block title %}{% endblock %}</title>
    <!-- <link rel="stylesheet" href="/static/css/commons.css" /> -->
    <link rel="stylesheet" href="{{ url_for('static',filename='css/commons.css') }}" />

    {% block css %}{% endblock %}
</head>
<body>
    <div class="pg-header"></div>
    <div class="pg-body">
        {% block body %}{% endblock %}
    </div>

    {% block js %}{% endblock %}
</body>
</html>
layout.html(基板) 
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<form method="post">
    <input type="text" name="user">
    <input type="text" name="pwd">
    <input type="submit" value="提交">
</form>
</body>
</html>
login.html

 

 

附：

alembic==0.9.6
blinker==1.4
certifi==2017.11.5
chardet==3.0.4
click==6.7
DBUtils==1.2
docopt==0.6.2
Flask==0.12.2
Flask-Migrate==2.1.1
Flask-Script==2.0.6
Flask-Session==0.3.1
Flask-SQLAlchemy==2.3.2
idna==2.6
itsdangerous==0.24
Jinja2==2.10
Mako==1.0.7
MarkupSafe==1.0
pipreqs==0.4.9
PyMySQL==0.8.0
python-dateutil==2.6.1
python-editor==1.0.3
PyTyrion==1.0.1
requests==2.18.4
six==1.11.0
SQLAlchemy==1.2.0
urllib3==1.22
Werkzeug==0.14.1
WTForms==2.1
xlrd==1.1.0
yarg==0.1.9
requirement.txt 
#!/usr/bin/env python
# -*- coding:utf-8 -*-
from flask import request, session,redirect


# 登陸成功時 _request_ctx_stack.top.user = user


class Auth(object):
    def __init__(self, app=None):
        self.app = app
        if app:
            self.init_app(app)

    def init_app(self, app):
        app.auth_manager = self

        app.before_request(self.check_login)
        app.context_processor(self.auth_context_processor)

    def auth_context_processor(self):
        name = session.get('user')
        return dict(current_user=name)

    def check_login(self):
        # print(request.url)
        # print(request.path)
        if request.path == '/login':
            return None

        if session.get('user'):
            return None
        return redirect('/login')

    def permission(self):
        pass

    def login(self,data):
        session['user'] = data
auth.py

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程