import pymysql
#封裝的增刪改
def change_data(sql1,host='localhost',user='root',
pwd='123456',database='milor'):
'''
:param sql1: 傳入的sql語句
:param host: 數據庫host,localhost為本地服務器
:param user: 用戶名
:param pwd: 密碼
:param database: 連接的數據庫
:return: 沒有返回值
'''
# con = 將服務器地址,用戶名,密碼傳給connect方法 建立連接
con = pymysql.connect(host,user,pwd)
# cur: 創建數據庫游標對象
cur = con.cursor()
# 拼接字符串sql
sql = 'use '+database
# 執行進入數據庫sql
cur.execute(sql)
# 執行傳入的sql1命令
cur.execute(sql1) # 返回值是受影響的行數
# 提交數據
st = con.commit()
print(st)
# 關閉游標連接
cur.close()
# 關閉數據庫連接
con.close()
#封裝的查詢 注釋和上面一樣,多了個返回查詢結果(記得接收)
def select_data(sql1,host='localhost',user='root',
pwd='123456',database='milor'):
con = pymysql.connect(host,user,pwd)
cur = con.cursor()
sql = 'use '+database
cur.execute(sql)
cur.execute(sql1) # 查詢之后會將結果 封裝到游標中
data = cur.fetchall() # 取出所有數據
con.commit()
cur.close()
con.close()
return data #將數據返回給調用者
記錄一哈,方便以后自己直接復制使用