本文目錄一覽：
- 1、如何使用python連接mysql數據庫
- 2、python語言基礎知識是什麼?
- 3、怎麼用python連接mysql數據庫
- 4、Python 操作 MySQL 的5種方式
- 5、掌握Python 操作 MySQL 數據庫
- 6、怎麼用python鏈接和操作mysql數據庫
如何使用python連接mysql數據庫
在 Python 語言環境下我們這樣連接數據庫。
In [1]: from mysql import connector
In [2]: cnx = connector.connect(host=”172.16.192.100″,port=3306,user=”appuser”,password=”xxxxxx”)
但是連接數據庫的背後發生了什麼呢？
答案
當我們通過驅動程序（mysql-connector-python,pymysql）連接 MySQL 服務端的時候，就是把連接參數傳遞給驅動程序，驅動程序再根據參數會發起到 MySQL 服務端的 TCP 連接。當 TCP 連接建立之後驅動程序與服務端之間會按特定的格式和次序交換數據包，數據包的格式和發送次序由 MySQL 協議 規定。MySQL 協議：整個連接的過程中 MySQL 服務端與驅動程序之間，按如下的次序發送了這些包。
MySQL 服務端向客戶端發送一個握手包，包里記錄了 MySQL-Server 的版本，默認的授權插件，密碼鹽值（auth-data）。
2. MySQL 客戶端發出 ssl 連接請求包（如果有必要的話）。
3. MySQL 客戶端發出握手包的響應包，這個包時記錄了用戶名，密碼加密後的串，客戶端屬性，等等其它信息。
4. MySQL 服務端發出響應包，這個包里記錄了登錄是否成功，如果沒有成功也會給出錯誤信息。
python語言基礎知識是什麼?
如下：
一、Python語言基礎
Python核心：Python數據基本運算、語句、容器、函數
Python 面向對象編程：OOA、OOD、OOP、天龍八部技能系統框架 設計 Python高級：模塊、包、函數式編程、文件。
二、Python高級軟件開發技術
Linux操作系統 ：Linux常用命令、編輯工具、vim/Pycharm
數據結構與算法 ：鏈表、棧和隊列、樹和二叉樹、查找排序
IO網絡編程：文件操作、位元組流讀寫、網絡協議、套接 字、TCP/UDP
並發編程：多進程、進程池、進程通信、多線程、線程鎖、多任務並發、IO模型、協程
Python 正則表達式：正則表達式、貪婪模和非貪婪模式、re模塊
MySQL基礎：數據庫應用、SQL語言、Mysql增刪改查、 pymysql模塊
三、Python Web全棧式工程師
HTML/CSS HTML5標籤，CSS選擇器，CSS樣式屬性以 及值
Java ：JS流程控制，DOM，BOM，JQuery API
MySQL高級：MySQL索引、事務、引擎、優化、pymysql 模塊使用
Python Django 框架：Django、模板、視圖、模型、請求對象等
Ajax Ajax,：JSON, Jquery對Ajax的支持, 跨域訪問
四、Python 爬蟲
Redis：Redis、string、hash、list、set、zset、 Python與MySQL和Redis結合
爬蟲、HTTP、BeautifulSoup,XPath,Scrapy其實無論是學習什麼知識，都要有一個對學習目標的清楚認識。 只有這樣才能朝着目標持續前進，少走彎路，從學習中得到不斷的提升，享受python學習計劃的過程。
怎麼用python連接mysql數據庫
在 Python 語言環境下我們這樣連接數據庫。
In [1]: from mysql import connector
In [2]: cnx = connector.connect(host=”172.16.192.100″,port=3306,user=”appuser”,password=”xxxxxx”)
但是連接數據庫的背後發生了什麼呢？
答案
當我們通過驅動程序（mysql-connector-python,pymysql）連接 MySQL 服務端的時候，就是把連接參數傳遞給驅動程序，驅動程序再根據參數會發起到 MySQL 服務端的 TCP 連接。當 TCP 連接建立之後驅動程序與服務端之間會按特定的格式和次序交換數據包，數據包的格式和發送次序由 MySQL 協議 規定。MySQL 協議：整個連接的過程中 MySQL 服務端與驅動程序之間，按如下的次序發送了這些包。
MySQL 服務端向客戶端發送一個握手包，包里記錄了 MySQL-Server 的版本，默認的授權插件，密碼鹽值（auth-data）。
2. MySQL 客戶端發出 ssl 連接請求包（如果有必要的話）。
3. MySQL 客戶端發出握手包的響應包，這個包時記錄了用戶名，密碼加密後的串，客戶端屬性，等等其它信息。
4. MySQL 服務端發出響應包，這個包里記錄了登錄是否成功，如果沒有成功也會給出錯誤信息。
Python 操作 MySQL 的5種方式
1、MySQLdb
# 前置條件
sudo apt-get install python-dev libmysqlclient-dev # Ubuntu
sudo yum install python-devel mysql-devel # Red Hat / CentOS
# 安裝
pip install MySQL-python
Windows 直接通過下載 exe 文件安裝
#!/usr/bin/python
import MySQLdb
db = MySQLdb.connect(
host = “localhost”, # 主機名
user = “root”, # 用戶名
passwd = “pythontab.com”, # 密碼
db = “testdb”) # 數據庫名稱
# 查詢前，必須先獲取游標
cur = db.cursor()
# 執行的都是原生SQL語句
cur.execute(“SELECT * FROM mytable”)
for row in cur.fetchall():
print(row[0])
db.close()
2、mysqlclient
# Windows安裝
pip install some-package.whl
# linux 前置條件
sudo apt-get install python3-dev # debian / Ubuntu
sudo yum install python3-devel # Red Hat / CentOS
brew install mysql-connector-c # macOS (Homebrew)
pip install mysqlclient
3、PyMySQL
pip install PyMySQL
# 為了兼容mysqldb，只需要加入
pymysql.install_as_MySQLdb()
import pymysql
conn = pymysql.connect(host = ‘127.0.0.1’, user = ‘root’, passwd = “pythontab.com”, db = ‘testdb’)
cur = conn.cursor()
cur.execute(“SELECT Host,User FROM user”)
for r in cur:
print(r)
cur.close()
conn.close()
4、peewee
pip install peewee
import peewee
from peewee import *
db = MySQLDatabase(‘testdb’, user = ‘root’, passwd = ‘pythontab.com’)
class Book(peewee.Model):
author = peewee.CharField()
title = peewee.TextField()
class Meta:
database = db
Book.create_table()
book = Book(author = “pythontab”, title = ‘pythontab is good website’)
book.save()
for book in Book.filter(author = “pythontab”):
print(book.title)
5、SQLAlchemy
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy_declarative import Address, Base, Person
class Address(Base):
__tablename__ = ‘address’
id = Column(Integer, primary_key = True)
street_name = Column(String(250))
engine = create_engine(‘sqlite:///sqlalchemy_example.db’)
Base.metadata.bind = engine
DBSession = sessionmaker(bind = engine)
session = DBSession()
# Insert a Person in the person table
new_person = Person(name = ‘new person’)
session.add(new_person)
session.commit()
掌握Python 操作 MySQL 數據庫
本文Python 操作 MySQL 數據庫需要是使用到 PyMySQL 驅動
Python 操作 MySQL 前提是要安裝好 MySQL 數據庫並能正常連接使用，安裝步驟詳見下文。
注意： 安裝過程我們需要通過開啟管理員權限來安裝，否則會由於權限不足導致無法安裝。
首先需要先下載 MySQL 安裝包， 官網下載地址 下載對應版本即可,或直接在網上拉取並安裝：
權限設置：
初始化 MySQL：
啟動 MySQL：
查看 MySQL 運行狀態：
Mysql安裝成功後，默認的root用戶密碼為空，你可以使用以下命令來創建root用戶的密碼：
登陸：
創建數據庫：
查看數據庫：
PyMySQL 模塊使用 pip命令進行安裝：
假如系統不支持 pip 命令，可以使用以下方式安裝：
pymysql .connect 函數：連接上數據庫
輸出結果顯示如下：表面數據庫連接成功
使用 pymysql 的 connect() 方法連接數據庫，connect 參數解釋如下：
conn.cursor():獲取游標
如果要操作數據庫，光連接數據是不夠的，咱們必須拿到操作數據庫的游標，才能進行後續的操作，游標的主要作用是用來接收數據庫操作後的返回結果，比如讀取數據、添加數據。通過獲取到的數據庫連接實例 conn 下的 cursor() 方法來創建游標，實例如下：
輸出結果為：
cursor 返回一個游標實例對象，其中包含了很多操作數據的方法，如執行sql語句，sql 執行命令： execute() 和 executemany()
execute(query,args=None):
executemany(query,args=None)：
其他游標對象如下表：
完整數據庫連接操作實例如下：
以上結果輸出為：
創建表代碼如下：
如下所示數據庫表創建成功：
插入數據實現代碼：
插入數據結果：
Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。
查詢數據代碼如下：
輸出結果：
DB API中定義了一些數據庫操作的錯誤及異常，下表列出了這些錯誤和異常:
本文給大家介紹 Python 如何連接 Mysql 進行數據的增刪改查操作，文章通過簡潔的代碼方式進行示例演示，給使用 Python 操作 Mysql 的工程師提供支撐。
怎麼用python鏈接和操作mysql數據庫
你可以訪問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 上建立的。
如何安裝MySQLdb?
為了用DB-API編寫MySQL腳本，必須確保已經安裝了MySQL。複製以下代碼，並執行：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
如果執行後的輸出結果如下所示，意味着你沒有安裝 MySQLdb 模塊：
Traceback (most recent call last):
File “test.py”, line 3, in module
import MySQLdb
ImportError: No module named MySQLdb
安裝MySQLdb，請訪問 ，(Linux平台可以訪問：)從這裡可選擇適合您的平台的安裝包，分為預編譯的二進制文件和源代碼安裝包。
如果您選擇二進制文件發行版本的話，安裝過程基本安裝提示即可完成。如果從源代碼進行安裝的話，則需要切換到MySQLdb發行版本的頂級目錄，並鍵入下列命令:
$ gunzip MySQL-python-1.2.2.tar.gz
$ tar -xvf MySQL-python-1.2.2.tar
$ cd MySQL-python-1.2.2
$ python setup.py build
$ python setup.py install
注意：請確保您有root權限來安裝上述模塊。
數據庫連接
連接數據庫前，請先確認以下事項：
您已經創建了數據庫 TESTDB.
在TESTDB數據庫中您已經創建了表 EMPLOYEE
EMPLOYEE表字段為 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
連接數據庫TESTDB使用的用戶名為 “testuser” ，密碼為 “test123”,你可以可以自己設定或者直接使用root用戶名及其密碼，Mysql數據庫用戶授權請使用Grant命令。
在你的機子上已經安裝了 Python MySQLdb 模塊。
如果您對sql語句不熟悉，可以訪問我們的 SQL基礎教程
實例：
以下實例鏈接Mysql的TESTDB數據庫：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# 使用execute方法執行SQL語句
cursor.execute(“SELECT VERSION()”)
# 使用 fetchone() 方法獲取一條數據庫。
data = cursor.fetchone()
print “Database version : %s ” % data
# 關閉數據庫連接
db.close()
執行以上腳本輸出結果如下：
Database version : 5.0.45
創建數據庫表
如果數據庫連接存在我們可以使用execute()方法來為數據庫創建表，如下所示創建表EMPLOYEE：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# 如果數據表已經存在使用 execute() 方法刪除表。
cursor.execute(“DROP TABLE IF EXISTS EMPLOYEE”)
# 創建數據表SQL語句
sql = “””CREATE TABLE EMPLOYEE (
FIRST_NAME CHAR(20) NOT NULL,
LAST_NAME CHAR(20),
AGE INT,
SEX CHAR(1),
INCOME FLOAT )”””
cursor.execute(sql)
# 關閉數據庫連接
db.close()
數據庫插入操作
以下實例使用執行 SQL INSERT 語句向表 EMPLOYEE 插入記錄：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# SQL 插入語句
sql = “””INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES (‘Mac’, ‘Mohan’, 20, ‘M’, 2000)”””
try:
# 執行sql語句
cursor.execute(sql)
# 提交到數據庫執行
db.commit()
except:
# Rollback in case there is any error
db.rollback()
# 關閉數據庫連接
db.close()
以上例子也可以寫成如下形式：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用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()
實例：
以下代碼使用變量向SQL語句中傳遞參數:
…………………………….
user_id = “test123”
password = “password”
con.execute(‘insert into Login values(“%s”, “%s”)’ % \
(user_id, password))
…………………………….
數據庫查詢操作
Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。
fetchone(): 該方法獲取下一個查詢結果集。結果集是一個對象
fetchall():接收全部的返回結果行.
rowcount: 這是一個只讀屬性，並返回執行execute()方法後影響的行數。
實例：
查詢EMPLOYEE表中salary（工資）字段大於1000的所有數據：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用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()
以上腳本執行結果如下：
fname=Mac, lname=Mohan, age=20, sex=M, income=2000
數據庫更新操作
更新操作用於更新數據表的的數據，以下實例將 TESTDB表中的 SEX 字段全部修改為 ‘M’，AGE 字段遞增1：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用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 的所有數據：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB” )
# 使用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()
執行事務
事務機制可以確保數據一致性。
事務應該具有4個屬性：原子性、一致性、隔離性、持久性。這四個屬性通常稱為ACID特性。
原子性（atomicity）。一個事務是一個不可分割的工作單位，事務中包括的諸操作要麼都做，要麼都不做。
一致性（consistency）。事務必須是使數據庫從一個一致性狀態變到另一個一致性狀態。一致性與原子性是密切相關的。
隔離性（isolation）。一個事務的執行不能被其他事務干擾。即一個事務內部的操作及使用的數據對並發的其他事務是隔離的，並發執行的各個事務之間不能互相干擾。
持久性（durability）。持續性也稱永久性（permanence），指一個事務一旦提交，它對數據庫中數據的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。
Python DB API 2.0 的事務提供了兩個方法 commit 或 rollback。
原創文章，作者：C7PQ6，如若轉載，請註明出處：https://www.506064.com/zh-hk/n/130391.html
微信掃一掃 
支付寶掃一掃 