Python3 - MySQL適配器 PyMySQL

本文咱們爲你們介紹 Python3 使用 PyMySQL 鏈接數據庫，並實現簡單的增刪改查。

什麼是 PyMySQL？

PyMySQL 是在 Python3.x 版本中用於鏈接 MySQL 服務器的一個庫，Python2中則使用mysqldb。

PyMySQL 遵循 Python 數據庫 API v2.0 規範，幷包含了 pure-Python MySQL 客戶端庫。

PyMySQL 安裝

在使用 PyMySQL 以前，咱們須要確保 PyMySQL 已安裝。

PyMySQL 下載地址：https://github.com/PyMySQL/PyMySQL。

若是還未安裝，咱們能夠使用如下命令安裝最新版的 PyMySQL：

$ pip install PyMySQL

若是你的系統不支持 pip 命令，能夠使用如下方式安裝：

一、使用 git 命令下載安裝包安裝(你也能夠手動下載)：

$ git clone https://github.com/PyMySQL/PyMySQL $ cd PyMySQL/ $ python3 setup.py install

二、數據庫操做實例，直接上代碼。

 

import pymysql
import datainfo
import time

#獲取參數

host = datainfo.host
username = datainfo.username
password = datainfo.password
database = datainfo.db

print()

#測試數據庫鏈接
def testconnect():

    #打開數據庫連接 按照以下 順序寫，端口和字符 根據須要填寫，端口默認爲3306
    # db = pymysql.connect(self.host,self.username,self.password,self.database,[self.port,charset='utf8'])

    db = pymysql.connect(host,username,password,database)

    #使用cursor() 方法建立一個遊標對象 cursor

    cursor = db.cursor()

    #使用execute()方法執行SQL查詢

    cursor.execute("select version()")

    #使用fetchone ()獲取單條數據

    data = cursor.fetchone()

    print(data)

    db.close()

#插入數據庫
def InsertDate():
    #打開數據庫連接

    db = pymysql.connect(host,username,password,database,charset='utf8')

    #使用cursor() 方法建立一個遊標對象 cursor

    cursor = db.cursor()

    create_time = time.strftime('%Y-%m-%d %H:%M:%S')
    update_time = time.strftime('%Y-%m-%d %H:%M:%S')
    start_time = time.strftime('%Y-%m-%d %H:%M:%S')
    end_time = time.strftime('%Y-%m-%d %H:%M:%S')
    remark = "測試插入信息"
    print("開始")
    #Sql 插入語句
    sql = "insert into demo(start_time,end_time,creat_time,update_time,remark) " \
          "VALUES ('%s','%s','%s','%s','%s')"\
          %(start_time,end_time,create_time,update_time,remark)
    try:
        #執行sql
        print("執行插入")
        tt = cursor.execute(sql)
        print(tt)
        db.commit()
    except UnicodeEncodeError as e :
        #發生錯誤時回滾
        print(e)
        db.rollback()
    db.close()


#查詢操做
def selectData():
    db = pymysql.connect(host, username, password, database, charset='utf8')

    # 使用cursor() 方法建立一個遊標對象 cursor

    cursor = db.cursor()

    sql = "select * from demo where id >='%d'" %(1)
    try:
        #執行sql
        print("執行查詢")
        cursor.execute(sql)
        results = cursor.fetchall()
        for row in results:
            id = row[0]
            start_time = row[1]
            end_time = row[2]
            create_time = row[3]
            update_time = row[4]
            remark = row[5]
            #打印結果
            print("id = %d,start_time=%s,end_time=%s,create_time=%s,update_time=%s,remark=%s" %(id,start_time,end_time,create_time,update_time,remark))

        db.commit()
    except UnicodeEncodeError as e :
        #發生錯誤時回滾
        print(e)

    db.close()

#更新操做
def update_data():
    db = pymysql.connect(host, username, password, database, charset='utf8')

    # 使用cursor() 方法建立一個遊標對象 cursor

    cursor = db.cursor()
    update_time = time.strftime('%Y-%m-%d %H:%M:%S')
    sql = "update demo set update_time ='%s' where id >='%d' " %(update_time,1)
    try:
        #執行sql
        print("執行更新")
        cursor.execute(sql)

        db.commit()
    except UnicodeEncodeError as e :
        #發生錯誤時回滾
        print(e)
        db.rollback()
    db.close()

#刪除操做
def delete_Date():
    db = pymysql.connect(host, username, password, database, charset='utf8')

    # 使用cursor() 方法建立一個遊標對象 cursor

    cursor = db.cursor()

    sql = "delete from demo where id <'%d' " %(1)
    try:
        #執行sql
        print("執行刪除")
        cursor.execute(sql)

        db.commit()
    except UnicodeEncodeError as e :
        #發生錯誤時回滾
        print(e)
        db.rollback()
    db.close()



if __name__ == '__main__':
    testconnect()
    InsertDate()
    selectData()
    update_data()
    delete_Date()