Python 操作 MySQL 資料庫

使用示例：

import pymysql  #python3
conn=pymysql.connect(host="localhost",port=3306,user="root",password="abcd",database="bank",charset="utf8")  #字元集不是必須的
cursor = conn.cursor()
sql="select * from user_info"
result=cursor.execute(sql)   #不論增刪查改，result都是受影響的記錄數，int型
for row in cursor:   #遍歷結果集
    print(row)  #輸出一條記錄，元組形式
    print(row[0])  #輸出記錄中的某個欄位
cursor.close()
conn.close()

提取一條記錄：

import pymysql  #python3
conn=pymysql.connect(host="localhost",user="root",password="abcd",database="bank",charset="utf8")  #字元集不是必須的
cursor = conn.cursor()
sql="select * from user_info"
result=cursor.execute(sql)
print(cursor.fetchone())  #提取並返回一條記錄，指針會自動後移。最初指針指向第一條之前。第一條
print(cursor.fetchone())  #第二條。元組形式。
print(cursor.fetchone()[0])  #一個欄位，不能使用欄位名，只能使用索引
cursor.close()
conn.close()

提取多條記錄：

import pymysql  #python3
conn=pymysql.connect(host="localhost",user="root",password="abcd",database="bank",charset="utf8")  #字元集不是必須的
cursor = conn.cursor()
sql="select * from user_info"
result=cursor.execute(sql)
print(cursor.fetchmany(2))   #提取指定的條數，指針會自動後移。只要是提取，指針都會自動後移。
for row in cursor:  #cursor中是從第三行開始的記錄
    print(row)
#fetchmany()返回值是嵌套的元組形式。  ((1, 'chy', 200.0), (2, 'zhangsan', 200.0))。一個元素即一條記錄。
#fetchall()是提取結果集的所有記錄
#cursor存放結果集，提取就是把一些記錄從cursor中提取出來（從cursor中拿出來，cursor中不再有這些記錄了）
cursor.close()
conn.close()

設置sql語句參數：

import pymysql  #python3
conn=pymysql.connect(host="localhost",user="root",password="abcd",database="bank",charset="utf8")  #字元集不是必須的
cursor = conn.cursor()
id=1
name="chy"
# sql="select * from user_info where id=%d and name='%s'"%(id,name)   #如果是字元串，%s要加引號
sql="select * from user_info where id={} and name='{}'".format(id,name)  #如果是字元串，{}也要加引號
result=cursor.execute(sql)
print(cursor.fetchall())   #提取結果集中所有的記錄數
cursor.close()
conn.close()

插入一條記錄：

import pymysql  #python3
conn=pymysql.connect(host="localhost",user="root",password="abcd",database="bank",charset="utf8")  #字元集不是必須的
cursor = conn.cursor()
id=3
name="wangwu"
money=100
sql="insert into user_info (id,name,money) values (%d,'%s',%d)"%(id,name,money)  #如果是字元串，占位的要加引號
result=cursor.execute(sql)  #增刪查改都是execute
print(result)  #1   搜相應的記錄數
print(cursor.fetchall())  #不會報錯，空元組
conn.commit()  #需要提交才會同步到資料庫。缺少此句代碼，不會同步到資料庫。
cursor.close()
conn.close()

增刪改的操作類似，註意增刪改都需要conn.commit()才會提交到資料庫。

另一種設置參數的方式：

import pymysql  #python3
conn=pymysql.connect(host="localhost",user="root",password="abcd",database="bank",charset="utf8")
cursor = conn.cursor()
sql="insert into user_info (id,name,money) values (%s,%s,%s)"  #如果是在execute()中註入數據，不管是什麼類型，都必須寫成%s，且不能加引號
result=cursor.execute(sql,(5,"name",10))  #在execute()中註入數據。在這裡區分數據類型。使用元組、列表均可
#result=cursor.execute(sql,[5,"name",10]) 
conn.commit()
cursor.close()
conn.close()

批量操作：

import pymysql  #python3
conn=pymysql.connect(host="localhost",user="root",password="abcd",database="bank",charset="utf8")
cursor = conn.cursor()
sql="insert into user_info (id,name,money) values (%s,%s,%s)" #如果是在execute()中註入數據，不管是什麼類型，都必須寫成%s，且不能加引號
data=((17,"chy",90),(18,"chy",99))  #至少2個元素，使用嵌套的元組、列表均可
#data=[[17,"chy",90],[18,"chy",99]]
try:
    result=cursor.executemany(sql,data)  #批量操作，註入嵌套的元組。註意是executemany()，且必須是嵌套的元組，元組中至少要有2個元組（記錄），只有一條會出錯。
    conn.commit()   #executemany()是執行2條及以上的操作，所以至少2個元素
except Exception as e:
    print(e)
    conn.rollback()  #失敗就回滾
cursor.close()
conn.close()