【过时】MySQLdb：Python 操作 MySQL 数据库

小伙伴们有没有觉得学习数据库很有意思？有意思就对了！今天就给大家带来《【过时】MySQLdb：Python 操作 MySQL 数据库》，以下内容将会涉及到MySQL、python，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

NOTE（2017-11-18）: MySQLdb 不支持 Python 3，而 Python 3 是主流，所以就没有学习的必要了。

环境：MySQL 5.6.27, Ubuntu 15.10 64-bit

个人笔记，可读性较差。寻教程请移步：MySQL Python tutorial

官方简介

MySQLdb is an thread-compatible interface to the popular MySQL
database server that provides the Python database API.

安装

通过 pip 安装

import _mysql
import sys

try:
    con = _mysql.connect('localhost', 'root', '******', 'test')

    con.query('select version()')
    result = con.use_result()

    print 'MySQL version: %s' % result.fetch_row()[0]

except _mysql.Error, e:
    print 'Error %d: %s' % (e.args[0], e.args[1])
    sys.exit(1)

finally:
    if con:
        con.close()

改用

import MySQLdb as mdb
import sys

try:
    con = mdb.connect('localhost', 'root', '******', 'test')

    cur = con.cursor()
    cur.execute('select version()')

    ver = cur.fetchone()

    print 'MySQL version: %s' % ver

except mdb.Error, e:
    print 'Error %d: %s' % (e.args[0], e.args[1])
    sys.exit(1)

finally:
    if con:
        con.close()

创建表，插入数据

# coding: utf-8

import MySQLdb as mdb

con = mdb.connect('localhost', 'root', '******', 'test')

with con:
    cur = con.cursor()
    cur.execute('drop table if exists writers')
    cur.execute('create table writers(id int primary key auto_increment,\
            name varchar(25)) default charset utf8')
    cur.execute('insert into writers(name) values("Jack London")')
    cur.execute('insert into writers(name) values("Honore de Balzac")')
    cur.execute('insert into writers(name) values("Lion Feuchtwanger")')
    cur.execute('insert into writers(name) values("Emile Zola")')
    cur.execute('insert into writers(name) values("Truman Capote")')
    cur.execute('insert into writers(name) values("曹雪芹")')

查询

一次取回所有结果：

import MySQLdb as mdb

con = mdb.connect('localhost', 'root', '******', 'test')

with con:
    cur = con.cursor()
    cur.execute('select * from writers')

    # 结果集 rows 为元组（tuple）的元组，每一个元组代表了表中的一行。
    rows = cur.fetchall()
    for row in rows:
        print row

挨个取回结果：

import MySQLdb as mdb

con = mdb.connect('localhost', 'root', '******', 'test')

with con:
    cur = con.cursor()
    cur.execute('select * from writers')

    for i in range(cur.rowcount):
        row = cur.fetchone()
        print row

使用字典 Cursor

import MySQLdb as mdb

con = mdb.connect('localhost', 'root', '******', 'test')

def test_dict_cursor():
    with con:
        cur = con.cursor(mdb.cursors.DictCursor) # 字典 cursor
        cur.execute('select * from writers limit 4')

        # rows 为字典的元组
        rows = cur.fetchall()
        for row in rows:
            print row['id'], row['name'] # 通过列名访问结果

打印列名

import MySQLdb as mdb

con = mdb.connect('localhost', 'root', '******', 'test')

with con:
    cur = con.cursor()
    cur.execute('select * from writers limit 4')

    rows = cur.fetchall()
        
    # 元组的元组，每一个元组对应一个结果列，元组的第一个元素为列名。
    desc = cur.description

    # 打印前两个结果列的列名。
    print '%s %3s' % (desc[0][0], desc[1][0])

    for row in rows:
        print '%2s %3s' % row

Prepared Statements

Prepared Statements 可以提高安全性和性能，特别是对于多次重复执行的查询。Python 的数据库 API 规范建议了 5 种不同的方式来构造 Prepared Statements，MySQLdb 只支持其中的一种，代码类似于

import MySQLdb as mdb

con = mdb.connect('localhost', 'root', '******', 'test')

with con:
    cur = con.cursor()

    cur.execute("update writers set name = %s where id = %s",
            ("Guy de Maupasant", "4"))

    print "Number of rows updated:", cur.rowcount

事务

前面的例子一直使用

# coding: utf-8

import MySQLdb as mdb

try:
    con = mdb.connect('localhost', 'root', '******', 'test')

    # Cursor 创建，事务开始。
    cur = con.cursor()

    cur.execute('drop table if exists writers')
    # MyISAM doesn't support transaction.
    cur.execute('create table writers(id int primary key auto_increment,\
            name varchar(25)) engine=innodb')

    cur.execute('insert into writers(name) values("Jack London")')
    cur.execute('insert into writers(name) values("Honore de Balzac")')
    cur.execute('insert into writers(name) values("Lion Feuchtwanger")')
    cur.execute('insert into writers(name) values("Emile Zola")')
    cur.execute('insert into writers(name) values("Truman Capote")')

    # 显式地调用 commit 来结束一个事务。
    con.commit()

except mdb.Error, e:
    # 异常发生时，调用 rollback 进行回滚。
    if con:
        con.rollback()

    print "Error %d: %s" % (e.args[0], e.args[1])
    sys.exit(1)

finally:
    if con:
        con.close()

Cursor 有必要 close 吗？

原则上讲，不需要显式地调用 cursor 对象的

class BaseCursor(object):
    def __del__(self):
        self.close()
        self.errorhandler = None
        self._result = None

不过，还是建议主动调用

close

今天关于《【过时】MySQLdb：Python 操作 MySQL 数据库》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！