今天小編給大家分享一下PyMySQL怎么使用的相關知識點,內容詳細,邏輯清晰,相信大部分人都還太了解這方面的知識,所以分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后有所收獲,下面我們一起來了解一下吧。
我們在使用MySQL的時候,可以在MySQL的客戶終端來操作數據庫中的表,同時,也可以使用navicat等可視化的工具來操作數據表。但是,這只是操作個別數據,如果我們想要插入10萬條數據,那肯定就不能這么做了。我們可以通過程序寫一個循環來自動插入,因此,PyMySQL就是使用python語言來直接操作數據庫的一個接口。
1 查詢數據庫中的表的信息:
# 需求:查詢數據庫person中info表的信息 # 1.導包 import pymysql try: # 2.連接MySQL數據庫的服務 connc = pymysql.Connect( user="root", # The first four arguments is based on DB-API 2.0 recommendation. password="4412", host='127.0.0.1', # mysql服務端的IP,默認是127.0.0.1/localhost,或者寫真實的ip database='person', port=3306, charset="utf8") # 3.創建游標對象 cur = connc.cursor() # 4.編寫SQL語句 sql = 'select * from info;' # 5.使用游標對象調用SQL cur.execute(sql) # 6.獲取查詢的結果 result= cur.fetchall() print(result) # 7.關閉游標對象 cur.close() # 8.關閉連接 connc.close() except Exception as e: print(e)
2 增加數據:
大部分的步驟都和前面一樣,直接在程序中注釋看:
# 需求:
# 增加數據 劉德華56 男 數據 到 數據庫person--的info表中
# 修改數據 小王 的名字為 小王吧 到 數據庫person--的info表中
# 刪除數據 張三 數據庫person--的info表中
# 1.導包
import pymysql
# 2.連接MySQL服務
connc = pymysql.Connect(
user="root", # The first four arguments is based on DB-API 2.0 recommendation.
password="4412",
host='127.0.0.1', # mysql服務端的IP,默認是127.0.0.1/localhost,或者寫真實的ip
database='person',
port=3306,
charset="utf8")
# 3.創建游標對象
cur = connc.cursor()
try:
# 4.編寫、增加、刪除的SQL語句
# 增加數據 劉德華 56 男
sql = 'insert into info values(%s, %s, %s, %s)'
add_data = [0,"劉德華", 56, "男"]
# 5.使用游標對象執行SQL語句
cur.execute(sql, add_data)
# 6.提交操作
connc.commit()
except Exception as e:
print(e)
# 操作失敗,數據回滾
connc.rollback()
finally:
# 7.關閉游標對象
cur.close()
# 8.關閉連接
connc.close()
print("結束!")3 修改數據:
# 需求:
# 增加數據 劉德華56 男 數據 到 數據庫person--的info表中
# 修改數據 小王 的名字為 小王吧 到 數據庫person--的info表中
# 刪除數據 張三 數據庫person--的info表中
# 1.導包
import pymysql
# 2.連接MySQL服務
connc = pymysql.Connect(
user="root", # The first four arguments is based on DB-API 2.0 recommendation.
password="4412",
host='127.0.0.1', # mysql服務端的IP,默認是127.0.0.1/localhost,或者寫真實的ip
database='person',
port=3306,
charset="utf8")
# 3.創建游標對象
cur = connc.cursor()
try:
# 4.編寫、增加、刪除的SQL語句
# 修改數據 李四 的名字為 李四的爸爸
sql = 'update info set name=%s where name="李四"'
update_data = ["李四的爸爸"]
# 5.使用游標對象執行SQL語句
cur.execute(sql, update_data)
# 6.提交操作
connc.commit()
except Exception as e:
print(e)
# 操作失敗,數據回滾
connc.rollback()
finally:
# 7.關閉游標對象
cur.close()
# 8.關閉連接
connc.close()
print("結束!")4 刪除數據:
# 需求:
# 增加數據 劉德華56 男 數據 到 數據庫person--的info表中
# 修改數據 小王 的名字為 小王吧 到 數據庫person--的info表中
# 刪除數據 張三 數據庫person--的info表中
# 1.導包
import pymysql
# 2.連接MySQL服務
connc = pymysql.Connect(
user="root", # The first four arguments is based on DB-API 2.0 recommendation.
password="4412",
host='127.0.0.1', # mysql服務端的IP,默認是127.0.0.1/localhost,或者寫真實的ip
database='person',
port=3306,
charset="utf8")
# 3.創建游標對象
cur = connc.cursor()
try:
# 4.編寫、增加、刪除的SQL語句
# 修改數據 李四 的名字為 李四的爸爸
sql = 'update info set name=%s where name="李四"'
update_data = ["李四的爸爸"]
# 5.使用游標對象執行SQL語句
cur.execute(sql, update_data)
# 6.提交操作
connc.commit()
except Exception as e:
print(e)
# 操作失敗,數據回滾
connc.rollback()
finally:
# 7.關閉游標對象
cur.close()
# 8.關閉連接
connc.close()
print("結束!")以上就是“PyMySQL怎么使用”這篇文章的所有內容,感謝各位的閱讀!相信大家閱讀完這篇文章都有很大的收獲,小編每天都會為大家更新不同的知識,如果還想學習更多的知識,請關注億速云行業資訊頻道。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。