python3之pymysql模塊

1、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

2、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)  ：用於無緩沖的游標，它將結果作為字典返回

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

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