python操作mysql數據庫

 

https://study.163.com/course/courseMain.htm?courseId=1006383008&share=2&shareId=400000000398149（博主錄制）

 

 

1.下載wampserver，PHP集成環境下載

 http://www.wampserver.com/en/

使用環境：Windows+python3.4+MySQL5.5+Navicat

2.下載Navicat for mysql

3.Python安裝MySQLClient

 

 新建數據庫

新建了一個本地的鏈接，yaozh_db，打開鏈接

 

新建數據庫

 

 

 

 

導入全部數據，欄位名行，第一個數據行，最后一個數據行都不填

 

 

 

 

設置主鍵

 

導入向導

 

 

點擊開始

處理成功

 

 

 be_usan數據庫報導入字符串太長錯時，使用utf-8編碼格式，部分錯誤字段可以設置為text格式

 

 

 

 

一、創建連接

1.准備工作，想要使用Python操作MySQL，首先需要安裝MySQL-Python的包，在Python 3.x下，該包已經改名為MySQLClient。可以使用pip方式安裝：

pip install MySQLClient

 

或者下載包文件，進行安裝也可以。

2.Python使用MySQL的流程：

3.啟動MySQL服務器：以管理員身份啟動“cmd”，輸入命令：’net start mysql‘

 

3.啟動MySQL服務器：以管理員身份啟動“cmd”，輸入命令：’net start mysql‘

Python中使用MySQL導入方法：import MySQLdb

4.創建Connection

　　Connection：創建了Python客戶端與數據庫之間的網絡通路。他的參數如下

參數名	類型	說明
host	String	MySQL的服務器地址
port	int	MySQL的端口號
user	String	用戶名
passwd	String	密碼
db	String	使用的數據庫
charset	String	連接字符集

　　Connection支持的方法：

方法名	說明
cursor（）	創建並且返回游標
commit（）	提交當前事物
rollback()	回滾當前事物r()
close()	關閉Connection

5.獲取Cursor.

Cursor:游標對象，用於執行查詢和獲取結果，它支持的方法如下：

方法名	說明
execute()	用於執行一個數據庫的查詢命令
fetchone()	獲取結果集中的下一行
fetchmany(size)	獲取結果集中的下（size）行
fetchall()	獲取結果集中剩下的所有行
rowcount	最近一次execute返回數據/影響的行數
close()	關閉游標

下面我們在Python中創建一個實例：

Python中使用MySQL導入方法：import MySQLdb

 

 

# -*- coding: utf-8 -*-
"""
Created on Thu Aug  3 10:17:47 2017

@author: toby
"""

import MySQLdb
#鏈接
conn=MySQLdb.connect(host='localhost',port=3306,user='root',passwd='',db='yaozh_db',charset='utf8')
#獲取操作游標 
cursor=conn.cursor() 
'''
#刪除表,DROP TABLE用於取消一個或多個表  
sql = "drop table if exists user"  
cursor.execute(sql) 
'''

cursor.execute('select * from be_agents')
data = cursor.fetchall() 
#方法獲取一條數據庫
data1 = cursor.fetchone()
print(data[:10])
print(data1)
#print(conn)
#print(cursor)
 
cursor.close()
conn.close()

 

 

 

https://www.runoob.com/python/python-mysql.html

 

Python 標准數據庫接口為 Python DB-API，Python DB-API為開發人員提供了數據庫應用編程接口。

Python 數據庫接口支持非常多的數據庫，你可以選擇適合你項目的數據庫：

• GadFly
• mSQL
• MySQL
• PostgreSQL
• Microsoft SQL Server 2000
• Informix
• Interbase
• Oracle
• Sybase

你可以訪問Python數據庫接口及API查看詳細的支持數據庫列表。

不同的數據庫你需要下載不同的DB API模塊，例如你需要訪問Oracle數據庫和Mysql數據，你需要下載Oracle和MySQL數據庫模塊。

DB-API 是一個規范. 它定義了一系列必須的對象和數據庫存取方式, 以便為各種各樣的底層數據庫系統和多種多樣的數據庫接口程序提供一致的訪問接口 。

Python的DB-API，為大多數的數據庫實現了接口，使用它連接各數據庫后，就可以用相同的方式操作各數據庫。

Python DB-API使用流程：

• 引入 API 模塊。
• 獲取與數據庫的連接。
• 執行SQL語句和存儲過程。
• 關閉數據庫連接。

---

什么是MySQLdb?

MySQLdb 是用於Python鏈接Mysql數據庫的接口，它實現了 Python 數據庫 API 規范 V2.0，基於 MySQL C API 上建立的。

---

 

 

數據庫插入操作

以下實例使用執行 SQL INSERT 語句向表 EMPLOYEE 插入記錄：

 

# -*- coding: utf-8 -*-
"""
Created on Fri Aug  4 09:50:02 2017

@author: toby
"""

import MySQLdb

# 打開數據庫連接
db=MySQLdb.connect(host='localhost',port=3306,user='root',passwd='',db='yaozh_db',charset='utf8')

