PyMySQL 是在 Python3.x 版本中用于連接 MySQL 服務(wù)器的一個(gè)庫(kù)，Python2中則使用mysqldb。

1.PyMySQL的安裝

PS G:\book> pip install pymysql

Collecting pymysql

Downloading https://files./packages/ed/39/15045ae46f2a123019aa968dfcba0396c161c20f855f11dea6796bcaae95/PyMySQL-0.9.3-py2.py3-none-any.whl (47kB)

100% |████████████████████████████████| 51kB 17kB/s

Installing collected packages: pymysql

Successfully installed pymysql-0.9.3

2.使用python操作數(shù)據(jù)庫(kù)的流程

3.各個(gè)對(duì)象的介紹

導(dǎo)入import pymysql后，使用pymysql.connect函數(shù)就可以連接數(shù)據(jù)庫(kù)了。

pymysql.connect()參數(shù)說(shuō)明：

conn=pymysql.connect(host='127.0.0.1',user='root',passwd='123456',db='test',port=3306)

還可以簡(jiǎn)寫(xiě)為這樣：

conn=pymysql.connect('127.0.0.1','root','123456','test',3306)

打開(kāi)數(shù)據(jù)庫(kù)鏈接后，返回一個(gè)connection對(duì)象。

connection對(duì)象支持的方法，如下表所示：

通過(guò)connection對(duì)象的cursor方法，返回一個(gè)cursor游標(biāo)對(duì)象，

cursor對(duì)象支持的方法，如下表所示：

4. 連接數(shù)據(jù)庫(kù)

import pymysql

#數(shù)據(jù)庫(kù)連接，返回?cái)?shù)據(jù)庫(kù)連接對(duì)象

conn=pymysql.connect('127.0.0.1','root','123456','tt',3306)

#conn=pymysql.connect('127.0.0.1','root','123456','tt',3306)

cur=conn.cursor()

5.創(chuàng)建數(shù)據(jù)表

sql='''

create table test(id int not null auto_increment primary key,username varchar(50),password varchar(50))

'''

cur.execute(sql)

注意：這段代碼是創(chuàng)建一個(gè)表，一般可以通過(guò)可視化界面進(jìn)行創(chuàng)建。

6. 插入數(shù)據(jù)

插入test表中數(shù)據(jù)，該表有兩個(gè)字段，可以使用占位符%s,可以有效避免sql注入問(wèn)題。參數(shù)通過(guò)元組插入。

insertsql='''

insert into test(username,password) values (%s,%s)

'''

cur.execute(insertsql,('admin','123456'))

還可以executemany實(shí)現(xiàn)批量插入，比起循環(huán)插入效率要高。

insertmanysql='''

insert into test(username,password) values (%s,%s)

'''

cur.executemany(insertmanysql,[('zhangsan','123456'),('master','123456')])

上述方式無(wú)論插入單條數(shù)據(jù)還是多條數(shù)據(jù)都不會(huì)立即生效，需要進(jìn)行事務(wù)提交。

conn.commit()

如果出現(xiàn)異常，可以使用事務(wù)回滾操作

conn.rollback()

7.查詢數(shù)據(jù)

游標(biāo)對(duì)象提供了fetchall方法，獲取全部數(shù)據(jù)。返回一個(gè)元組。

Fetchone方法，獲取其中的一個(gè)結(jié)果，返回一個(gè)元組。

cur.execute('select * from test')

rs=cur.fetchall()

for line in rs:

print(line)

<class 'tuple'>

(1, 'admin', '123456')

(2, 'zhangsan', '123456')

(3, 'master', '123456')

cur.execute('select * from test')

rs=cur.fetchone()

print(rs)

<class 'tuple'>

(1, 'admin', '123456')

8.更新數(shù)據(jù)

import pymysql

#數(shù)據(jù)庫(kù)連接，返回?cái)?shù)據(jù)庫(kù)連接對(duì)象

conn=pymysql.connect('127.0.0.1','root','123456','etc',3306)

cur=conn.cursor()

try:

updatesql='update test set username=%s where id=%s'

cur.execute(updatesql,('manager',1))

conn.commit()

cur.execute('select * from test')

rs=cur.fetchall()

for line in rs:

print(line)

except:

conn.rollback()

conn.close()

(1, 'manager', '123456')

(2, 'zhangsan', '123456')

(3, 'master', '123456')

9.刪除數(shù)據(jù)

import pymysql

#數(shù)據(jù)庫(kù)連接，返回?cái)?shù)據(jù)庫(kù)連接對(duì)象

conn=pymysql.connect('127.0.0.1','root','123456','tt',3306)

cur=conn.cursor()

try:

delsql='delete from test where id=%s'

cur.execute(delsql,(3,))

conn.commit()

cur.execute('select * from test')

rs=cur.fetchall()

print(rs)

except:

print('發(fā)生了錯(cuò)誤')

conn.rollback()

conn.close()

((1, 'manager', '123456'), (2, 'zhangsan', '123456'))

可以看到，id=3的數(shù)據(jù)已經(jīng)被刪除。

python訪問(wèn)數(shù)據(jù)庫(kù)基本類似，非常簡(jiǎn)單，大家動(dòng)手做一個(gè)屬于你的數(shù)據(jù)庫(kù)應(yīng)用吧。