python的数据库模块

下文主要是针对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
http://blog.csdn.net/ojtojt/article/details/3846990
    
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)