python -- 连接mysql数据库

由于python2.x与3.x的不兼容性，导致在python3中，不能使用类似在2.x中常用的模块mysqldb来连接mysql数据库。

在python3.x中， 连接MySQL的方案有：oursql, PyMySQL, myconnpy 等。

我常用的是pymysql。

1、pymysql安装：

　　一般推荐直接用pip3包管理器安装

pip3 install pymysql

　　还可以有其他安装方法，百度。

2、pymysql引用：

　　跟其他模块一样，在安装好pymysql之后，在需要的py文件里面导入pymysql，然后就能使用pymysql进行mysql数据库连接操作。

import pymysql　　

3、pymysql应用：

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import pymysql

#连接mysql
conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='root',
    passwd='root',
    db='pystudy',
    charset='utf8'
)

#使用cursor方法创建一个游标对象 cur
cur = conn.cursor()

#使用excute方法执行SQL语句,并返回受影响的行数
# reCount = cur.execute('select * from students')

#使用executemany方法执行多条insert语句
li = [
    ('txowner','male',23,13281818181,'CN'),
    ('xtsec','male',25,132834321,'USA'),
    ('tom','male',28,1328153431,'JP'),
    ('gouzi','female',22,132345181,'CN'),
]
reCount1 = cur.executemany('insert into students(name,sex,age,tel,nal) values(%s,%s,%s,%s,%s)',li)

#删除数据
# reCount = cur.execute('delete from students where age = 28')

#修改数据
# reCount = cur.execute('update students set sex = %s where name = %s',('female','admin'))
    #注意：这里用%s占位，后面写参数时不需要用%

#事物回滚操作（事物回滚操作只有在提交事务之前才有效，一旦事物提交，就不能进行回滚了）
conn.rollback()  #只有在ENGINE=InnoDB时有用，MyISAM不支持事物，所以不能进行回滚

#提交当前事物到数据库执行
conn.commit()

#使用cursor对象的fetchall方法获取全部数据
# data = cur.fetchall()
# data = cur.fetchone()
# data = cur.fetchmany(3)

# print(data)

#关闭连接
cur.close()
conn.close()

4、pymysql模块说明：

#!/usr/bin/env python
# -*- coding: utf-8 -*-
'''
pymysql模块作用：python连接mysql

简单用法：
pymysql.Connect()参数说明
host(str):      MySQL服务器地址
port(int):      MySQL服务器端口号（默认3306可不写）
user(str):      用户名
passwd(str):    密码
db(str):        数据库名称
charset(str):   连接编码（默认可不写）

connection对象支持的方法
cursor()        使用该连接创建并返回游标
commit()        提交当前事务
rollback()      回滚当前事务（mysql使用事务前需确定存储引擎为innodb，MyISAM是不能进行回滚的）
close()         关闭连接

cursor对象支持的方法
execute(op)     执行一个数据库的操作命令
executemany()   执行多个数据库的操作命令
fetchone()      取得结果集的下一行
fetchmany(size) 获取结果集的下几行（以元组形式返回）
fetchall()      获取结果集中的所有行（以元组形式返回）
rowcount()      返回数据条数或影响行数
close()         关闭游标对象
'''

　5、事物回滚

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import pymysql

#连接mysql
conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='root',
    passwd='root',
    db='pystudy',
    charset='utf8'
)

#使用cursor方法创建一个游标对象 cur
cur = conn.cursor()

try:
    li = [
        ('txowner','male',23,13281818181,'CN'),
        ('xtsec','male',25,132834321,'USA'),
        ('tom','male',28,1328153431,'JP'),
        ('gouzi','female',22,132345181,'CN'),
    ]
    reCount1 = cur.executemany('insert into students(name,sex,age,tel,nal) values(%s,%s,%s,%s,%s)',li)
    assert 1==2

except Exception as e:
    conn.rollback()

else:
    conn.commit()

#关闭连接
cur.close()
conn.close()