# 使用cursor()方法獲取操作游標 
cursor = db.cursor()

# SQL 插入語句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
       LAST_NAME, AGE, SEX, INCOME) \
       VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
       ('Mac', 'Mohan', 20, 'M', 2000)
try:
   # 執行sql語句
   cursor.execute(sql)
   # 提交到數據庫執行
   db.commit()
except:
   # 發生錯誤時回滾
   db.rollback()

# 關閉數據庫連接
db.close()

 

 

---

數據庫查詢操作

Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。

• fetchone(): 該方法獲取下一個查詢結果集。結果集是一個對象
• fetchall():接收全部的返回結果行.
• rowcount: 這是一個只讀屬性，並返回執行execute()方法后影響的行數。

實例：

查詢EMPLOYEE表中salary（工資）字段大於1000的所有數據：

# -*- coding: utf-8 -*-
"""
Created on Fri Aug  4 09:57:31 2017

@author: toby
"""

import MySQLdb

# 打開數據庫連接
db=MySQLdb.connect(host='localhost',port=3306,user='root',passwd='',db='yaozh_db',charset='utf8')

# 使用cursor()方法獲取操作游標 
cursor = db.cursor()

# SQL 查詢語句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > '%d'" % (1000)
try:
   # 執行SQL語句
   cursor.execute(sql)
   # 獲取所有記錄列表
   results = cursor.fetchall()
   for row in results:
      fname = row[0]
      lname = row[1]
      age = row[2]
      sex = row[3]
      income = row[4]
      # 打印結果
      print ("fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
             (fname, lname, age, sex, income ))
except:
   print ("Error: unable to fecth data")

# 關閉數據庫連接
db.close()

 

 

 

---

數據庫更新操作

更新操作用於更新數據表的的數據，以下實例將 EMPLOYEE 表中的 SEX 字段為 'M' 的 AGE 字段遞增 1：

 

# -*- coding: utf-8 -*-
"""
Created on Fri Aug  4 09:50:02 2017

@author: toby
"""

import MySQLdb

# 打開數據庫連接
db=MySQLdb.connect(host='localhost',port=3306,user='root',passwd='',db='yaozh_db',charset='utf8')

# 使用cursor()方法獲取操作游標 
cursor = db.cursor()

# SQL 更新語句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')
try:
   # 執行SQL語句
   cursor.execute(sql)
   # 提交到數據庫執行
   db.commit()
except:
   # 發生錯誤時回滾
   db.rollback()

# 關閉數據庫連接
db.close()

 

---

刪除操作

刪除操作用於刪除數據表中的數據，以下實例演示了刪除數據表 EMPLOYEE 中 AGE 大於 20 的所有數據：

 

 

# -*- coding: utf-8 -*-
"""
Created on Fri Aug  4 09:50:02 2017

@author: toby
"""

import MySQLdb

# 打開數據庫連接
db=MySQLdb.connect(host='localhost',port=3306,user='root',passwd='',db='yaozh_db',charset='utf8')

# 使用cursor()方法獲取操作游標 
cursor = db.cursor()

# SQL 刪除語句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
   # 執行SQL語句
   cursor.execute(sql)
   # 提交修改
   db.commit()
except:
   # 發生錯誤時回滾
   db.rollback()

# 關閉連接
db.close()

 

 

 

復合SQL腳本

復合SQL語句腳本

# -*- coding: utf-8 -*-
"""
Created on Thu Aug  3 11:28:34 2017

@author: toby
"""

# -*- coding: utf-8 -*-
"""
Created on Fri Aug  4 09:50:02 2017

@author: toby
"""

import MySQLdb

# 打開數據庫連接
db=MySQLdb.connect(host='localhost',port=3306,user='root',passwd='',db='yaozh_db',charset='utf8')

# 使用cursor()方法獲取操作游標 
cursor = db.cursor()

# SQL 插入語句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
       LAST_NAME, AGE, SEX, INCOME) \
       VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
       ('Toby', 'Lee', 30, 'M', 6000)
       
sql1 = "INSERT INTO EMPLOYEE(FIRST_NAME, \
       LAST_NAME, AGE, SEX, INCOME) \
       VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
       ('lili', 'Lee', 30, 'F', 2000)    
       
sql2 = "INSERT INTO EMPLOYEE(FIRST_NAME, \
       LAST_NAME, AGE, SEX, INCOME) \
       VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
       ('bobo', 'zhang', 40, 'M', 3000)         
       
try:
   # 執行sql語句
   cursor.execute(sql)
   cursor.execute(sql1)
   cursor.execute(sql2)
   # 提交到數據庫執行
   db.commit()
except:
   # 發生錯誤時回滾
   db.rollback()

# 關閉數據庫連接
db.close()

 

復合SQL查詢

# -*- coding: utf-8 -*-
"""
Created on Fri Aug  4 09:50:02 2017

@author: toby
"""

import MySQLdb

