防伪码:忘情公子著
MySQLdb是用来通过python控制mysql数据库的一个模块。
在说这个模块之前,我们先来想一下在命令行模式下操作mysql数据库的步骤,一般来说分为三步:
1、连接数据库;
2、操作数据库(通过sql语句);
3、断开数据库连接
按此思路可知,python中的MySQLdb也是需要经过这三个步骤的,只不过不是在命令行模式下手工执行而已。
要想使用MySQLdb必须保证系统中有安装MySQL-python这个软件。
本篇文章主要是讲MySQLdb模块的使用,至于安装的步骤,请自行上网查阅。
MySQLdb模块在其内部提供了以下几个子模块:
connections:专门用来建立连接
constants(package)
converters:实现将python中的字符串转换成mysql可以处理的数据类型
cursors:游标。基于游标发送sql语句,获取执行结果
release
times
MySQLdb模块的常用方法:
在执行以下方法时,前面的connect和cursor均要替换成其实例化的对象名称。
connect(*args, **kwargs):连接数据库。常用参数有以下这些
user='Username'
passwd='Password'
host='Ip_Address'
db='dbname' #默认操作哪个db
port='Port_number'
connect_timeout='连接超时时间'
compress:实现压缩后进行数据传输
connect.stat():查看连接状态
connect.ping():测试正在连接的mysql服务器是否在线,不在线则尝试去重新连接
connect.commit():提交当前事务
connect.rollback():回滚事务
connect.autocommit(self,on):设置自动提交事务功能,参数值为1时开启此功能,值为0时关闭此功能
connect.thread_id():获取线程号
connect.shutdown():关闭mysql服务(前提是连接的用户有权限关闭mysql服务)
connect.cursor(self, cursorclass=None):通过connect连接对象创建游标对象
connect.select_db('dbname'):选择一个数据库进行操作
cursor.execute(self, query, args=None):通过cursor游标对象执行单条语句
cursor.executemany(self, query, args):通过cursor游标对象执行多条语句
这里的参数args必须是一个元组序列类型,可以是元组内包含元组,也可以是列表内包含元组
cursor.fetchone(self):通过cursor游标对象取出执行查询语句后的单条记录。
fetchone方法一次只能取一条记录;
可以通过遍历循环的方式取得所有记录;
默认只能从上往下查,无法从下往上查;
cursor.fetchmany(self, size=None):通过cursor游标对象取出查询语句后的多条记录
size参数用来设置取出多少条记录
如:cursor.fetchmany(10)表示取出10条记录
cursor.fetchall(self):通过cursor游标对象取出执行查询语句后的所有记录
cursor.scroll(self, value, mode='relative'):控制数据指针的位置
value参数:
用来设置偏移位,也就是移动多少位置
mode参数:
默认是relative,也就是从当前位置开始偏移;
当设置为absolute时表示绝对位置,从头开始偏移
如:cursor.scroll(0,absolute)表示将指针移动到头部,从头开始,移动0位
接下来我们来演示一下用MySQLdb模块实现mysql的增删改查功能:
在这里我们要操作的数据库名为aproduct,在aproduct库中有张表test2,查询出来内容如下:
<code>mysql> select </code><code>*</code> <code>from</code> <code>test2;</code>
<code>+</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>+</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>+</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>+</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>+</code>
<code>| name | age | job | city |</code>
<code>| tom | </code><code>30</code> <code>| teacher | SH |</code>
<code>| jerry | </code><code>25</code> <code>| doctor | WC |</code>
<code>2</code> <code>rows </code><code>in</code> <code>set</code> <code>(</code><code>0.09</code> <code>sec)</code>
创建一个连接对象:
<code>conn </code><code>=</code> <code>MySQLdb.connect(user</code><code>=</code><code>'roo'</code><code>,passwd</code><code>=</code><code>'abc123!'</code><code>,host</code><code>=</code><code>'127.0.0.1'</code><code>)</code>
通过connect连接对象创建游标对象:
<code>cur </code><code>=</code> <code>conn.cursor()</code>
通过以上两个步骤就能正常连接到一个数据库,接下来就是操作数据库了。
一般来说通过python来操作数据库指的是对数据库进行增、删、改、查,至于创建数据库最好是在数据库命令行界面下操作。
假定我们要ss_product这个库进行操作,在命令行下我们需要用到use ss_product,但在python下是没有use命令的,但我们可以通过select_db来实现这个功能:
<code>conn.select_db(</code><code>'aproduct'</code><code>)</code>
通过cursor游标对象执行sql语句:
在前面我们看到,test2这张表有四个字段,接下来我们给插入一条记录。
<code>cur.execute(</code><code>"insert into test2(name,age,job,city) value('sean',28,'Engineer','SH')"</code><code>)</code>
我们在命令行下看看数据是否插入成功:
<code>+</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>+</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>+</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>+</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>-</code><code>+</code>
<code>| name | age | job | city |</code>
<code>| tom | </code><code>30</code> <code>| teacher | SH |</code>
<code>| jerry | </code><code>25</code> <code>| doctor | WC |</code>
<code>| sean | </code><code>28</code> <code>| Engineer | SH |</code>
<code>3</code> <code>rows </code><code>in</code> <code>set</code> <code>(</code><code>0.00</code> <code>sec)</code>
由此可见,数据已经插入成功了,但这样插入数据会很麻烦。
因为数据不可能是固定的,不可能每次插入数据都去修改SQL语句,所以我们通常将sql语句放到一个变量名中。
<code>sqli </code><code>=</code> <code>"insert into test2(name,age,job,city) value(%s,%s,%s,%s)"</code>
<code>cur.execute(sqli,(</code><code>'abc'</code><code>,</code><code>30</code><code>,</code><code>'actor'</code><code>,</code><code>'WH'</code><code>))</code>
在命令行里看看是否插入成功:
<code>| abc | </code><code>30</code> <code>| actor | WH |</code>
<code>4</code> <code>rows </code><code>in</code> <code>set</code> <code>(</code><code>0.00</code> <code>sec)</code>
可以看到,数据已经插入成功。这样的方式比之前面一种写死数据就要灵活得多了。
但是这样只能一次插入一条数据,要想插入多条数据则需要像下面这样操作:
<code>sqlim </code><code>=</code> <code>"insert into test2(name,age,job,city) values(%s,%s,%s,%s)"</code>
当要插入多条数据时,通常把所有的数据放到values下,虽然不知道要插入多少数据,但是字段是固定的
在本例中是4个字段,所以values内只需要我们给四个%s占位即可,这里只能使用%s进行占位。
游标对象(cursor)的execute方法只能同时插入一条数据,想要同时插入多条数据则要使用executemany方法:
<code>cur.executemany(sqlim,[(</code><code>'a123'</code><code>,</code><code>40</code><code>,</code><code>'teacher'</code><code>,</code><code>'NC'</code><code>),(</code><code>'a456'</code><code>,</code><code>34</code><code>,</code><code>'Engineer'</code><code>,</code><code>'BJ'</code><code>),(</code><code>'lisi'</code><code>,</code><code>25</code><code>,</code><code>'worker'</code><code>,</code><code>'GZ'</code><code>)])</code>
注意:sqlim后面的参数必须是一个元组序列类型,可以是元组内包含元组,也可以是列表内包含元组。
在命令行下看看数据库表的内容:
<code>| a123 | </code><code>40</code> <code>| teacher | NC |</code>
<code>| a456 | </code><code>34</code> <code>| Engineer | BJ |</code>
<code>| lisi | </code><code>25</code> <code>| worker | GZ |</code>
<code>7</code> <code>rows </code><code>in</code> <code>set</code> <code>(</code><code>0.00</code> <code>sec)</code>
接下来我们用同样的命令来尝试下删除”lisi“这条记录:
<code>sqld </code><code>=</code> <code>"delete from test2 where name='lisi'"</code>
<code>cur.execute(sqld)</code>
看看数据库结果:
<code>6</code> <code>rows </code><code>in</code> <code>set</code> <code>(</code><code>0.00</code> <code>sec)</code>
接下来我们将名字叫abc的这条记录中的年龄给改成35:
<code>sqlu </code><code>=</code> <code>"update test2 set age=35 where name='abc'"</code>
<code>cur.execute(sqlu)</code>
进数据库看看结果:
<code>| abc | </code><code>35</code> <code>| actor | WH |</code>
接下来看看怎么查询:
我们用sql语句在命令行中查询时会返回一张表,其类型如上例的结果所示。
但在python中MySQLdb模块是无法实现打印出这种格式的,此时我们需要通过另一种方法来实现查询功能。
<code>sqls </code><code>=</code> <code>"select * from test2"</code>
<code>cur.execute(sqls)</code>
<code>cur.fetchone() </code><code>#查询一条记录</code>
<code>cur.fetchmany(</code><code>6</code><code>) </code><code>#查询6条记录</code>
MySQLdb模块中的查询是通过游标来控制的,我们可以通过cursor游标对象的scroll方法来控制游标。
当sql语句执行完毕以后,我们需要断开数据库连接,分为以下几个步骤:
<code>cur.close() </code><code>#断开游标</code>
<code>conn.close() </code><code>#断开数据库</code>
本文转自 忘情OK 51CTO博客,原文链接:http://blog.51cto.com/itchentao/1891436,如需转载请自行联系原作者