python連接mysql腳本的簡單介紹

本文目錄一覽：

• 1、如何用python連接mysql數據庫
• 2、python3.4怎麼連接mysql pymysql連接mysql數據庫
• 3、怎麼做才能使mysql和python連接起來
• 4、如何使用Python3.4連接MySQL
• 5、如何使用python連接mysql數據庫
• 6、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

python3.4怎麼連接mysql pymysql連接mysql數據庫

到python官方網站下載最新python程序。根據系統有32,64位。

直接下一步，就可以安裝成功。

在python官網中去下載ez_setup.py文件。

此工具是python管理包工具，通過它可以下載很多服務。

請根據系統下載相關文件。

在python中執行python ez_setup.py文件，如果沒有配置環境變量，可以在python安裝路徑中找到python.exe，在此目錄中執行上面命令。

命令執行成功後，會在python安裝目錄下easy_install.exe工具包。

在CMD命令行執行：easy_install.exe pymysql3

如果找不到該命令，切換服務到python安裝目錄/Scripts/下執行。如果此目錄下沒有easy_install.exe，證明上一步沒有安裝成功。

安裝pymysql3服務如下。

pymysql3服務安裝成功後，開始寫python程序連接mysql服務。

mysql數據庫安裝在此省略，到mysql官方網站下載，下一步安裝就可以了。

python程序內容如下：import pymysql

conn = pymysql.connect(user=’root’, passwd=’root’,

host=’localhost’, db=’zjctest’)

cur = conn.cursor()

cur.execute(“SELECT * FROM zjc”)

for r in cur:

print(“row_number:” , (cur.rownumber) )

print(“id:”+str(r[0])+”name:”+str(r[1])+”age:”+str(r[2]))

cur.close()

conn.close()

執行結果如下，證明連接mysql數據庫成功，且數據正確返回。

怎麼做才能使mysql和python連接起來

什麼是 PyMySQL？

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

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

PyMySQL 安裝

在使用 PyMySQL 之前，我們需要確保 PyMySQL 已安裝。

PyMySQL 下載地址：。

如果還未安裝，我們可以使用以下命令安裝最新版的 PyMySQL：

$ pip3 install PyMySQL

如果你的系統不支持 pip 命令，可以使用以下方式安裝：

1、使用 git 命令下載安裝包安裝(你也可以手動下載)：

$ git clone cd PyMySQL/$ python3 setup.py install

2、如果需要制定版本號，可以使用 curl 命令來安裝：

$ # X.X 為 PyMySQL 的版本號$ curl -L | tar xz$ cd PyMySQL*$ python3 setup.py install

$ # 現在你可以刪除 PyMySQL* 目錄

注意：請確保您有root權限來安裝上述模塊。

安裝的過程中可能會出現”ImportError: No module named setuptools”的錯誤提示，意思是你沒有安裝setuptools，你可以訪問 找到各個系統的安裝方法。

Linux 系統安裝實例：

$ wget python3 ez_setup.py

數據庫連接

連接數據庫前，請先確認以下事項：

您已經創建了數據庫 TESTDB.

在TESTDB數據庫中您已經創建了表 EMPLOYEE

EMPLOYEE表字段為 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。

連接數據庫TESTDB使用的用戶名為 “testuser” ，密碼為 “test123”,你可以可以自己設定或者直接使用root用戶名及其密碼，Mysql數據庫用戶授權請使用Grant命令。

在你的機子上已經安裝了 Python MySQLdb 模塊。

如果您對sql語句不熟悉，可以訪問我們的 SQL基礎教程

實例：

以下實例鏈接 Mysql 的 TESTDB 數據庫：

實例(Python 3.0+)

#!/usr/bin/python3

import pymysql

# 打開數據庫連接db = pymysql.connect(“localhost”,”testuser”,”test123″,”TESTDB” )

# 使用 cursor() 方法創建一個游標對象 cursorcursor = db.cursor()

# 使用 execute()  方法執行 SQL 查詢 cursor.execute(“SELECT VERSION()”)

# 使用 fetchone() 方法獲取單條數據.data = cursor.fetchone()

print (“Database version : %s ” % data)

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

執行以上腳本輸出結果如下：

Database version : 5.5.20-log

創建數據庫表

如果數據庫連接存在我們可以使用execute()方法來為數據庫創建表，如下所示創建表EMPLOYEE：

實例(Python 3.0+)

#!/usr/bin/python3

import pymysql

# 打開數據庫連接db = pymysql.connect(“localhost”,”testuser”,”test123″,”TESTDB” )

# 使用 cursor() 方法創建一個游標對象 cursorcursor = db.cursor()

# 使用 execute() 方法執行 SQL，如果表存在則刪除cursor.execute(“DROP TABLE IF EXISTS EMPLOYEE”)

# 使用預處理語句創建表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 插入記錄：

實例(Python 3.0+)

#!/usr/bin/python3

import pymysql

# 打開數據庫連接db = pymysql.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:   # 如果發生錯誤則回滾

  db.rollback()

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

以上例子也可以寫成如下形式：

