怎么在python中利用PYMYSQL對MYSQL數據庫進行連接

怎么在python中利用PYMYSQL對MYSQL數據庫進行連接？相信很多沒有經驗的人對此束手無策，為此本文總結了問題出現的原因和解決方法，通過這篇文章希望你能解決這個問題。

什么是MYSQL數據庫

MySQL是一個關系型數據庫管理系統，由瑞典MySQL AB 公司開發，目前屬于 Oracle 旗下產品。MySQL 是最流行的關系型數據庫管理系統之一，在 WEB 應用方面，MySQL是最好的 RDBMS (Relational Database Management System，關系數據庫管理系統) 應用軟件之一。

什么是PYMYSQL

PyMySQL 是在 Python3.x 版本中用于連接 MySQL 服務器的一個庫，Python2中則使用mysqldb。

PyMySQL 遵循 Python 數據庫 API v2.0 規范，并包含了 pure-Python MySQL 客戶端庫。

PyMySQL安裝

pip install pymysql

PyMySQL使用

連接數據庫

1、首先導入PyMySQL模塊

2、連接數據庫（通過connect()）

3、創建一個數據庫對象 （通過cursor()）

4、進行對數據庫做增刪改查

# coding:utf-8
import pymysql
# 連接數據庫
count = pymysql.connect(
      host = 'xx.xxx.xxx.xx', # 數據庫地址
      port = 3306,  # 數據庫端口號
      user='xxxx',  # 數據庫賬號
      password='XXXX',  # 數據庫密碼
      db = 'test_sll')  # 數據庫表名# 創建數據庫對象
db = count.cursor()

查找數據

db.fetchone()獲取一條數據

db.fetchall()獲取全部數據

# coding:utf-8
import pymysql
# 連接數據庫
count = pymysql.connect(
      host = 'xx.xxx.xxx.xx', # 數據庫地址
      port = 3306,  # 數據庫端口號
      user='xxxx',  # 數據庫賬號
      password='xxxx',  # 數據庫密碼
      db = 'test_sll')  # 數據庫名稱
# 創建數據庫對象
db = count.cursor()
# 寫入SQL語句
sql = "select * from students "
# 執行sql命令
db.execute(sql)
# 獲取一個查詢
# restul = db.fetchone()
# 獲取全部的查詢內容
restul = db.fetchall()
print(restul)
db.close()

修改數據

commit() 執行完SQL后需要提交保存內容

# coding:utf-8
import pymysql
# 連接數據庫
count = pymysql.connect(
      host = 'xx.xxx.xxx.xx', # 數據庫地址
      port = 3306,  # 數據庫端口號
      user='xxx',  # 數據庫賬號
      password='xxx',  # 數據庫密碼
      db = 'test_sll')  # 數據庫表名
# 創建數據庫對象
db = count.cursor()
# 寫入SQL語句
sql = "update students set age = '12' WHERE id=1"
# 執行sql命令
db.execute(sql)
# 保存操作
count.commit()
db.close()

刪除數據

# coding:utf-8
import pymysql
# 連接數據庫
count = pymysql.connect(
      host = 'xx.xxx.xxx.xx', # 數據庫地址
      port = 3306,  # 數據庫端口號
      user='xxxx',  # 數據庫賬號
      password='xxx',  # 數據庫密碼
      db = 'test_sll')  # 數據庫表名
# 創建數據庫對象
db = count.cursor()
# 寫入SQL語句
sql = "delete from students where age = 12"
# 執行sql命令
db.execute(sql)
# 保存提交
count.commit()
db.close()

新增數據

新增數據這里涉及到一個事務問題，事物機制可以保證數據的一致性，比如插入一個數據，不會存在插入一半的情況，要么全部插入，要么都不插入

# coding:utf-8
import pymysql
# 連接數據庫
count = pymysql.connect(
      host = 'xx.xxx.xxx.xx', # 數據庫地址
      port = 3306,  # 數據庫端口號
      user='xxxx',  # 數據庫賬號
      password='xxx',  # 數據庫密碼
      db = 'test_sll')  # 數據庫表名
# 創建數據庫對象
db = count.cursor()
# 寫入SQL語句
sql = "insert INTO students(id,name,age)VALUES (2,'安靜','26')"
# 執行sql命令
db.execute(sql)
# 保存提交
count.commit()
db.close()

到這可以發現除了查詢不需要保存，其他操作都要提交保存，并且還會發現刪除，修改，新增，只是修改了SQL，其他的沒什么變化

創建表

創建表首先我們先定義下表內容的字段

# coding:utf-8
import pymysql
# 連接數據庫
count = pymysql.connect(
      host = 'xx.xxx.xxx.xx', # 數據庫地址
      port = 3306,  # 數據庫端口號
      user='xxxx',  # 數據庫賬號
      password='xxx',  # 數據庫密碼
      db = 'test_sll')  # 數據庫表名
# 創建數據庫對象
db = count.cursor()
# 寫入SQL語句
sql = 'CREATE TABLE students (id VARCHAR(255) ,name VARCHAR(255) ,age INT)'
# 執行sql命令
db.execute(sql)
db.close()

看完上述內容，你們掌握怎么在python中利用PYMYSQL對MYSQL數據庫進行連接的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！