建站
咨詢
售后
建站咨詢
新聞中心
SanicDB 是為 Python的異步 Web 框架 Sanic 方便操作MySQL而開(kāi)發(fā)的工具，是對(duì) aiomysql.Pool 的輕量級(jí)封裝。Sanic 是異步IO的Web框架，同時(shí)用異步IO讀寫(xiě)MySQL才能更大發(fā)揮它的效率。雖然這個(gè)模塊叫做 SanicDB，但是它可以用在任何異步IO操作MySQL的地方。
創(chuàng)新互聯(lián)-專業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性價(jià)比婺城網(wǎng)站開(kāi)發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫(kù),直接使用。一站式婺城網(wǎng)站制作公司更省心,省錢,快速模板網(wǎng)站建設(shè)找我們，業(yè)務(wù)覆蓋婺城地區(qū)。費(fèi)用合理售后完善，十載實(shí)體公司更值得信賴。
SanicDB的靈感來(lái)源于tornado里面的對(duì)MySQLdb（MySQL的C語(yǔ)言接口的Python封裝）的操作，后來(lái)tornado把它去除了，就有人把這部分代碼寫(xiě)成一個(gè)單獨(dú)的模塊叫做 torndb，torndb是對(duì)python-mysql的封裝，不能進(jìn)行異步操作。但是它很簡(jiǎn)潔，用起來(lái)已經(jīng)非常習(xí)慣了。
在用Sanic的時(shí)候，發(fā)現(xiàn)有異步IO的aiomysql可以用，但是用起來(lái)還有點(diǎn)麻煩，于是就著手對(duì)aiomysql進(jìn)行封裝，既然aiomysql支持連接池，那就直接封裝aiomysql.Pool吧。
代碼倉(cāng)庫(kù)： https://github.com/veelion/sanicdb
首先，看看它的初始化
class SanicDB:"""A lightweight wrapper around aiomysql.Pool for easy to use """def __init__(self, host, database, user, password, loop=None, sanic=None, minsize=3, maxsize=5, return_dict=True, pool_recycle=7*3600, autocommit=True, charset = "utf8mb4", **kwargs):'''
前面4個(gè)參數(shù)是對(duì)應(yīng)數(shù)據(jù)庫(kù)的；
loop 是你的應(yīng)用程序中的事件循環(huán)（event_loop）；
sanic 是你的Sanic 應(yīng)用中的sanic 對(duì)象；
loop 和 sanic 兩者只需提供一個(gè)即可，當(dāng)同時(shí)存在時(shí)，連接數(shù)據(jù)庫(kù)其實(shí)用的是sanic里面的loop， 這在__init__()代碼中可以看到。
minisize 和 maxsize 是連接池的個(gè)數(shù)限制；
return_dict 是返回的數(shù)據(jù)一條記錄為一個(gè)dict，key是MySQL表的字段名，value是字段的值；
pool_recycle 是連接池重連的時(shí)間間隔，MySQL默認(rèn)的連接閑置時(shí)間是8小時(shí)；
對(duì)MySQL的讀寫(xiě)操作方法：
async def query(self, query, *parameters, **kwparameters):
async def execute(self, query, *parameters, **kwparameters):
async def get(self, query, *parameters, **kwparameters):
從代碼中可以看到，以上三個(gè)函數(shù)都是調(diào)用的cursor的execute() 執(zhí)行 SQL 命令，但是query(), get() 用于讀操作返回?cái)?shù)據(jù)，query返回全部數(shù)據(jù)（list），get只返回一條數(shù)據(jù)。
execute() 方法用來(lái)執(zhí)行寫(xiě)操作，返回受影響的行ID。
上面三個(gè)函數(shù)都是一樣的：
query 是要執(zhí)行的SQL語(yǔ)句， 后面兩個(gè)參數(shù)是用來(lái)參數(shù)化執(zhí)行sql語(yǔ)句的。參數(shù)化執(zhí)行sql是為了防止SQL注入的，那么參數(shù)化執(zhí)行SQL是什么意思呢，舉個(gè)例子就目標(biāo)了。
比如，進(jìn)行用戶登錄時(shí)，我們要執(zhí)行一條SQL，Python拼接SQL如下：
sql = "select * from user where name='%s' and password='%s'" % (input_name, input_password)
input_name 和 input_password 都是用戶輸入的，如果用戶想搗鬼，他把input_name 輸入成 “ ‘ or 1 = 1 –”，拼接出來(lái)的sql就成了：
select * from user where name='' or 1 = 1 --' and password='anything'
or 后面的 1=1 就是True，而 — 后面都成了注釋，這條語(yǔ)句不管input_name, input_password 是什么都可以執(zhí)行，通過(guò)用戶驗(yàn)證，達(dá)到了注入目的。
參數(shù)化執(zhí)行SQL就是把拼接SQL的任務(wù)交給SanicDB（實(shí)際上是它后的aiomysql后面的pymysql），我們只把要拼接的參數(shù)當(dāng)做*parameters傳給讀寫(xiě)方法即可：
mydb.query("select * from user where user=%s and password=%s", input_name, input_password)
更高級(jí)的封裝：
query(), get(), execute() 就是基本的操作，在此基礎(chǔ)上，做了進(jìn)一步封裝，讓寫(xiě)應(yīng)用更方便：
# 檢查一個(gè)table中是否含有某字段為某值的記錄async def table_has(self, table_name, field, value): # 把一個(gè)item插入一個(gè)表，item為dict，key是字段名，# ignore_duplicated為True時(shí)，遇到唯一索引重復(fù)時(shí)不報(bào)錯(cuò)async def table_insert(self, table_name, item, ignore_duplicated=True): # 更新一個(gè)table的記錄，updates是dict，key為字段名async def table_update(self, table_name, updates, field_where, value_where):
示例
代碼倉(cāng)庫(kù)中有兩個(gè)示例：
test.py 是在普通asyncio程序中使用異步MySQL的例子
example.py 是在Sanic Web中使用的例子
特別說(shuō)明一下，Sanic 對(duì)象 app 中還沒(méi)有生成 event_loop 對(duì)象（它是在app.run() 之后生成的），所以在Sanic中初始化SanicDB時(shí)（app.run()）之前，運(yùn)行sql語(yǔ)句會(huì)報(bào)錯(cuò)。如果需要?jiǎng)?chuàng)建連接后初始化運(yùn)行一些SQL操作，可以利用Sanic的Listner：
@app.listener('before_server_start')async def setup_db(app, loop):
app.db = await db_setup()
文章首發(fā)于我的個(gè)人博客，同時(shí)我也在
猿人學(xué)網(wǎng)站
上寫(xiě)Python教程
你也可以關(guān)注我的個(gè)人公眾號(hào)：猿人學(xué)Python
網(wǎng)站欄目：簡(jiǎn)單介紹我的開(kāi)源小工具：SanicDB
鏈接分享：http://www.ef60e0e.cn/article/jgdhdo.html
