您好,登錄后才能下訂單哦!
在使用pymysql作為MySQL驅動時,在多線程模型下,如果我們沒有為每個線程創建一個單獨的連接的話,就會遇到下列錯誤
pymysql.err.InternalError: Packet sequence number wrong - got 0 expected 1
這是因為pymysql的threadsafety級別為 1: Threads may share the module, but not connections.
但是為每個線程創建單獨的連接的話,如果任務量比較大同時使用線程池的場景下,會造成client和MySQL server之間的頻繁“連接-登錄-退出”,這顯然是不優雅的。所以我們需要一個“連接池”,以達到client和MySQL之間只需維持較少的連接,即可完成任務的效果。
筆者實現了一個基于pymysql的連接池模塊pymysql_pool
,包含兩個類
pymysql_pool.Connection類,繼承自pymysql.connections.Connection
類,在保證使用方法一致的前提下,增加了對連接池的維護
pymysql_pool.Connection
對象。這里的pymysql_pool.Connection
對象相比pymysql.connections.Connection
對象,增加了一個屬性來標明該連接所屬的連接池,也正是通過該屬性來區分一個普通連接和一個池中的連接,進而對連接對象的close()
方法和Context Manager Protocol
進行不同的處理項目詳情請移步github
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。