python之MySQLdb模块-创新互联

防伪码:忘情公子著

成都创新互联服务项目包括孟连网站建设、孟连网站制作、孟连网页制作以及孟连网络营销策划等。多年来,我们专注于互联网行业,利用自身积累的技术优势、行业经验、深度合作伙伴关系等,向广大中小型企业、政府机构等提供互联网行业的解决方案,孟连网站推广取得了明显的社会效益与经济效益。目前,我们服务的客户以成都为中心已经辐射到孟连省份的部分城市,未来相信会继续扩大服务区域并继续获得客户的支持与信任!

 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,查询出来内容如下:

mysql> select * from test2; +-------+------+---------+------+ | name  | age  | job     | city | +-------+------+---------+------+ | tom   |   30 | teacher | SH   | | jerry |   25 | doctor  | WC   | +-------+------+---------+------+ 2 rows in set (0.09 sec)

 创建一个连接对象:

conn = MySQLdb.connect(user='roo',passwd='abc123!',host='127.0.0.1')

 通过connect连接对象创建游标对象:

cur = conn.cursor()

 通过以上两个步骤就能正常连接到一个数据库,接下来就是操作数据库了。

 一般来说通过python来操作数据库指的是对数据库进行增、删、改、查,至于创建数据库最好是在数据库命令行界面下操作。

 假定我们要ss_product这个库进行操作,在命令行下我们需要用到use ss_product,但在python下是没有use命令的,但我们可以通过select_db来实现这个功能:

conn.select_db('aproduct')

 通过cursor游标对象执行sql语句:

  在前面我们看到,test2这张表有四个字段,接下来我们给插入一条记录。

cur.execute("insert into test2(name,age,job,city) value('sean',28,'Engineer','SH')")

 我们在命令行下看看数据是否插入成功:

mysql> select * from test2; +-------+------+----------+------+ | name  | age  | job      | city | +-------+------+----------+------+ | tom   |   30 | teacher  | SH   | | jerry |   25 | doctor   | WC   | | sean  |   28 | Engineer | SH   | +-------+------+----------+------+ 3 rows in set (0.00 sec)

 由此可见,数据已经插入成功了,但这样插入数据会很麻烦。

 因为数据不可能是固定的,不可能每次插入数据都去修改SQL语句,所以我们通常将sql语句放到一个变量名中。

sqli = "insert into test2(name,age,job,city) value(%s,%s,%s,%s)" cur.execute(sqli,('abc',30,'actor','WH'))

 在命令行里看看是否插入成功:

mysql> select * from test2; +-------+------+----------+------+ | name  | age  | job      | city | +-------+------+----------+------+ | tom   |   30 | teacher  | SH   | | jerry |   25 | doctor   | WC   | | sean  |   28 | Engineer | SH   | | abc   |   30 | actor    | WH   | +-------+------+----------+------+ 4 rows in set (0.00 sec)

 可以看到,数据已经插入成功。这样的方式比之前面一种写死数据就要灵活得多了。

 但是这样只能一次插入一条数据,要想插入多条数据则需要像下面这样操作:

sqlim = "insert into test2(name,age,job,city) values(%s,%s,%s,%s)"

 当要插入多条数据时,通常把所有的数据放到values下,虽然不知道要插入多少数据,但是字段是固定的

 在本例中是4个字段,所以values内只需要我们给四个%s占位即可,这里只能使用%s进行占位。

 游标对象(cursor)的execute方法只能同时插入一条数据,想要同时插入多条数据则要使用executemany方法:

cur.executemany(sqlim,[('a123',40,'teacher','NC'),('a456',34,'Engineer','BJ'),('lisi',25,'worker','GZ')])

 注意:sqlim后面的参数必须是一个元组序列类型,可以是元组内包含元组,也可以是列表内包含元组。

 在命令行下看看数据库表的内容:

mysql> select * from test2; +-------+------+----------+------+ | name  | age  | job      | city | +-------+------+----------+------+ | tom   |   30 | teacher  | SH   | | jerry |   25 | doctor   | WC   | | sean  |   28 | Engineer | SH   | | abc   |   30 | actor    | WH   | | a123  |   40 | teacher  | NC   | | a456  |   34 | Engineer | BJ   | | lisi  |   25 | worker   | GZ   | +-------+------+----------+------+ 7 rows in set (0.00 sec)

 接下来我们用同样的命令来尝试下删除”lisi“这条记录:

sqld = "delete from test2 where name='lisi'" cur.execute(sqld)

 看看数据库结果:

mysql> select * from test2; +-------+------+----------+------+ | name  | age  | job      | city | +-------+------+----------+------+ | tom   |   30 | teacher  | SH   | | jerry |   25 | doctor   | WC   | | sean  |   28 | Engineer | SH   | | abc   |   30 | actor    | WH   | | a123  |   40 | teacher  | NC   | | a456  |   34 | Engineer | BJ   | +-------+------+----------+------+ 6 rows in set (0.00 sec)

 接下来我们将名字叫abc的这条记录中的年龄给改成35:

sqlu = "update test2 set age=35 where name='abc'" cur.execute(sqlu)

 进数据库看看结果:

mysql> select * from test2; +-------+------+----------+------+ | name  | age  | job      | city | +-------+------+----------+------+ | tom   |   30 | teacher  | SH   | | jerry |   25 | doctor   | WC   | | sean  |   28 | Engineer | SH   | | abc   |   35 | actor    | WH   | | a123  |   40 | teacher  | NC   | | a456  |   34 | Engineer | BJ   | +-------+------+----------+------+ 6 rows in set (0.00 sec)

 接下来看看怎么查询:

  我们用sql语句在命令行中查询时会返回一张表,其类型如上例的结果所示。

  但在python中MySQLdb模块是无法实现打印出这种格式的,此时我们需要通过另一种方法来实现查询功能。

sqls = "select * from test2" cur.execute(sqls) cur.fetchone()      #查询一条记录 cur.fetchmany(6)    #查询6条记录

 MySQLdb模块中的查询是通过游标来控制的,我们可以通过cursor游标对象的scroll方法来控制游标。

 当sql语句执行完毕以后,我们需要断开数据库连接,分为以下几个步骤:

cur.close()     #断开游标 conn.close()    #断开数据库

另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


名称栏目:python之MySQLdb模块-创新互联
文章来源:http://azwzsj.com/article/cesiho.html