前言
大家都知道在Python中如果要连接数据库，不管是MySQL、SQL Server、PostgreSQL亦或是SQLite，使用时都是采用游标的方式，所以就不得不学习Python DB-API。
Python所有的数据库接口程序都在一定程度上遵守 Python DB-API 规范。DB-API定义了一系列必须的对象和数据库存取方式，以便为各种底层数据库系统和多种多样的数据库接口程序提供一致的访问接口。由于DB-API 为不同的数据库提供了一致的访问接口， 在不同的数据库之间移植代码成为一件轻松的事情。
Python连接数据库流程：
使用connect创建connection连接
connect 方法生成一个 connect 对象, 我们通过这个对象来访问数据库。符合标准的模块都会实现 connect 方法。
connect 函数的参数如下所示：
- user Username
- password Password
- host Hostname
- database Database name
- dsn Data source name
数据库连接参数可以以一个 DSN 字符串的形式提供，示例：connect(dsn='host:MYDB',user='root',password=' ')
当然，不同的数据库接口程序可能有些差异，并非都是严格按照规范实现，例如MySQLdb则使用 db 参数而不是规范推荐的 database 参数来表示要访问的数据库：
MySQLdb连接时可用参数
- host: 数据库主机名.默认是用本地主机
- user: 数据库登陆名.默认是当前用户
- passwd: 数据库登陆的秘密.默认为空
- db: 要使用的数据库名.没有默认值
- port: MySQL服务使用的TCP端口.默认是3306
- charset: 数据库编码
psycopg2连接时可用参数：
- dbname – 数据库名称 (dsn连接模式)
- database – 数据库名称
- user – 用户名
- password – 密码
- host – 服务器地址 (如果不提供默认连接Unix Socket)
- port – 连接端口 (默认5432)
其中connect对象又有如下方法:
- close():关闭此connect对象, 关闭后无法再进行操作，除非再次创建连接
- commit():提交当前事务，如果是支持事务的数据库执行增删改后没有commit则数据库默认回滚
- rollback():取消当前事务
- cursor():创建游标对象
使用cursor创建游标对象
cursor游标对象又有如下属性和方法:
常用方法:
- close():关闭此游标对象
- fetchone():得到结果集的下一行
- fetchmany([size = cursor.arraysize]):得到结果集的下几行
- fetchall():得到结果集中剩下的所有行
- excute(sql[, args]):执行一个数据库查询或命令
- excutemany(sql, args):执行多个数据库查询或命令
常用属性:
- connection:创建此游标对象的数据库连接
- arraysize:使用fetchmany()方法一次取出多少条记录，默认为1
- lastrowid:相当于PHP的last_inset_id()
其他方法：
- __iter__()：创建一个可迭代对象（可选）
- next()：获取结果集的下一行（如果支持迭代的话）
- nextset()：移到下一个结果集（如果支持的话）
- callproc(func[,args])：调用一个存储过程
- setinputsizes(sizes)：设置输入最大值（必须有，但具体实现是可选的）
- setoutputsizes(sizes[,col])：设置大列 fetch 的最大缓冲区大小
其他属性：
- description：返回游标活动状态（包含7个元素的元组）：（name, type_code, display_size, internal_size, precision, scale, null_ok）只有 name 和 type_cose 是必需的
- rowcount：最近一次 execute() 创建或影响的行数
- messages：游标执行后数据库返回的信息元组（可选）
- rownumber：当前结果集中游标所在行的索引（起始行号为 0）
DB-API只中的错误定义
错误类的层次关系：
|
1
2
3
4
5
6
7
8
9
10
11
|
StandardError|__Warning|__Error|__InterfaceError|__DatabaseError|__DataError|__OperationalError|__IntegrityError|__InternalError|__ProgrammingError|__NotSupportedError |
数据库操作示例
代码如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
|
#! /usr/bin/env python# -*- coding: utf-8 -*-# *************************************************************# Filename @ operatemysql.py# Author @ Huoty# Create date @ 2015-08-16 10:44:34# Description @ # *************************************************************import MySQLdb# Script starts from here# 连接数据库db_conn = MySQLdb.connect(host = 'localhost', user= 'root', passwd = '123456')# 如果已经创建了数据库，可以直接用如下方式连接数据库#db_conn = MySQLdb.connect(host = "localhost", user = "root",passwd = "123456", db = "testdb")"""connect方法常用参数: host: 数据库主机名.默认是用本地主机 user: 数据库登陆名.默认是当前用户 passwd: 数据库登陆的秘密.默认为空 db: 要使用的数据库名.没有默认值 port: MySQL服务使用的TCP端口.默认是3306 charset: 数据库编码"""# 获取操作游标 cursor = db_conn.cursor()# 使用 execute 方法执行SQL语句cursor.execute("SELECT VERSION()")# 使用 fetchone 方法获取一条数据库。dbversion = cursor.fetchone()print "Database version : %s " % dbversion# 创建数据库cursor.execute("create database if not exists dbtest")# 选择要操作的数据库db_conn.select_db('dbtest');# 创建数据表SQL语句sql = """CREATE TABLE if not exists employee( first_name CHAR(20) NOT NULL, last_name CHAR(20), age INT, sex CHAR(1), income FLOAT )"""try: cursor.execute(sql)except Exception, e: # Exception 是所有异常的基类，这里表示捕获所有的异常 print "Error to create table:", e# 插入数据sql = """INSERT INTO employee(first_name, last_name, age, sex, income) VALUES ('%s', '%s', %d, '%s', %d)"""# Sex: Male男, Female女employees = ( {"first_name": "Mac", "last_name": "Mohan", "age": 20, "sex": "M", "income": 2000}, {"first_name": "Wei", "last_name": "Zhu", "age": 24, "sex": "M", "income": 7500}, {"first_name": "Huoty", "last_name": "Kong", "age": 24, "sex": "M", "income": 8000}, {"first_name": "Esenich", "last_name": "Lu", "age": 22, "sex": "F", "income": 3500}, {"first_name": "Xmin", "last_name": "Yun", "age": 31, "sex": "F", "income": 9500}, {"first_name": "Yxia", "last_name": "Fun", "age": 23, "sex": "M", "income": 3500} )try: # 清空表中数据 cursor.execute("delete from employee") # 执行 sql 插入语句 for employee in employees: cursor.execute(sql % (employee["first_name"], \ employee["last_name"], \ employee["age"], \ employee["sex"], \ employee["income"])) # 提交到数据库执行 db_conn.commit() # 对于支持事务的数据库， 在Python数据库编程中， # 当游标建立之时，就自动开始了一个隐形的数据库事务。 # 用 commit 方法能够提交事物except Exception, e: # Rollback in case there is any error print "Error to insert data:", e #b_conn.rollback()print "Insert rowcount:", cursor.rowcount# rowcount 是一个只读属性，并返回执行execute(方法后影响的行数。)# 数据库查询操作:# fetchone() 得到结果集的下一行 # fetchmany([size=cursor.arraysize]) 得到结果集的下几行 # fetchall() 返回结果集中剩下的所有行 try: # 执行 SQL cursor.execute("select * from employee") # 获取一行记录 rs = cursor.fetchone() print rs # 获取余下记录中的 2 行记录 rs = cursor.fetchmany(2) print rs # 获取剩下的所有记录 ars = cursor.fetchall() for rs in ars: print rs # 可以用 fetchall 获得所有记录，然后再遍历except Exception, e: print "Error to select:", e# 数据库更新操作sql = "UPDATE employee SET age = age + 1 WHERE sex = '%c'" % ('M')try: # 执行SQL语句 cursor.execute(sql) # 提交到数据库执行 db_conn.commit() cursor.execute("select * from employee") ars = cursor.fetchall() print "After update: ------" for rs in ars: print rsexcept Exception, e: # 发生错误时回滚 print "Error to update:", e db.rollback()# 关闭数据库连接db_conn.close() |
其他参考文档：
https://www.python.org/dev/peps/pep-0249/
http://wiki.python.org/moin/DatabaseInterfaces
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流。
