概述

Python 数据库接口支持非常多的数据库，你可以选择适合你项目的数据库：

不同的数据库你需要下载不同的DB API模块，例如你需要访问Oracle数据库和MysqL数据，你需要下载Oracle和MysqL数据库模块。

DB-API 是一个规范. 它定义了一系列必须的对象和数据库存取方式,以便为各种各样的底层数据库系统和多种多样的数据库接口程序提供一致的访问接口 。

Python的DB-API，为大多数的数据库实现了接口，使用它连接各数据库后，就可以用相同的方式操作各数据库。

Python DB-API使用流程：

一、什么是MysqLdb?

MysqLdb 是用于Python链接MysqL数据库的接口，它实现了 Python 数据库 API 规范 V2.0，基于 MysqL C API 上建立的。

二、如何安装MysqLdb?

为了用DB-API编写MysqL脚本，必须确保已经安装了MysqL。复制以下代码，并执行：

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MysqLdb

如果执行后的输出结果如下所示，意味着你没有安装 MysqLdb 模块：

Traceback (most recent call last):
 File "test.py",line 3,in <module>
  import MysqLdb
ImportError: No module named MysqLdb

如果您选择二进制文件发行版本的话，安装过程基本安装提示即可完成。如果从源代码进行安装的话，则需要切换到MysqLdb发行版本的顶级目录，并键入下列命令:

$ gunzip MysqL-python-1.2.2.tar.gz
$ tar -xvf MysqL-python-1.2.2.tar
$ cd MysqL-python-1.2.2
$ python setup.py build
$ python setup.py install

注意：请确保您有root权限来安装上述模块。

三、数据库连接

连接数据库前，请先确认以下事项：

实例：

以下实例链接MysqL的TESTDB数据库：

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MysqLdb

# 打开数据库连接
db = MysqLdb.connect("localhost","codecloud","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 使用execute方法执行sql语句
cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法获取一条数据库。
data = cursor.fetchone()

print "Database version : %s " % data

# 关闭数据库连接
db.close()

执行以上脚本输出结果如下：

Database version : 5.0.45

四、创建数据库表

如果数据库连接存在我们可以使用execute()方法来为数据库创建表，如下所示创建表EMPLOYEE：

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MysqLdb

# 打开数据库连接
db = MysqLdb.connect("localhost","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 如果数据表已经存在使用 execute() 方法删除表。
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 创建数据表sql语句
sql = """CREATE TABLE EMPLOYEE (
     FIRST_NAME CHAR(20) NOT NULL,LAST_NAME CHAR(20),AGE INT,SEX CHAR(1),INCOME FLOAT )"""

cursor.execute(sql)

# 关闭数据库连接
db.close()

五、数据库插入操作

以下实例使用执行 sql INSERT 语句向表 EMPLOYEE 插入记录：

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MysqLdb

# 打开数据库连接
db = MysqLdb.connect("localhost","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# sql 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,SEX,INCOME)
     VALUES ('Mac','Mohan',20,'M',2000)"""
try:
  # 执行sql语句
  cursor.execute(sql)
  # 提交到数据库执行
  db.commit()
except:
  # Rollback in case there is any error
  db.rollback()

# 关闭数据库连接
db.close()

以上例子也可以写成如下形式：

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MysqLdb

# 打开数据库连接
db = MysqLdb.connect("localhost","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# sql 插入语句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME,\
    LAST_NAME,INCOME) \
    VALUES ('%s','%s','%d','%c','%d' )" % \
    ('Mac',2000)
try:
  # 执行sql语句
  cursor.execute(sql)
  # 提交到数据库执行
  db.commit()
except:
  # 发生错误时回滚
  db.rollback()

# 关闭数据库连接
db.close()

实例：

以下代码使用变量向sql语句中传递参数:

..................................
user_id = "test123"
password = "password"

con.execute('insert into Login values("%s","%s")' % \
       (user_id,password))
..................................

六、数据库查询操作

Python查询MysqL使用 fetchone() 方法获取单条数据,使用fetchall() 方法获取多条数据。

实例：

查询EMPLOYEE表中salary（工资）字段大于1000的所有数据：

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MysqLdb

# 打开数据库连接
db = MysqLdb.connect("localhost","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# sql 查询语句
sql = "SELECT * FROM EMPLOYEE \
    WHERE INCOME > '%d'" % (1000)
try:
  # 执行sql语句
  cursor.execute(sql)
  # 获取所有记录列表
  results = cursor.fetchall()
  for row in results:
   fname = row[0]
   lname = row[1]
   age = row[2]
   sex = row[3]
   income = row[4]
   # 打印结果
   print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
       (fname,lname,age,sex,income )
except:
  print "Error: unable to fecth data"

# 关闭数据库连接
db.close()

以上脚本执行结果如下：

fname=Mac,lname=Mohan,age=20,sex=M,income=2000

七、数据库更新操作

更新操作用于更新数据表的的数据，以下实例将 TESTDB表中的 SEX 字段全部修改为 ‘M'，AGE 字段递增1：

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MysqLdb

# 打开数据库连接
db = MysqLdb.connect("localhost","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# sql 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1
             WHERE SEX = '%c'" % ('M')
try:
  # 执行sql语句
  cursor.execute(sql)
  # 提交到数据库执行
  db.commit()
except:
  # 发生错误时回滚
  db.rollback()

# 关闭数据库连接
db.close()

执行事务

事务机制可以确保数据一致性。

事务应该具有4个属性：原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。

Python DB API 2.0 的事务提供了两个方法 commit 或 rollback。

实例：

# sql删除记录语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
  # 执行sql语句
  cursor.execute(sql)
  # 向数据库提交
  db.commit()
except:
  # 发生错误时回滚
  db.rollback()

对于支持事务的数据库， 在Python数据库编程中，当游标建立之时，就自动开始了一个隐形的数据库事务。

commit()方法游标的所有更新操作，rollback（）方法回滚当前游标的所有操作。每一个方法都开始了一个新的事务。

错误处理

DB API中定义了一些数据库操作的错误及异常，下表列出了这些错误和异常:

以上就是本文的全部内容，希望对大家的学习有所帮助。

总结

以上是编程之家为你收集整理的Python连接mysql数据库的正确姿势全部内容，希望文章能够帮你解决Python连接mysql数据库的正确姿势所遇到的程序开发问题。

如果您也喜欢它,动动您的小指点个赞吧