python3之pymysql模塊

一、python3 MySQL數據庫連接模塊

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

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

PyMySQL模塊下載地址：https://github.com/PyMySQL/PyMySQL

安裝PyMySQL模塊的方法：

#(1)pip方式安裝
$pip install PyMySQL

#(2)克隆安裝
$git clone https://github.com/PyMySQL/PyMySQL
　　$cd PyMySQL
　　$python3 setup.py install

#(3)源碼安裝
$ curl -L https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz
　　$ cd PyMySQL*
　　$python3 setup.py install

二、PyMySQL的API參考

（1）連接對象API：

classpymysql.connections.Connection(host=None, user=None, password='', database=None, port=0, unix_socket=None, charset='', sql_mode=None, read_default_file=None, conv=None, use_unicode=None, client_flag=0, cursorclass=<class 'pymysql.cursors.Cursor'>, init_command=None, connect_timeout=10, ssl=None, read_default_group=None, compress=None, named_pipe=None, no_delay=None, autocommit=False, db=None, passwd=None, local_infile=False, max_allowed_packet=16777216, defer_connect=False, auth_plugin_map={}, read_timeout=None, write_timeout=None, bind_address=None, binary_prefix=False)

使用MySQL服務器表示一個套接字，建立類實例的方法是調用connect()，將建立一個MySQL連接對象，創建鏈接可以使用的參數以下：

host：數據庫服務器主機名能夠是IP或域名

user：用戶登錄名

password：用戶名密碼
database：要使用的數據庫名

port：端口號默認3306

bind_address：多網口是綁定網絡接口，能夠是主機名或IP

unix_socket：指定套接字連接

read_timeout：讀取鏈接的超時時間

write_timeout：寫入鏈接的超時時間

carset：指定字符集
sql_mode：指定SQL_MODE

read_defautl_file：指定my.cnf配置文件讀取參數

init_command：創建鏈接時運行的初始SQL語句

 

連接對象使用的方法：

conn.close()   關閉連接

conn.commit()  提交更改到數據庫服務器

conn.cursor(cursor=None)  建立一個新的遊標來執行查詢，cursor指定遊標類型：Cursor、SSCursor、DictCursor或SSDictCursor，沒有指定即便用光標

conn.open   若是連接處於打開狀態則返回true

conn.ping(reconnect=True)  檢查服務器是否存在，reconnect爲True時從新連接

conn.rellback()   回滾當前事務

(2)遊標對象API

class pymysql.cursors.Cursor(connection)  ：建立與數據庫交換的對象，對象表示數據庫遊標，用於管理提取操做的上下文

遊標的方法：

cursor.callproc(procname)  查看數據庫存儲過程

cursor.close() 關閉遊標

cursor.execute(query,args=None) 執行查詢，query查詢參數爲字符串，args能夠是元組，列表或字典，用於查詢的參數，返回類型爲INT  

cursor.executemany(query,seq_of_parameters) 屢次查詢返回結果

cursor.fetchall()  獲取全部行

cursor.fetchmany(size=None) 獲取指定的行數

cursor.fetchone() 獲取下一行

cursor.max_stmt_length=1024000  executemany()生成的最大語句大小

cursor.mogrify(query,args=None)  經過調用execute()方法返回發送到數據庫的字符串

（3）其它對象API

class pymysql.cursors.SSCursor(connection)  ：用於返回大量數據的查詢

class pymysql.cursors.DictCursor(connection)  ：用於將結果做爲字典返回的遊標

class pymysql.cursors.SSDictCursor(connection)  ：用於無緩衝的遊標，它將結果做爲字典返回

三、pymysql使用

（1）MySQL查詢操做：

import pymysql

#建立數據庫連接，分別指定主機、用戶、密碼和數據庫名,必須保證用戶有權限連接
db=pymysql.connect('10.0.1.198','test1','123.com','test')

#建立遊標對象
cursor = db.cursor()

#使用execute()方法執行SQL語句
cursor.execute('select * from test1')

#獲取單條數據
print(cursor.fetchone())
#獲取N條數據
print(cursor.fetchmany(3))

#獲取全部數據，序列形式 
data = cursor.fetchall() 
print(data) 

#關閉遊標 
cursor.close() 
#關閉連接 
db.close()

（2）獲取字典類型數據：

import pymysql
#建立數據庫連接，分別指定主機、用戶、密碼和數據庫名,必須保證用戶有權限連接
db=pymysql.connect('10.0.1.198','test1','123.com','test')
#建立遊標對象，指定數據類型爲字典，將打印key,value
cursor = db.cursor(cursor=pymysql.cursors.DictCursor)
#使用execute()方法執行SQL語句
cursor.execute('select * from test1')

#獲取全部數據，字典形式
data = cursor.fetchall()
print(data)

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

（3）MySQL更新操做：

import pymysql

conn = pymysql.connect(host='10.0.1.198',port=3306,user='test1',passwd='123.com',db='test')
cursor = conn.cursor()
sql = "update test1 set age=28 where id=4"
cursor.execute(sql)
#提交語句到數據庫
conn.commit()
cursor.close()
conn.close()

（4）插入多條語句：

import pymysql

conn = pymysql.connect(host='10.0.1.198',port=3306,user='test1',passwd='123.com',db='test')
cursor = conn.cursor()
l1 = [
    ('k1','aa',22,'2222'),
    ('k2','bb',23,'3333'),
    ('k3','cc',24,'4444'),
    ('k4','dd',25,'5555')
]
#定義數據庫語句
sql = "insert into test1(name,sex,age,tel) values(%s,%s,%s,%s)"
#executemany()插入多條數據
cursor.executemany(sql,l1)
#獲取新增數據自增ID
print(cursor.lastrowid)
#提交語句到數據庫
conn.commit()
cursor.close()
conn.close()

（5）建立數據庫表：

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time    : 2018/1/30 17:19
# @Author  : Py.qi
# @File    : create_database.py
# @Software: PyCharm

import pymysql

conn = pymysql.connect('10.0.1.198','test1','123.com')
#建立遊標對象,字典輸出
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor.execute('drop database if exists student')
cursor.execute("create database student character set 'utf8' collate utf8_general_ci")

#若是表存在則刪除
cursor.execute('drop table if exists student.test2')
#sql建表語句
sql = '''create table student.test2(
    id int not null auto_increment primary key,
    name char(8) not null,
    age int not null)'''
#執行建表語句
cursor.execute(sql)

cursor.close()
conn.close()

（6）數據回滾操做：

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time    : 2018/1/30 14:53
# @Author  : Py.qi
# @File    : mysqldb_clien.py
# @Software: PyCharm

import pymysql
#建立數據庫連接，分別指定主機、用戶、密碼和數據庫名,必須保證用戶有權限連接
db=pymysql.connect('10.0.1.198','test1','123.com','test')
#建立遊標對象
cursor = db.cursor(cursor=pymysql.cursors.DictCursor)
#使用execute()方法執行SQL語句

sql2 = "insert into test1(name,sex,age,tel) values('zz','ee',21,'8999')"
try:
    cursor.execute(sql2)
    #提交到數據庫執行
    db.commit()
except:
    #發生錯誤時回滾操做
    db.rollback()

#獲取全部數據，序列形式
data = cursor.fetchall()
print(data)

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

（7）錯誤處理：

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的子類。

-----------------------------------------------------------------------------------------------------------------------------------------