全棧開發一條龍——前端篇
第一篇:框架確定、ide設置與項目創建
第二篇:介紹項目文件意義、組件結構與導入以及setup的引入。
第三篇:setup語法,設置響應式數據。
第四篇:數據綁定、計算屬性和watch監視
第五篇 : 組件間通信及知識補充
第六篇:生命周期和自定義hooks
第七篇:路由
第八篇:傳參
第九篇:插槽,常用api和全局api。
全棧開發一條龍——后端篇
第一篇:初識Flask&MySQL實現前后端通信
本文將繼續講述sql操作、發送http請求和郵件發送。
文章目錄
- 一、sql數據庫操作
- 1.添加數據
- 2.修改數據
- 3.刪除數據
- 二、模式請求
- 三、類視圖
- 四、郵件發送
一、sql數據庫操作
數據庫只有查找操作是可以用老版寫法的,在上一篇我們已經說過了,接下來介紹一些別的操作。
1.添加數據
按老版本這么寫:
db.session.execute( "insert into user (email,password,name) values('1177@hotmail.com','Aa123456','DJTrump' ) " )
報錯,把bug修了
db.session.execute( text("insert into user (email,password,name) values('1177@hotmail.com','Aa123456','DJTrump') ") )
不報錯,但不添加至數據庫
注:如果一定要用老版本,請把每一個元素都寫全,不然添加不成功。使用我下面的方法,可以缺省自增變量。
同時請注意,用老方法也別忘了commit,不然只是緩存。
新版要這么寫:
class user_add(db.Model):__tablename__ = 'user'id = db.Column(db.Integer, primary_key=True, autoincrement=True)email = db.Column( db.String(150) )password = db.Column( db.String(150) )name = db.Column( db.String(45) )
# 添加數據
usr_add = user_add()
usr_add.email = "1177@hotmail.com"
usr_add.name = "DJTrump"
usr_add.password = "Aa123456"
db.session.add(usr_add)
db.session.commit()
就添加成功了。我們把他封裝起來,并寫一個路由。
@app.route('/add')
def user_add(em,na,ps,id):# 添加數據usr_add = user()usr_add.email = emusr_add.name = nausr_add.password = psusr_add.id = iddb.session.add(usr_add)db.session.commit()
2.修改數據
我們先用filter找到我們要修改什么數據,然后修改,最后提交。
@app.route('/edit')
def user_edit():changei = user.query.filter(user.id=="1").first()changei.email = "114514@123.com"db.session.commit()
調用這個方法發現是可以修改成功的。
其中.first表示找到的第一個,也可以是all等參數,由于我們這里的id是唯一參數,所以必定只能找到一個,怎么寫都可以了。
3.刪除數據
與修改數據類似。
@app.route('/delete')
def user_delete():delete_user = user.query.filter(user.id=="2").first()db.session.delete(delete_user)db.session.commit()
至此完整代碼如下:
from flask import Flask,jsonify,request
from flask_cors import CORS
from sqlalchemy import text
from dataset_info import *app = Flask(__name__)
app.config["JSON_AS_ASCII"] = False#導入數據庫
from data import db
URI = "mysql://" + mysql_account + ":" + mysql_password + "@" + mysql_host + ":" + mysql_port + "/" + mysql_data_col
app.config["SQLALCHEMY_DATABASE_URI"] = URI
app.config["SQLALCHEMY_COMMIT_ON_TEARDOWN"] = True
#初始化操作
db.init_app(app)CORS(app,cors_allowed_orgins = "*")def list_row2list_dic(list_row): dic_temp = {}list_dic = []for x in list_row:listda = []listidx= []for dx in x: listda.append(dx)xx = x._key_to_index for idx in xx:listidx.append(idx)dic_temp=dict(zip(listidx,listda))list_dic.append(dic_temp)return list_dic
class user(db.Model):__tablename__ = 'user'id = db.Column(db.Integer, primary_key=True, autoincrement=True)email = db.Column( db.String(150) )password = db.Column( db.String(150) )name = db.Column( db.String(45) )@app.route('/add')
def user_add(email,name,password,id):# 添加數據usr_add = user()usr_add.email = emailusr_add.name = nameusr_add.password = passwordusr_add.id = iddb.session.add(usr_add)db.session.commit()@app.route('/edit')
def user_edit():changei = user.query.filter(user.id=="1").first()changei.email = "114514@123.com"db.session.commit()@app.route('/delete')
def user_delete():delete_user = user.query.filter(user.id=="2").first()db.session.delete(delete_user)db.session.commit()@app.route('/', methods=['GET'])
def index():res = {"msg" : "你好,這里是后端入口"}#url傳參 獲取id參數,默認為noneid = request.args.get("id",None)print("id:"+id)raw_userlist = db.session.execute( text("select * from user") ).fetchall()userlist = list_row2list_dic(raw_userlist)d2js={"data":userlist}return jsonify(d2js)#啟動flaskif __name__ == "__main__":#調試模式 這樣每次修改代碼不用每次重啟服務app.run(debug=True, host = "0.0.0.0",port = 5000)# app.run(debug=True)
配置可以專門寫一個文件,防止以后改的時候到處找
mysql_account = "root"
mysql_password = "xxxxx"
mysql_host = "localhost"
mysql_port = "3306"
mysql_data_col = "test_data"
二、模式請求
我們之前說過get的請求模式,我們現在來試試post的請求。一般我們用post來提交數據、表單等,返回值一般為是否提交成功。post的接參數的方法與put一致,用form。delete和get用args接收參數,其他寫法幾乎一致,我們這里拿post舉例。其他只要form換args就行了,就不寫了。
manage:
# 測試post
@app.route('/insert/', methods=['POST'])
def test_post():#post和get用form接收參數email = request.form.get("email",None)id = request.form.get("id",None)name = request.form.get("name",None)password = request.form.get("password",None)user_add(email=email,id=id,name=name,password=password)return jsonify( {"errorcode":0,"msg":"插入成功"} )
test:
def test_post(self,url,data={}):res = requests.post(url=url,data=data)return res.textres = httpapi.test_post("http://localhost:5000/insert/",data={"id":123,"name":"123","email":"123","password":"123"})res = res.encode('utf-8').decode('unicode_escape')print(res)
運行后我們可以發現數據庫中確實加入了數據,具體怎么寫的應該很容易理解,看代碼即可。
三、類視圖
到此為止,我們的方法已經很多了,我們需要用更好的封裝方式來管理我們的方法。
我們可以請求函數寫成類,然后可以寫get,post等幾個不同的功能,這樣就可以一個接口多個功能,而且還能繼承,非常方便。
四、郵件發送
掌握了數據庫和數據傳輸之后,我們如果想做最基礎的登錄注冊,還需要學會郵箱驗證。
打開你的郵箱,找到設置,我的是163郵箱
把這個服務打開,然后會跳出一長串大寫字母的授權碼,請記錄下來。
接下來進入代碼階段:
我們先在social文件夾中在建立一個文件:mail_send.py文件,用于封裝發送郵件。
我們先導入庫,這些庫應該都是python自帶的。
import smtplib
#導入文本庫
from email.mime.text import MIMEText
#導入郵件分類
from email.mime.multipart import MIMEMultipart
然后寫發送郵件的業務類
class send_email:def __init__(self):self.sender_mail = "你的賬號"self.password = "你的授權碼"def send_mail(self,dest_mail,title,content):mail = MIMEMultipart()#設置標題mail["Subject"] = title#發送者mail["From"] = self.sender_mail#收件人mail["to"] = dest_mail#寫內容part = MIMEText(content,"html","utf-8")#把內容填進去mail.attach(part)s = smtplib.SMTP_SSL("smtp.163.com",465) s.login(self.sender_mail , self.password )s.sendmail(self.sender_mail , dest_mail , mail.as_string() )s.close()
注釋寫的非常清楚,代碼的理解請看注釋,唯一要說的是 s = smtplib.SMTP_SSL("smtp.163.com",465)
這是在定義stmp協議類,前面的請輸入你的郵箱的運營商的stmp,我是163郵箱,如果你是qq郵箱,就把163換成qq。后一個參數是port端口號,stmp協議的默認端口號是465.
最后寫一個測試代碼
sendemail = send_email()
sendemail.send_mail(dest_mail="你想發給的人",title="測試標題",content="測試文件內容")
就發送成功啦~