下文主要是针对CPython, 对于Jython, 访问数据库可以使用zxJdbc(支持DB API2.0规范), 当然也可以直接JDBC, 对于IronPython, 可以使用ADO.Net.
#==========================
# python的DB Module
#==========================
Database Modules for Python
MySQL: MySQL-python,
PostgreSQL: psycopg2,
Oracle: cx_Oracle,
mssql: pymssql,
ODBC bridge: pyodbc,
#==========================
# python的DB API
#==========================
python 定义了DB API 2.0规范, http://www.python.org/dev/peps/pep-0249/
在python的标准库中已经基于该规范实现了对sqlite3的访问. http://docs.python.org/library/sqlite3.html
对于其他数据库, 都有基于DB API 2.0的实现, cx-oracle就是针对Oracle 数据库的实现, 并做了非常棒的扩展(甚至包含一个非常好用的orm实现, Mapping的过程非常简单, 只需要给cursor.rowfactory赋值为某个类).
DB API 2.0中的几个对象:
*connection, 这个和JDBC/ADO.Net中的connection一样
*cursor, 这个比较特殊, 有点像JDBC中PreparedStatement和RowSet的混合体, 可以由connection创建cursor, 无论是执行SQL/DDL/DML都需要有cursor.execute()来执行.
如果要遍历SQL的返回集, 下面两种方法是等效的:
方法1(推荐这个写法, 更容易理解)：
cursor.excute("select * from table1")
rows=cursor.fetchall()
for row in rows
... print row
方法2：
cursor.excute("select * from table1")
for row in cursor:
... print row
#==========================
# 学习DB API的一个教程
#==========================
Fast, Easy Database Access with Python
http://www.devx.com/dbzone/Article/22093/1954
#==========================
# pyodbc的几个教程
#==========================
Linux 下使用pyodbc 连接 MSSql Server 2008
pyodbc Quick Examples
http://code.google.com/p/pyodbc/wiki/GettingStarted
Connecting to ODBC Databases from Python with pyodbc
http://www.easysoft.com/developer/languages/python/pyodbc.html
备注:
1. jython如果无法找到Oracle 或其它数据库的JDBC driver, 下面这个访问应该很有效: 将Jdbc driver的jar文件名加到jython.jar的manifest.mf文件lib path中, 需要注意manifest.mf苛刻的格式. 这个方法同样适用于, 通过jython调用第三方java类库, 比如jdom等.
2. DB API2的参数查询的2个示例. 为防止sql 注入, 应避免用%字符操作符拼接sql的方法, 第一种写法最通用, 第二种写法通用性较差,zxjdbc就不支持.
cur.execute("select name_last, age from people where name_last=? and age=?", (who, age)) #qmark style, positional parameter style
cur.execute("select * from people where name_last=:who and age=:age", {"who": who, "age": age}) #named parameter style
最后贴一个很有用的函数, 将sql以及参数都打印到logger中
#====================
#执行sql, 并将sql和参数打印到logger中
#====================
def executeSqlWithLog(logger, cursor, sql, params=None):
logger.debug('===SQL statement is:')
logger.debug(sql)
if params is not None and params.__len__()>0:
logger.debug('---SQL paramters list BEGIN:')
for param in params:
logger.debug('%s'%param)
logger.debug('---SQL paramters list END.')
cursor.execute(sql,params)