python之数据库支持-阿里云开发者社区

开发者社区> 数据库> 正文
登录阅读全文

python之数据库支持

简介:

13.1.1 全局变量

任何支持2.0版本DB API的数据库模块都必须定义3个描述模块特性的全局变量。这样做的原因时API设计的很灵活,以支持不同的基础机制、避免过多包装,可如果想让程序同时应用于几个数据库,那可是件麻烦事了,因为需要考虑到各种可能出现的状况。


变量名 用途

apilevel 所使用的python DB API版本

threadsafety 模块的线程安全等级

paramstyle 在SQL查询中使用的参数风格

API级别是个字符串常量,提供正在使用的API版本号。

线程安全性等级是个取值范围0~3的整数。0表示线程完全不共享模块,而3表示模块是安全线程安全的。1表示线程本身可以共享模块,但不对连接共享。如果不使用多个线程,那么完全不用担心这个变量。

参数风格表示执行多次类似查询的时候,参数是如何被拼接到SQL查询中的。


13.1.2 异常

为了能尽可能准确的处理错误,API中定义了一些异常类。它们被定义在一种层次结构中,所以可以通过一个except块捕捉多种异常。


13.1.3 连接和游标

为了使用基础数据库系统,首先必须连接到它。这个时候需要使用具有恰当名称的connect函数,该函数有很多参数,而具体使用哪个参数取决于数据库。

connect函数的常用参数

dsn 数据源名称,给出该参数表示数据库依赖

user 用户名

password 用户密码

host 主机名

database 数据库名


connect函数返回连接对象,这个对象表示目前和数据库的会话。

连接对象方法

close() 关闭连接之后,连接对象和它的游标均不可用

commit() 如果支持的话就提交挂起的事务,否则不做任何事

rollback() 回滚挂起的事务(可能不可用)

cursor() 返回连接的游标对象


cursor方法将我们引入另外一个主题:游标对象。通过游标执行sql查询并检查结果。游标比连接支持更多的方法。



13.1.4 类型

数据库对插入到具有某种类型的列中的值有不同的要求,是为了能正确地与基础sql数据库进行交互操作,DB API定义了用于特殊类型和值的构造函数及常量。


13.2.1 入门

这里以SQLite数据库作为示例。


将SQLite作为名为sqlite3的模块导入。之后就可以创建一个到数据库文件的连接----如果文件不存在就会被创建----通过提供一个文件名:

>>>import sqlite3

>>>conn = sqlite3.connect('somedatabase.db')

之后就能获得连接的游标:

>>>curs = conn.cursor()

这个游标可以用来执行sql查询,完成查询并且做出某些更改后确保已经进行了提交,这样才可以将这些修改真正的保存到文件中:

>>>conn.commit()

可以在每次修改数据库后都进行提交,而不是仅仅在准备关闭时才提交,准备关闭数据库时,使用close方法:

>>>conn.close()


13.2.2 数据库应用程序示例

1.创建和填充表

为了真正地创建数据库表并且向其中插入数据,写个完全独立的一次程序可能是最简单的方案。


下面程序创建了叫做food的表和适当的字段,并且从ABBREV.txt中读取数据。之后分解析,然后通过调用curs.execute执行SQL的INSERT语句将文本字段中的值插入到数据库中。

将数据导入数据库

import sqlite3

def convert(value)

if value.startswith('~'):

return value.strip('~')

if not value:

value = '0'

return float(value)

conn = sqlite3.connect('food.db')

curs = conn.cursor()


curs.execute('''

CREATE TABLE food (

id TEXT PRIMARY KEY,

desc TEXT,

water FLOAT,

kcal FLOAT,

ash FLOAT,

fiber FLOAT

)

''')

query = 'INSERT INTO food VALUES(?,?,?,?,?,?)'

for line in open('ABBREV.txt'):

fileds = line.split('^')

vals = [convert(f) for f in fileds[:filed_count]]

curs.execute(query,vals)

conn.commit()

conn.close()


当运行这个程序时,它会创建一个叫做food.db的新文件,它包含数据库中的所有数据。


2.搜索和处理结果

使用数据库很简单。再说一次,需要创建连接并且获得该链接的游标。使用execute方法执行sql查询,用fetchall等方法提取结果。

展示一个将SQL SELECT条件查询作为命令行参数,之后按记录格式打印出返回行的小程序。可以用下面的命令尝试这个程序:

$python food_query.py "kcal <= 100 AND fiber >= 10 ORDER BY sugar"

运行的时候可能注意到有个问题。第一行,生橘子皮看起来不含任何糖分,这是因为在数据文件中这个字段丢失了。可以改进刚才的导入脚本检测条件,然后插入None带代替真实的值来表示丢失的数据。可以使用如下条件:

"kcal <= 100 AND fiber >= 10 AND sugar ORDER BY sugar"

请求在任何返回行中包含实际数据的糖分字段。

食品数据库查询程序(food_query.py)

import sqlite3,sys

conn = sqlite3.connect('food.db')

curs = conn.cursor()


query = 'SELECT * FROM food WHERE %s' % sys.argv[1]

print query

curs.execute(query)

names = [f[0] for f in curs.description]

for row in curs.fetchall():

for pair in zip(names,row):

print '%s: %s' % pair

print



      本文转自潘阔 51CTO博客,原文链接:http://blog.51cto.com/pankuo/1661447,如需转载请自行联系原作者





版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
数据库
使用钉钉扫一扫加入圈子
+ 订阅

分享数据库前沿,解构实战干货,推动数据库技术变革

其他文章