Python mysql-DreamScape
要想使python可以操作mysql 就需要MySQL-python驱动，它是python 操作mysql必不可少的模块。下载地址：https://pypi.python.org/pypi/MySQL-python/，可以根据不同的平台下载不同的版本。这里以Windows平台为例，资源地址是：https://pypi.python.org/packages/27/06/596ae3afeefc0cda5840036c42920222cb8136c101ec0f453f2e36df12a0/MySQL-python-1.2.5.win32-py2.7.exe#md5=6f43f42516ea26e79cfb100af69a925e；Linux平台需下载源码zip包，下载MySQL-python-1.2.5.zip 文件之后直接解压。进入MySQL-python-1.2.5目录:>>python setup.py install
安装完成后，通过cmd验证：
Python 2.7.5 (default, Nov 20 2017, 22:43:36) on win32 Type "copyright", "credits" or "license()" for more information.
>>> help()
help> MySQLdb
Help on package MySQLdb:
NAME
MySQLdb - MySQLdb - A DB API v2.0 compatible interface to MySQL.
>>> import MySQLdb
没有报错提示MySQLdb模块找不到，说明安装OK ，下面开始使用python 操作数据库之前，我们有必要来回顾一下mysql的基本操作：
mysql -u root -p（有密码时）
mysql -u root （无密码时）
// 查看当前所有的数据库
mysql> show databases;
//作用与test数据库或切换数据库
mysql> use test;
//查看test库下面的表
mysql> show tables;
//创建user表，name 和password 两个字段
mysql> create table user (name VARCHAR(20),password VARCHAR(20));
//向user表内插入若干条数据
mysql> insert into user values('Tom','1321');
//查看user表的数据
mysql> select * from user;
//删除name 等于Jack的数据
mysql> delete from user where name = 'Jack';
//修改name等于Alen 的password 为 1111
mysql> update user set password='1111' where name = 'Alen';
接下来就来举例看下python是如何操作mysql的：
import MySQLdb conn= MySQLdb.connect(
host='localhost',
port = 3306,
user='root',
passwd='123456',
db ='test',
)
cur = conn.cursor()
#创建数据表
#cur.execute("create table student(id int ,name varchar(20),class varchar(30),age varchar(10))")
#插入一条数据
#cur.execute("insert into student values('2','Tom','3 year 2> #一次插入多条记录
sqli="insert into student values(%s,%s,%s,%s)"
cur.executemany(sqli,[
('3','Tom','1 year 1>
('3','Jack','2 year 1>
('3','Yaheng','2 year 2> ])
#修改查询条件的数据
#cur.execute("update student set> #删除查询条件的数据
#cur.execute("delete from student where age='9'")
#获取表中数据
cur.fetchone()
#获取第一条数据
cur.scroll(0,'absolute')
#打印表中的多少数据
info = cur.fetchmany(aa)
for ii in info:
print ii
cur.close()
conn.commit()
conn.close()
上面的例子中用到了游标对象cursor和事务execute，它们各自支持的方法有：
execute(op[,args])执行一个数据库的查询和命令fetchone()获取结果集的下一行fetchmany(size)获取结果集的下几行务fetchall()获取结果集中剩下的所有行rowcount()最近一次execute返回数据的行数或影响的行数close()关闭游标对象 execute操作的集合称为事务。
事务：访问和更新数据库的一个程序执行单元。
原子性：事务中包括的所有操作只有都做和都不做连个选择。
一致性：事务必须使数据库从一致性状态变到另一个一致性状态。
隔离性：一个事务的执行不能被其他事务干扰。
持久性：一旦事务提交了，它对数据库的改变就是永久性的。
使用事务的方法：
关闭自动commit：设置conn.autocommit(False)
正常结束事务：conn.commit()
异常结束事务：conn.rollback()
注意不关闭自动更新事务，每一条sql语句都是会更新事务，假如有一条执行错误，那就GG了。默认关闭。
conn = MySQLdb.connect(host='localhost',port = 3306,user='root', passwd='123456',db ='test')
connect() 方法用于创建数据库的连接，里面可以指定参数：用户名，密码，主机等信息。这只是连接到了数据库，要想操作数据库需要创建游标。
cur = conn.cursor()
通过获取到的数据库连接conn下的cursor()方法来创建游标。
cur.execute("create table student(id int ,name varchar(20),class varchar(30),age varchar(10))")
通过游标cur 操作execute()方法可以写入纯sql语句。通过execute()方法中写如sql语句来对数据进行操作。
cur.close() 关闭游标
conn.commit()方法在提交事物，在向数据库插入一条数据时必须要有这个方法，否则数据不会被真正的插入。
conn.close()关闭数据库连接
executemany()方法可以一次插入多条值，执行单挑sql语句,但是重复执行参数列表里的参数,返回值为受影响的行数。
fetchone()方法可以帮助我们获得表中的数据，可是每次执行cur.fetchone() 获得的数据都不一样，换句话说我没执行一次，游标会从表中的第一条数据移动到下一条数据的位置，所以，我再次执行的时候得到的是第二条数据。
scroll(0,'absolute') 方法可以将游标定位到表中的第一条数据。
fetchmany()方法可以获得多条数据，但需要指定数据的条数，通过一个for循环就可以把多条数据打印出。
import MySQLdb #使用连接池
from DBUtils.PooledDB import PooledDB
#5为连接池里的最少连接数
pool = PooledDB(MySQLdb,5,host='localhost',user='root',passwd='pwd',db='myDB',port=3306)
#以后每次需要数据库连接就是用connection（）函数获取连接就好了
conn = pool.connection()
cur=conn.cursor()
SQL="select * from test"
r=cur.execute(SQL)
r=cur.fetchall()
cur.close()
conn.close()
PooledDB的参数：
1. mincached，最少的空闲连接数，如果空闲连接数小于这个数，pool会创建一个新的连接；
2. maxcached，最大的空闲连接数，如果空闲连接数大于这个数，pool会关闭空闲连接；
3. maxconnections，最大的连接数；
4. blocking，当连接数达到最大的连接数时，在请求连接的时候，如果这个值是True，请求连接的程序会一直等待，直到当前连接数小于最大连接数，如果这个值是False，会报错；
5. maxshared 当连接数达到这个数，新请求的连接会分享已经分配出去的连接；
使用连接池的好处：
1.在程序创建连接的时候，可以从一个空闲的连接中获取，不需要重新初始化连接，提升获取连接的速度； 2.关闭连接的时候，把连接放回连接池，而不是真正的关闭，所以可以减少频繁地打开和关闭连接；
所谓索引的就是具有（约束和加速查找的一种方式），创建索引的缺点是对数据进行（修改、更新、删除）比较慢！在频繁查找使用的数据进行创建索引；通过设置得索引去查找速度较快。
1、主键索引：
特性：加速查找、不能为空、不能重复；
2、普通索引INDEX：
特性：加速查找；
3、唯一索引：
特性：加速查找、可以为空、不能重复；
主键索引PRIMARY KEY：加速查找+约束（不为空、不能重复）
唯一索引UNIQUE:加速查找+约束（不能重复）
4、联合索引：
特征：（多列）联合主键索引、联合唯一索引、联合普通索引；
-PRIMARY KEY(id,name):联合主键索引
-UNIQUE(id,name):联合唯一索引
-INDEX(id,name):联合普通索引
5、全文索引：
特征：对文本的内容进行分词，进行搜索；
#上边是通过索引查找，速度快！ ===========================================
mysql> select * from useru where uname='alex23232';
+-------+-----------+---------------+--------+
|> +-------+-----------+---------------+--------+
| 23232 | alex23232 | 23232@.qq.com | 男 |
+-------+-----------+---------------+--------+
1 row in set (0.04 sec)
#上边的就是没有通过索引进行查找，速度较慢！
===========================================
mysql> select * from useru where emlia='23423@.qq.com';
+-------+-----------+---------------+--------+
|> +-------+-----------+---------------+--------+
| 23423 | alex23423 | 23423@.qq.com | 男 |
+-------+-----------+---------------+--------+
1 row in set (0.18 sec)
1 创建索引
- 在创建表时就创建
create table s1(
> name char(6),
age int,
email varchar(30),
index(id)
);
- 在创建表后创建
create index name on s1(name);#添加普通索引
create unique index age on s1(age);#添加唯一索引
alter table s1 add primary key(id);#添加主键索引
create index name on s1(id,name);#添加联合普通索引
注：在创表的时候创建只能写在后面单写，因为他不是起约束的作用；
2 删除索引
drop index> drop index name on s1;
alter table s1 add primary key(id,name);联合主键索引
alter table s1 drop primary key;#删除主键索引
3 正确使用索引
select sql_no_cache * from s1 where email='xxx'; #命中索引，速度很快
select sql_no_cache * from s1 where email like '%old%'; #无法使用索引，速度依然很慢
注：索引必须是一个明确的值才能体现其查询速度，例如where>#范围小的话，索引有用
mysql> select count(*) from s1 where> +----------+
| count(*) |
+----------+
| 999 |
+----------+
1 row in set (0.00 sec)
#范围大的话，索引没用
mysql> select count(*) from s1 where> +----------+
| count(*) |
+----------+
| 298999 |
+----------+
1 row in set (0.13 sec)
页:
[1]