逐步完善中……

本篇記錄連線mysql，並執行sql語句，可以參考https://www.runoob.com/python3/python3-mysql.html

目錄

1、安裝連線mysql的模組

2、瞭解模組中的常用方法以及使用

1、安裝連線mysql模組

使用pip完成模組的安裝，執行pip3 install PyMySQL：

安裝安裝後，可以看到模組是可以正常匯入的

2、瞭解模組中的常用方法以及使用

第一步：使用該模組連線mysql

#!/usr/bin/python3
 
import pymysql
 
# 開啟資料庫連線
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

封裝：

def  Connect(mysql_info):        
        try:
            conn = MySQLdb.connect(host=db_info['host'],
            port=db_info['port'],
            user=db_info['user'],
            passwd=db_info['passwd'],
            db=db_info['db'],
            charset=db_info['charset'])
            return conn
        except Exception as a:
            print("資料庫連線異常：%s"%a)　　

傳入資料庫資訊：

mysql_info = {"host": 'localhost',
                "port": 3306,
                "user": 'root',
                "passwd": '123456',
                "db": 'aiopms',
                "charset": 'utf8'}

第二步：資料庫的查、增、刪

查：

    def mysql_getrows(self, sql):
        ''' 返回查詢結果'''
        cur = self.conn.cursor()
        try:
            cur.execute(sql)
        except Exception as a:
            print("執行 SQL 語句出現異常：%s"%a)
        else:
            rows = cur.fetchall()
            cur.close()
            return rows

增、刪：使用execute()方法執行語句

def mysql_execute(self, sql):
        #通過cursor()方法來建立遊標
        cur = self.conn.cursor()
        try:
            #execute()方法執行語句
            a=cur.execute(sql)
        except Exception as a:
            self.conn.rollback() # sql 執行異常後回滾
            print("執行 SQL 語句出現異常：%s"%a)
        else:
            cur.close()
            self.conn.commit() # sql 無異常時提交