# 打開數據庫連接
db=MySQLdb.connect(host='localhost',port=3306,user='root',passwd='',db='yaozh_db',charset='utf8')

# 使用cursor()方法獲取操作游標 
cursor = db.cursor()

# SQL 刪除語句
sql = "SELECT*FROM be_ypzl WHERE me_name ='阿膠' and me_fake='假冒'"
#sql = "SELECT me_name FROM be_ypzl"
#sql = "SELECT me_name FROM be_ypzl WHERE me_name = '阿膠'"
try:
   # 執行SQL語句
   cursor.execute(sql)
   #獲取數據
   data = cursor.fetchall() 
   print(data)
   # 提交修改
   db.commit()
except:
   # 發生錯誤時回滾
   db.rollback()

# 關閉連接
db.close()

 

包含關系查詢

# -*- coding: utf-8 -*-
"""
Created on Fri Aug  4 09:50:02 2017

@author: toby
"""

import MySQLdb

# 打開數據庫連接
db=MySQLdb.connect(host='localhost',port=3306,user='root',passwd='',db='yaozh_db',charset='utf8')

# 使用cursor()方法獲取操作游標 
cursor = db.cursor()

# LIKE='%阿膠%'表示包含阿膠
sql = "SELECT*FROM be_ypzl WHERE me_name LIKE'%阿膠%' and me_fake='假冒'"
#sql = "SELECT*FROM be_ypzl WHERE me_name LIKE'%阿膠%'"
#sql = "SELECT*FROM be_ypzl WHERE me_name LIKE'%阿膠%' and me_fake='假冒'"
#sql = "SELECT me_name FROM be_ypzl"
#sql = "SELECT me_name FROM be_ypzl WHERE me_name = '阿膠'"
try:
   # 執行SQL語句
   cursor.execute(sql)
   #獲取數據
   data = cursor.fetchall() 
   print(data)
   # 提交修改
   db.commit()
except:
   # 發生錯誤時回滾
   db.rollback()

# 關閉連接
db.close()

 

執行事務

事務機制可以確保數據一致性。

事務應該具有4個屬性：原子性、一致性、隔離性、持久性。這四個屬性通常稱為ACID特性。

• 原子性（atomicity）。一個事務是一個不可分割的工作單位，事務中包括的諸操作要么都做，要么都不做。
• 一致性（consistency）。事務必須是使數據庫從一個一致性狀態變到另一個一致性狀態。一致性與原子性是密切相關的。
• 隔離性（isolation）。一個事務的執行不能被其他事務干擾。即一個事務內部的操作及使用的數據對並發的其他事務是隔離的，並發執行的各個事務之間不能互相干擾。
• 持久性（durability）。持續性也稱永久性（permanence），指一個事務一旦提交，它對數據庫中數據的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。

Python DB API 2.0 的事務提供了兩個方法 commit 或 rollback。

實例：

# SQL刪除記錄語句 sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20) try: # 執行SQL語句 cursor.execute(sql) # 向數據庫提交 db.commit() except: # 發生錯誤時回滾 db.rollback()

對於支持事務的數據庫， 在Python數據庫編程中，當游標建立之時，就自動開始了一個隱形的數據庫事務。

commit()方法游標的所有更新操作，rollback（）方法回滾當前游標的所有操作。每一個方法都開始了一個新的事務。

---

錯誤處理

DB API中定義了一些數據庫操作的錯誤及異常，下表列出了這些錯誤和異常:

異常	描述
Warning	當有嚴重警告時觸發，例如插入數據是被截斷等等。必須是 StandardError 的子類。
Error	警告以外所有其他錯誤類。必須是 StandardError 的子類。
InterfaceError	當有數據庫接口模塊本身的錯誤（而不是數據庫的錯誤）發生時觸發。 必須是Error的子類。
DatabaseError	和數據庫有關的錯誤發生時觸發。 必須是Error的子類。
DataError	當有數據處理時的錯誤發生時觸發，例如：除零錯誤，數據超范圍等等。 必須是DatabaseError的子類。
OperationalError	指非用戶控制的，而是操作數據庫時發生的錯誤。例如：連接意外斷開、 數據庫名未找到、事務處理失敗、內存分配錯誤等等操作數據庫是發生的錯誤。 必須是DatabaseError的子類。
IntegrityError	完整性相關的錯誤，例如外鍵檢查失敗等。必須是DatabaseError子類。
InternalError	數據庫的內部錯誤，例如游標（cursor）失效了、事務同步失敗等等。 必須是DatabaseError子類。
ProgrammingError	程序錯誤，例如數據表（table）沒找到或已存在、SQL語句語法錯誤、 參數數量錯誤等等。必須是DatabaseError的子類。
NotSupportedError	不支持錯誤，指使用了數據庫不支持的函數或API等。例如在連接對象上 使用.rollback()函數，然而數據庫並不支持事務或者事務已關閉。 必須是DatabaseError的子類。

https://study.163.com/provider/400000000398149/index.htm?share=2&shareId=400000000398149（博主視頻教學主頁）