PyMySQL的安裝

pip install PyMySQL

python連接數據庫

import pymysqlconn = pymysql.connect(host='localhost', user='root', password="root",database='db', port=3306, # 數字3306charset='utf8', # 不是utf-8autocommit=True # autocommit=True 讓每次提交都去調用 commit 函數 即更新事務 ) # 連接數據庫， cursor= conn.cursor(cursor=pymysql.cursors.DictCursor) # cursor=pymysql.cursors.DictCursor 表示返回結果以字典形式返回（不加為元祖形式） cursor.execute("SELECT VERSION()") # 使用 execute() 方法執行 SQL 查詢 data = cursor.fetchone() # 使用 fetchone() 方法獲取單條數據 print ("Database version : %s " % data) db.close() # 關閉數據庫連接

創建表

import pymysqldb = pymysql.connect("localhost","testuser","test123","TESTDB" ) cursor = db.cursor()# 使用 execute() 方法執行 SQL，如果表存在則刪除 cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")# 使用預處理語句創建表 sql = """CREATE TABLE EMPLOYEE (FIRST_NAME CHAR(20) NOT NULL,LAST_NAME CHAR(20),AGE INT, SEX CHAR(1),INCOME FLOAT )"""cursor.execute(sql) db.close()

增

import pymysqldb = pymysql.connect("localhost","testuser","test123","TESTDB" ) cursor = db.cursor()# SQL 插入語句 sql = "INSERT INTO EMPLOYEE(FIRST_NAME, LAST_NAME, AGE, SEX, INCOME) VALUES (%s, %s, %s, %s, %s )" % ('Mac', 'Mohan', 20, 'M', 2000) try:cursor.execute(sql) # 執行sql語句db.commit() # 提交到數據庫執行 except:db.rollback() # 如果發生錯誤則回滾db.close()# 最好不要自己拼接sql語句，會有sql注入的漏洞，使用execute（sql，參數）的方式可以防止 sql = "INSERT INTO EMPLOYEE(FIRST_NAME, LAST_NAME, AGE, SEX, INCOME) VALUES (%s, %s, %s, %s, %s )" cursor.execute(sql，('Mac', 'Mohan', 20, 'M', 2000)) # 執行sql語句

查

Python查詢 Mysql 使用 fetchone() 方法獲取單條數據, 使用 fetchall()?方法獲取多條數據。

• fetchone():?該方法獲取下一個查詢結果集。結果集是一個對象
• fetchall():?接收全部的返回結果行.
• rowcount:?這是一個只讀屬性，并返回執行execute()方法后影響的行數。

import pymysqldb = pymysql.connect("localhost","testuser","test123","TESTDB" ) cursor = db.cursor()sql = "SELECT * FROM EMPLOYEE WHERE INCOME > %s" % (1000) try:cursor.execute(sql) # 執行SQL語句results = cursor.fetchall() # 獲取所有記錄列表for row in results:fname = row[0]lname = row[1]age = row[2]sex = row[3]income = row[4]print ("fname=%s,lname=%s,age=%s,sex=%s,income=%s" % (fname, lname, age, sex, income )) except:print ("Error: unable to fetch data")db.close()

改

import pymysqldb = pymysql.connect("localhost","testuser","test123","TESTDB" ) cursor = db.cursor()sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M') try:cursor.execute(sql) # 執行SQL語句db.commit() # 提交到數據庫執行 exceptdb.rollback() # 發生錯誤時回滾db.close()

刪

import pymysqldb = pymysql.connect("localhost","testuser","test123","TESTDB" ) cursor = db.cursor()sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20) trycursor.execute(sql) # 執行SQL語句db.commit() # 提交修改 exceptdb.rollback() # 發生錯誤時回滾 db.close()

解決問題

pymysql.err.InterfaceError: (0, '')

原因：因為這個數據庫的連接建立太久了，會自動斷開，這個時候我們需要重新建立連接，否則訪問接口就會出現異常報錯了。

解決辦法：我們可以在每次操作SQL之前對連接進行檢查，如果發現連接已經斷開，則進行重連。在源碼中，如果使用了方法?ping(reconnect=True)?，那么可以在每次連接之前，會檢查當前連接是否已關閉，如果連接關閉則會重新進行連接，于是我們可以將其用于處理目前報錯的問題，改動后的代碼如下

class MYBMYSLQ(object):def __init__(self):self.conn = pymysql.connect("localhost","testuser","test123","TESTDB" ) self.cursor = self.conn.cursor(cursor=pymysql.cursors.DictCursor)def cmdb_select(self, sql, sql_arg=()):self.conn.ping(reconnect=True)self.cursor.execute(sql, sql_arg)return self.cursor.fetchall()

?

總結

以上是生活随笔為你收集整理的Python 第三方模块之 MySQL数据库连接模块 PyMySQL的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。