Python【pymysql】模塊

import pymysql
# 一、連上數據庫 帳號、密碼 ip 端口號 數據庫
#二、創建遊標
#三、執行sql
#4 、獲取結果
# 五、關閉遊標
#六、鏈接關閉
coon = pymysql.connect(
 host='127.0.0.1',user='jxz',passwd='123456',
 port=3306,db='jxz',charset='utf8'
 #port必須寫int類型，
 #charset這裏必須寫utf8,不能寫utf-8,寫utf-8會報錯
 #寫成username是錯誤的,必須寫成user
)
cur = coon.cursor() #創建遊標
# cur.execute('select * from stu;')#執行sql語句
cur.execute('insert into stu (id,name,sex) VALUE (1,"牛寒陽","女");')
# delete update insert必須commit,select不須要commit
coon.commit() #必須得commit
res = cur.fetchall() #獲取全部返回的結果
print(res)
cur.close()#關閉遊標
coon.close()#關閉鏈接

print("================分隔代碼塊=============")
#https://www.cnblogs.com/tkqasn/p/6001134.html
def my_db(host,user,passwd,db,sql,port=3306,charset='utf8'):
 import pymysql
 coon = pymysql.connect(user=user,
 host=host,
 port=port,
 passwd=passwd,
 db=db,
 charset=charset
 )
 cur = coon.cursor() #創建遊標
 cur.execute(sql)#執行sql
 if sql.strip()[:6].upper()=='SELECT':
 res = cur.fetchall() #返回的結果是一個二維元組
 else:
 coon.commit()
 res = 'ok'
 cur.close()
 coon.close()
 return res