MySQLdb操作数据库

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了MySQLdb操作数据库相关的知识,希望对你有一定的参考价值。

查询数据

使用execute()函数执行查询sql语句后,得到的只是受影响的行数,并不能真正拿到我们查询的内容。没关系,这里游标cursor中还提供了三种提取数据的方法:fetchone、fetchmany、fetchall,每个方法都会导致游标游动,所以必须注意游标的位置
cursor. fetchone()
获取游标所在处的一行数据,返回的是元组,没有则返回None,
cursor. fetchmany(size=None)
接收size条返回结果行。如果size的值大于返回的结果行的数量,则会返回cursor.arraysize条数据。返回的结果是一个元组,元组的元素也是元组,由每行数据组成;
cursor. fetchall()
接收全部的返回结果行。返回的结果是一个元组,元组的元素也是元组,由每行数据组成;

注意:
这些函数返回的结果数据均来自exceute()函数查询的结果集。如果exceute()结果集中没有数据,将会返回空元组。

Fetchone示例

import mysqldb
import random
try:
    conn = MySQLdb.connect(
        host = ‘127.0.0.1‘,
        user = ‘root‘,
        passwd = "123456",
        port = 3306)

    conn.select_db(‘python‘)# 

    cur = conn.cursor()# 获取游标
    cur.execute("select * from user")
    while 1:
        res = cur.fetchone()
        if res is None:
        #表示已经取完结果集
            break
        print res
    cur.close()
    conn.commit()
    conn.close()
    print u"sql执行成功"
except Exception, e:
print e

从execute()函数的查询结果中取数据,以元组的形式返回游标所在处的一条数据,如果游标所在处没有数据,将返回空元组,该数据执行一次,游标向下移动一个位置。fetchone()函数必须跟exceute()函数结合使用,并且在exceute()函数之后使用

Fetchmany示例

import MySQLdb
import random
try:
    conn = MySQLdb.connect(
        host = ‘127.0.0.1‘,
        user = ‘root‘,
        passwd = "123456",
        port = 3306)

    conn.select_db(‘python‘)# 选择pythonDB数据库

    cur = conn.cursor()# 获取游标
    cur.execute("select * from user")
    resTuple = cur.fetchmany(2)#2表示取两条数据
    print u"结果集类型:",type(resTuple)
    for i in resTuple:
        print i

    cur.close()
    conn.commit()
    conn.close()
    print u"sql执行成功"
except Exception, e:
print e

从exceute()函数结果中获取游标所在处的size条数据,并以元组的形式返回,元组的每一个元素都也是一个由一行数据组成的元组,如果size大于有效的结果行数,将会返回cursor.arraysize条数据,但如果游标所在处没有数据,将返回空元组。查询几条数据,游标将会向下移动几个位置。fetmany()函数必须跟exceute()函数结合使用,并且在exceute()函数之后使用

Fetchall示例

import MySQLdb
try:
    conn = MySQLdb.connect(
        host = ‘127.0.0.1‘,
        user = ‘root‘,
        passwd = "123456",
        port = 3306)

    conn.select_db(‘python‘)# 选择pythonDB数据库

    cur = conn.cursor()# 获取游标
    cur.execute("select * from user limit 2")
    resSet = cur.fetchall()
    print u"共%s条数据:" %len(resSet)
    print resSet#元组

    cur.close()
    conn.commit()
    conn.close()
    print u"sql执行成功"
except Exception, e:
    print e

获取游标所在处开始及以下所有的数据,并以元组的形式返回,元组的每一个元素都也是一个由一行数据组成的元组,如果游标所在处没有数据,将返回空元组。执行完这个方法后,游标将移动到数据库表的最后

更新数据
更新单条数据

#conding=utf-8
import MySQLdb
import random
try:
    conn = MySQLdb.connect(
        host = ‘127.0.0.1‘,
        user = ‘root‘,
        passwd = "123456",
        port = 3306)

    conn.select_db(‘python‘)

    cur = conn.cursor()# 获取游标
    #更新一条数据
    update = cur.execute("update user set password = ‘huhongqiang‘ where name=‘tom0‘")
    print u"修改语句受影响额行数:", update#为更新成功的条数
    #查询一条数据
    cur.execute("select * from user where name=‘tom0‘;")
    print cur.fetchone()

    cur.close()
    conn.commit()
    conn.close()
    print u"sql执行成功"
except MySQLdb.Error,e:
print e

批量更新数据

import MySQLdb
import random
try:
    conn = MySQLdb.connect(
        host = ‘127.0.0.1‘,
        user = ‘root‘,
        passwd = "123456",
        port = 3306)

    conn.select_db(‘python‘)# 选择pythonDB数据库

    cur = conn.cursor()# 获取游标
      #批量更新数据

sql = "update user set password = %s where name=%s"
cur.executemany(sql, [(‘345‘, ‘tom1‘), (‘123‘, ‘tom2‘)])
#此处传入一个列表,列表元素是元组
#查看更新后的结果
    query = cur.execute("select *  from user where name in (‘tom1‘,‘tom2‘)")
    print u"表中所有数据:"
    for i in cur.fetchall():
        print i

    cur.close()
    conn.commit()
    conn.close()
    print u"sql执行成功"
except Exception, e:
    print e

以上是关于MySQLdb操作数据库的主要内容,如果未能解决你的问题,请参考以下文章

python mysqldb 教程

用MySQLdb操作数据库流程示例:

简单封装MySQLdb模块操作MySQL数据库

简单封装MySQLdb模块操作MySQL数据库

python使用mysqldb连接数据库操作方法示例详解

MySQLdb操作数据库