flask项目创建

from flask import Flask

def create_app():
    app = Flask(__name__)

    @app.before_request
    def f1():
        print('f1')

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

    app.register_blueprint(account)
    app.register_blueprint(user)
    return app

from crm import create_app
app = create_app()

if __name__ == '__main__':
    app.run(port=8000)

from flask import Blueprint,url_for

# 创建了一个蓝图对象
account = Blueprint('account',__name__)

@account.before_request
def xx():
    print('xx')

@account.route('/login')
def login():
    url = url_for('account.register')
    print(url)
    return 'Login'

@account.route('/register')
def register():
    return 'register'

from flask import Blueprint

user =Blueprint('user',__name__)

@user.route('/user/list')
def user_list():
    return 'user list'

@user.route('/user/add')
def user_add():
    return 'user add'

import time
import threading


import pymysql
from DBUtils.PooledDB import PooledDB

# 创建数据库连接池
POOL = PooledDB(
    creator=pymysql,
    maxconnections=20,
    mincached=2,
    host='127.0.0.1',
    port=3306,
    user='root',
    password='123',
    database='pooldb',
    charset='utf8'
)

# 去数据库连接池获取一个连接
conn = POOL.connection()

cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor.execute('select * from tb1')
result = cursor.fetchall()


# 将此连接放还给连接池
conn.close()

import pymysql

from DBUtils.PooledDB import PooledDB

class SQLHelper(object):
    def __init__(self):
        # 创建数据库连接池
        self.pool = PooledDB(
            creator=pymysql,
            maxconnections=5,
            mincached=2,
            blocking=True,
            host='127.0.0.1',
            port=3306,
            user='root',
            password='123',
            database='s23day02',
            charset='utf8'
        )


    def connect(self):
        conn = self.pool.connection()
        cursor = conn.cursor()
        return conn,cursor


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


    def fetchone(self,sql,params=None):
        """
        获取单条
        :param sql:
        :param params:
        :return:
        """
        if not params:
            params = []
        conn,cursor = self.connect()
        cursor.execute(sql, params)
        result = cursor.fetchone()
        self.disconnect(conn,cursor)
        return result


    def fetchall(self,sql,params=None):
        """
        获取所有
        :param sql:
        :param params:
        :return:
        """
        import pymysql
        if not params:
            params = []
        conn, cursor = self.connect()
        cursor.execute(sql,params)
        result = cursor.fetchall()
        self.disconnect(conn, cursor)
        return result


    def commit(self,sql,params):
        """
        增删改
        :param sql:
        :param params:
        :return:
        """
        import pymysql
        if not params:
            params = []

        conn, cursor = self.connect()
        cursor.execute(sql, params)
        conn.commit()
        self.disconnect(conn, cursor)


db = SQLHelper()

from flask import Blueprint,url_for,request,render_template,session,redirect
from ..utils.sqlhelper import db

# 创建了一个蓝图对象
account = Blueprint('account',__name__)



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

    if request.method == 'GET':
        return render_template('login.html')
    user = request.form.get('user')
    pwd = request.form.get('pwd')

    # 根据用户名和密码去数据库进行校验
    # 连接/SQL语句/关闭
    result = db.fetchone('select * from user where username=%s and password=%s',[user,pwd])
    if result:
        # 在session中存储一个值
        session['user_info'] = user
        return redirect(url_for('user.user_list'))
    return render_template('login.html',error="用户名或密码错误")

class Base(object):
    CHARSET = 'utf8'
    PORT = 3306

class Prod(Base):
    HOST = '10.11.11.11'
    USER = 'test'
    PASSWORD = '123'
    DATABASE = 'dbtest'

class Test(Base):
    HOST = '13.16.55.89'
    USER = 'test'
    PASSWORD = '123'
    DATABASE = 'dbtest'

class Dev(Base):
    HOST = '127.0.0.1'
    USER = 'root'
    PASSWORD = '123'
    DATABASE = 's23day02'