實例(Python 3.0+)

#!/usr/bin/python3

import pymysql

# 打開數據庫連接db = pymysql.connect(“localhost”,”testuser”,”test123″,”TESTDB” )

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

# SQL 插入語句sql = “INSERT INTO EMPLOYEE(FIRST_NAME, \

      LAST_NAME, AGE, SEX, INCOME) \

      VALUES (‘%s’, ‘%s’,  %s,  ‘%s’,  %s)” % \       (‘Mac’, ‘Mohan’, 20, ‘M’, 2000)try:   # 執行sql語句

  cursor.execute(sql)

  # 執行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的所有數據：

實例(Python 3.0+)

#!/usr/bin/python3

import pymysql

# 打開數據庫連接db = pymysql.connect(“localhost”,”testuser”,”test123″,”TESTDB” )

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

# SQL 查詢語句sql = “SELECT * FROM EMPLOYEE \

      WHERE INCOME %s” % (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=%s,sex=%s,income=%s” % \             (fname, lname, age, sex, income ))except:   print (“Error: unable to fetch data”)

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

以上腳本執行結果如下：

fname=Mac, lname=Mohan, age=20, sex=M, income=2000

數據庫更新操作

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

實例(Python 3.0+)

#!/usr/bin/python3

import pymysql

# 打開數據庫連接db = pymysql.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 的所有數據：

實例(Python 3.0+)

#!/usr/bin/python3

import pymysql

# 打開數據庫連接db = pymysql.connect(“localhost”,”testuser”,”test123″,”TESTDB” )

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

# SQL 刪除語句sql = “DELETE FROM EMPLOYEE WHERE AGE %s” % (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。

實例

實例(Python 3.0+)

# SQL刪除記錄語句sql = “DELETE FROM EMPLOYEE WHERE AGE %s” % (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的子類。  

如何使用Python3.4連接MySQL

python3發佈以來，獲取了廣大程序員們的差評，說不穩定，又是不兼容什麼的，不過差評歸差評，python3既然已經發佈，肯定是個趨勢，但

在python3.4裏面，使用原來python2.7的mysqldb已經不能連接mysql數據庫了，比較令人糾結，不過我們可以使用

pymysql，來完成連接mysql的重任，步驟如下：

序號

描述

1

去github上下載pymysql的安裝包 pymysql

2

解壓到某個盤符下

3

打開cmd窗口（win環境下），進入pymysql的根目錄下執行命令，python setup.py install

4

在程序里，導入pymysql

5

開始連接數據庫

數據庫操作的API文檔連接:

代碼如下：

__author__ = ‘qindongliang’

#導入pymysql的包

import pymysql

try:

#獲取一個數據庫連接，注意如果是UTF-8類型的，需要制定數據庫

conn=pymysql.connect(host=’localhost’,user=’root’,passwd=’qin’,db=’person’,port=3306,charset=’utf8′)

cur=conn.cursor()#獲取一個游標

cur.execute(‘select * from person’)

data=cur.fetchall()

for d in data :

#注意int類型需要使用str函數轉義

print(“ID: “+str(d[0])+’ 名字： ‘+d[1]+” 性別： “+d[2])

cur.close()#關閉游標

conn.close()#釋放數據庫資源

except Exception :print(“發生異常”)

結果如下：

D:\python\python.exe D:/pythonide/pythonprojectworkspace/python/mysql.py

ID: 1 名字： 秦天 性別： 男

ID: 2 名字： 王晶 性別： 女

Process finished with exit code 0

如何使用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數據庫

1、進入mysql，創建一個新用戶test：

格式：grant 權限 on 數據庫名.表名 用戶@登錄主機 identified by “用戶密碼”;

grant all privileges on *.* to test@192.168.0.2 identified by “123456”;

或者

grant select,update,insert,delete on *.* to test@192.168.0.2 identified by “123456”;

2、 ./mysqladmin -uroot -ppwd reload

記住：對授權表的任何修改都需要重新reload

這時我們應該可以從192.168.0.2來遠程管理192.168.0.1的數據庫了

下面就是該腳本radius.py，其中出現三個日期：10天以後的日期future、今天的日期now、用戶到期時間userdate，如果userdate = future 並且 userdate = now，那麼向radreply表中插入一行，向用戶提示到期時間，及時繳費；如果userdate now，那麼將該用戶的狀態設為停機，不允許其再登陸。

#! /usr/local/python/bin/python

# -*- coding: UTF-8 -*-

#引入模塊

import MySQLdb

import datetime

#格式化日期，只有相同格式的日期才能進行比較

future = (datetime.date.today() + datetime.timedelta(10)).strftime(“%Y-%m-%d”)

now = (datetime.date.today()).strftime(“%Y-%m-%d”)

#這裡就是連接遠端數據庫了

conn = MySQLdb.connect (host = “192.168.0.1”,

user = “test”,

passwd = “123456”,

db = “radius”)

cursor = conn.cursor ()

cursor.execute (“SELECT login_name,id,last_date FROM customer where last_date!=” and type=’包月’ and status=’開通'”)