pymysql是一個Python的第三方包，需要手動安裝后才能使用

1.使用pymysql查詢數(shù)據(jù)

''' pymysql基本使用步驟 使用pymysql查詢數(shù)據(jù) '''import pymysql# 創(chuàng)建數(shù)據(jù)庫連接對象，除了端口外，其他類型都要用字符串類型 connect_db=pymysql.connect(host='localhost',port=3306,user='root',password='root',charset='utf8',database='jing_dong')# 獲取游標(biāo)對象，操作數(shù)據(jù)庫時都是使用游標(biāo)對象操作,類似與電腦寫文檔時的光標(biāo)，可以指示操作的起始位置 # 一個數(shù)據(jù)庫連接對象可以創(chuàng)建多個（多次）游標(biāo)對象，一般同一時刻只會建立一個進(jìn)行操作 # 游標(biāo)對象在創(chuàng)建時，默認(rèn)會開啟一個隱式的事務(wù)環(huán)境 cur=connect_db.cursor()# 操作數(shù)據(jù)庫 # 避免字符串引號和sql語句中的引號沖突，使用三引號 sql_str='''select * from goods'''# 執(zhí)行sql語句，會返回操作的數(shù)據(jù)行數(shù) row_count=cur.execute(sql_str) print(f'查詢到{row_count}條記錄')# 查詢數(shù)據(jù)的語句的返回值都是一個元祖，或者元祖套元祖 # 從游標(biāo)對象指示的位置開始，獲取一條查詢結(jié)果 result_one=cur.fetchone() # 返回一個元祖 print(result_one) print('*'*30)# 讓游標(biāo)回到開頭處 cur.rownumber=0# 從游標(biāo)對象指示的位置開始，獲取指定條數(shù)的記錄 result_many=cur.fetchmany(7) # 返回一個元祖類型的可迭代對象，一條數(shù)據(jù)的話是這樣的((),) for result in result_many:print(result) print('*'*30)# 讓游標(biāo)回到開頭處 cur.rownumber=0# 獲取所有數(shù)據(jù) result_all=cur.fetchall() # 返回一個元祖類型的可迭代對象，一條數(shù)據(jù)的話是這樣的((),) for result in result_all:print(result)# 關(guān)閉游標(biāo)對象 cur.close()# 關(guān)閉數(shù)據(jù)庫對象 connect_db.close()

2.使用pymysql插入數(shù)據(jù)

''' 插入數(shù)據(jù) '''import pymysql# Connect = connect = Connection = connections.Connection connect_db=pymysql.Connect(host='localhost',port=3306,database='jing_dong',user='root',password='root',charset='utf8') cur=connect_db.cursor() sql_str='''insert into goods(name,cate_id,brand_id) values('MacBookPro 15',1,5)''' t=cur.execute(sql_str) print(t) ''' 當(dāng)對數(shù)據(jù)庫做增刪改時，默認(rèn)會在事務(wù)環(huán)境中進(jìn)行操作，操作完成后要手動提交操作，否則程序默認(rèn)操作為回滾，那么剛才的操作就不會生效 但是增加數(shù)據(jù)時，即使回滾了，為主鍵的字段的auto_increment值也會加1 ''' # 事務(wù)的提交操作由數(shù)據(jù)庫連接對象來完成 # 事務(wù)的提交操作必須在執(zhí)行sql語句之后進(jìn)行 connect_db.commit()cur.close() connect_db.close()

3.使用pymysql修改數(shù)據(jù)

''' 使用pymysql更新數(shù)據(jù) '''import pymysqlconnect_db=pymysql.Connect(host='localhost',port=3306,user='root',password='root',charset='utf8',database='jing_dong') cur=connect_db.cursor() sql_str='''update goods set price=2099 where id=10''' cur.execute(sql_str) connect_db.commit() cur.close() connect_db.close()

4.使用pymysql刪除數(shù)據(jù)

''' 使用pymysql刪除數(shù)據(jù) '''import pymysqlconnect_db=pymysql.Connection(host='localhost',port=3306,user='root',password='root',charset='utf8',database='jing_dong') cur=connect_db.cursor() sql_str='''delete from goods where name='筆記本電腦17' ''' cur.execute(sql_str) connect_db.commit() cur.close() connect_db.close()

總結(jié)

以上是生活随笔為你收集整理的Python利用pymysql连接Mysql数据库的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。