Python操作数据库

一、MySQL数据库操作：

1、python标准数据库接口DB—API介绍：python标准数据库接口为python  DB—API，它为开发人员提供了数据库应用编程接口。python  DB—API支持很多种的数据库，用户可以自己选择跟自己项目相关的数据库。Python DB—API支持的数据库有：GadFly、mSQL、MySQL、PostgreSQL、Microsoft  SQL  Server  2000、Informix、Interbase、Oracle、Sybase

不同的数据库需要下载不同的DB  API模块，例如用户需要访问Oracle数据库和Mysql数据，需要下载Oracle、MySQL数据库模块。Python的DB—API，为大多数的数据库实现了接口，使用它连接各数据库后，就可以用相同的方式操作各数据库。

python  DB—API使用流程：1）引入DB—API模块；2）获取与数据库的连接；3）执行SQL语句和存储过程；4）关闭数据库连接

2、数据库连接：连接数据库前，用户需确认：连接数据库TESTDB使用的用户名为“testuser”，密码为“test123”，用户可以直接设定或者直接使用root用户名及其密码

以下实例连接Mysql的TESTDB数据库，对应了DB—API的四个步骤：

# encoding: utf-8
#!/usr/bin/python

# 1 引入API模块
import MySQLdb
# 2 获取与数据库的连接

# 打开数据库连接 
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )
# 3 执行SQL语句和存储过程
# 使用cursor()方法获取操作游标 
cursor = db.cursor()
# 使用execute方法执行SQL语句
cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法获取一条数据库。
data = cursor.fetchone()
print "Database version : %s " % data

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

　执行结果显示为：

Database version : 5.0.45

3、创建数据库：数据库表名为：EMPLAYEEMPLOYEE，数据表字段为：FIRST_NAME，LAST_NAME、AGE、SEX、INCOME

# encoding: utf-8
#!/usr/bin/python

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","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()

4、使用 SQL  INSERT 语句向数据库表 EMPLOYEE 插入记录：

# encoding: utf-8
#!/usr/bin/python

import MySQLdb

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

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

# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, 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()

  注：1）一定要有conn,commmit（）这句来提交事务，使用fetchall()方法获取很多条数据

·fetchone()：该方法获取下一个查询结果集，结果集是一个对象

·fetchall()：接收全部的返回结果行

·rowcount()：这是一个只读属性，并返回执行execute()方法后影响的行数

查询EMPLAYEE表中salary(工资)字段大于1000的所有数据：

# encoding: utf-8
#!/usr/bin/python

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","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

4、数据库更新操作：更新操作作用于更新数据表的数据

将TESTDB表中SEX字段全部修改为‘M’、AGE字段递增1：

# encoding: utf-8
#!/usr/bin/python

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","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()

5、数据库的事务机制：事务机制可以确保一致性，事务应该有4个属性：原子性、一致性、隔离性、永久性，这四个属性通常称为ACID特性

 原子性（atomicity）：一个事务是一个不可分割的工作单位，事务中包括的诸操作要么都做，要么都不做

一致性（consistency）:事务必须是使数据库从一个一致性状态变到另一个一致性状态，一致性与原子性是密切相关的

隔离性（isolation）：一个事务的执行不能被其他事务干扰，即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事务之间不能互相干扰

持久性（durability）：持续性也称永久性，指一个事务一旦提交，它对数据库中数据的改变就应该是永久性的，接下来的其他操作或故障不应该对其有任何影响。