PyMySQL簡介：

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

Django中也可以使用PyMySQL連接MySQL數據庫。

PyMySQL 安裝：

pip install pymysql

連接數據庫：

• 你有一個MySQL數據庫，並且已經啟動。
• 你有可以連接該數據庫的用戶名和密碼
• 你有一個有權限操作的database

"""
連接數據庫進行數據操作
"""
import pymysql

# 打開數據庫連接
db = pymysql.connect(host="
 
你的數據庫地址",
                     port=3306,
                     user="用戶名",
                     passwd="密碼",
                     db="數據庫名",
                     charset="utf8")

# 查詢操作
# 使用cursor()方法創建一個遊標對象cur
cur = db.cursor()
# 使用execute()方法執行SQL查詢
sql_add = "select * from orders where type=2
 
"
cur.execute(sql_add)
# 使用fetchall()方法獲取查詢結果
data = cur.fetchall()
print(data)
# 關閉數據庫連接
db.close()
# 元祖取值
print(data[0])
print(data[0][1])
# 數據大時單獨取出對應的值
for i in data:
    if "2651" in i:
        print(i[1])

# 刪除操作
# 使用cursor()方法創建一個遊標對象cur
cur = db.cursor()
# 使用execute()方法執行SQL增刪改查操作
 

sql_delete = "delete from orders  where type=2 limit 1"
cur.execute(sql_delete)
# 刪除數據或者修改數據時一定使用db.commit()提交
db.commit()
db.close()


# 刪除功能後下次跑自動化代碼沒有數據報錯，解決辦法
# 得到一個可以執行SQL語句的光標對象
cursor = db.cursor()

# 方法一：
# 修改數據的SQL語句
sql = "UPDATE USER1 SET age=%s WHERE name=%s;"
username = "Alex"
age = 80
try:
    # 執行SQL語句
    cursor.execute(sql, [age, username])
    # 提交事務
    db.commit()
except Exception as e:
    # 有異常，回滾事務
    db.rollback()
cursor.close()
db.close()

# 方法二：
def insert_db(sql_insert):
    # 使用cursor()方法創建一個遊標對象cur
    cur = db.cursor()
    # 判斷數據是否存在
    try:
        cur.execute(sql_insert)
        # 提交
        db.commit()
    except Exception as e:
        print("錯誤信息:%s" % str(e))
        # 錯誤回滾
        db.rollback()
    finally:
        db.close()
if __name__ == ‘__main__‘:
    sql_add = "insert student(id,name,age) values (10022,‘張三‘,20)"
    insert_db(sql_add)

python--連接數據庫pymysql