python3使用pymysql模塊，連接mysql數據庫，實現新增、查詢和更新操作

1、環境數據准備：

python3環境、pymysql模塊

mysql數據庫：本次代碼中用到的數據庫為本地的testdb數據庫，user表(表字段比較簡單，只有主鍵id，手機號mobile，密碼passwd)

2、本次代碼直接封裝為類，代碼中附有注釋，把數據庫參數改為自己實際的就可以直接使用

 

#引入pymysql模塊
import pymysql

class DoMysql:
    #初始化
    def __init__(self):
        #創建連接
        self.conn = pymysql.Connect(
          host = 'localhost',
          port = 3306,
          user = 'root',
          password = 'root',
          db = 'testdb',
          charset = 'utf8',
          cursorclass = pymysql.cursors.DictCursor  #以字典的形式返回數據
        )
        #獲取游標
        self.cursor = self.conn.cursor()

    #返回多條數據
    def fetchAll(self,sql):
        self.cursor.execute(sql)
        return self.cursor.fetchall()

    #插入一條數據
    def insert_one(self,sql):
        result = self.cursor.execute(sql)
        self.conn.commit()
        return result

    #插入多條數據
    def insert_many(self,sql,datas):
        result = self.cursor.executemany(sql,datas)
        self.conn.commit()
        return result

    #更新數據
    def update(self,sql):
        result = self.cursor.execute(sql)
        self.conn.commit()
        return result

    #關閉連接
    def close(self):
        self.cursor.close()
        self.conn.close()




if __name__ == '__main__':
    mysql  = DoMysql()
    #插入一條數據
    sql = 'insert into `user`(`mobile`,`passwd`) values("13100010000","123456")'
    result = mysql.insert_one(sql)
    print(result) #返回插入數據的條數(1)

    #插入多條數據
    datas = [
        ("13100010001","111111"),
        ("13100010002","666666")
    ]
    sql = 'insert into `user`(`mobile`,`passwd`) values(%s,%s)'
    result = mysql.insert_many(sql,datas)
    print(result) #返回插入數據的條數(2)

    #查詢數據
    sql = 'select * from user'
    result = mysql.fetchAll(sql) #返回列表,如果多條數據，列表中嵌套字典
    for item in result:
        print(item.get('mobile')) #循環列表，輸出mobile值

    #關閉連接
    mysql.close()

 

3、擴展信息

pymysql.Connect()參數說明
host(str): MySQL服務器地址
port(int): MySQL服務器端口號
user(str): 用戶名
passwd(str): 密碼
db(str): 數據庫名稱
charset(str): 連接編碼

connection對象支持的方法
cursor() 使用該連接創建並返回游標
commit() 提交當前事務
rollback() 回滾當前事務
close() 關閉連接

cursor對象支持的方法
execute(op) 執行一個數據庫的查詢命令
fetchone() 取得結果集的下一行
fetchmany(size) 獲取結果集的下幾行
fetchall() 獲取結果集中的所有行
rowcount() 返回數據條數或影響行數
close() 關閉游標對象