小奋斗 - 轻松学习从此开始!
IT小奋斗群 QQ群:62017228

python操作数据库(mysql)

一、软件环境

  python环境默认安装了sqlite3,如果需要使用sqlite3我们直接可以在python代码模块的顶部使用import sqlite3来导入该模块。本篇文章我是记录了python操作mysql数据库,mysql数据库下载

  由于我之前安装的是wampserver,默认安装了php、mysql和apache这3个环境,因此我没有在单独安装mysql数据库,只是下载了一个mysql管理工具Navicat for MySQL。在使用Navicat for MySQL连接本地mysql数据库时,发生连接失败问题,经过网上查询得知是mysql服务没有启动,如何启动mysql服务请看如何单独启动wamp 中自带的MySQL。其实很简单,就是打开命令行,选择目录到mysql数据库的bin目录下,执行mysqld命令即可。

  mysql 和mysqld 的区别:

  mysqld 是服务端程序
  mysql是命令行客户端程序

二、数据库操作

  python操作mysql数据库,新增、修改和删除比较简单,都是执行一个简单的sql语句。查询除了执行sql语句外还需要使用fetchone和fetchall来获取数据条目

 1 # -*- coding: UTF-8 -*-
 2 
 3 __author__ = 'Administrator'
 4 
 5 import MySQLdb
 6 
 7 # 打开数据库连接
 8 db = MySQLdb.connect("localhost","root","123456","test" )
 9 
10 # 使用cursor()方法获取操作游标
11 cursor = db.cursor()
12 
13 # 使用execute方法执行SQL语句
14 cursor.execute("SELECT VERSION()")
15 
16 # 使用 fetchone() 方法获取一条数据库。
17 data = cursor.fetchone()
18 
19 print "Database version : %s " % data
20 
21 # 如果数据表已经存在使用 execute() 方法删除表。
22 cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
23 
24 # 创建数据表SQL语句
25 sql = """CREATE TABLE EMPLOYEE (
26          FIRST_NAME  CHAR(20) NOT NULL,
27          LAST_NAME  CHAR(20),
28          AGE INT,
29          SEX CHAR(1),
30          INCOME FLOAT )"""
31 
32 cursor.execute(sql)
33 
34 # SQL 插入语句
35 sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
36          LAST_NAME, AGE, SEX, INCOME)
37          VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
38 try:
39    # 执行sql语句
40    cursor.execute(sql)
41    # 提交到数据库执行
42    db.commit()
43 except:
44    # Rollback in case there is any error
45    db.rollback()
46 
47 # SQL 查询语句
48 sql = "SELECT * FROM EMPLOYEE \
49        WHERE INCOME > '%d'" % (1000)
50 try:
51    # 执行SQL语句
52    cursor.execute(sql)
53    # 获取所有记录列表
54    results = cursor.fetchall()
55    for row in results:
56       fname = row[0]
57       lname = row[1]
58       age = row[2]
59       sex = row[3]
60       income = row[4]
61       # 打印结果
62       print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
63              (fname, lname, age, sex, income )
64 except:
65    print "Error: unable to fecth data"
66 
67 # 关闭数据库连接
68 db.close()

三、事务

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

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

  • 原子性(atomicity)。一个事务是一个不可分割的工作单位,事务中包括的诸操作要么都做,要么都不做。
  • 一致性(consistency)。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。
  • 隔离性(isolation)。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的,并发执行的各个事务之间不能互相干扰。
  • 持久性(durability)。持续性也称永久性(permanence),指一个事务一旦提交,它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。

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

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

  对于支持事务的数据库, 在Python数据库编程中,当游标建立之时,就自动开始了一个隐形的数据库事务。commit()方法游标的所有更新操作,rollback()方法回滚当前游标的所有操作。每一个方法都开始了一个新的事务。

我来评几句
登录后评论

已发表评论数(0)