python 的sqlite3连接模块用法.docx

? python在2.5版以后，就自带了sqlite3模块，直接import即可。 ? 模块可用后，就可以实现连接sqlite数据库的功能。sqlite3数据库与mysql不同，它每一个库叫做一个文件，连接的时候，库名即文件名，库内的表则操作方法与mysql相同，或许支持的sql语句会有一些差异。 ? 我根据连接mysql的操作方法的包装，改写成了这个sqlite数据库连接模块。附件有这个源码。 ? ? Python代码?? #coding=gbk?? import?os,sys,string?? import?sqlite3?? import?traceback?? ?? class?SQLObj(object):?? ????def?__init__(self,?db?=?youmoney):?? ????????self.db_name?=?db?? ????????self.connected?=?0?? ????????self.cur??=?None?#?指针对象?? ????????self.conn?=?None?#?连接对象?? ????????self._connect()?? ?? ????def?_connect(self):?? ????????try:?? ????????????#print?connect?to?,?self.db_name?? ????????????self.conn?=?sqlite3.connect(self.db_name)?? ????????????self.cur?=?self.conn.cursor()?? ????????????self.connected?=?1?? ????????except:?? ????????????traceback.print_exc()?? ????????????self.connected?=?0?? ? ????@property?? ????def?is_connected(self):?? ????????return?self.connected?!=?0?? ?? ????def?_check_alive(self):?? ????????if?not?self.is_connected:?? ????????????self._connect()?? ????????if?not?self.is_connected:?? ????????????raise?Cant?connect?to?sqlite3?? ?? ????#直接提取方法?? ????def?query(self,?sql,?warning=1):?? ????????self._check_alive()?? ????????try:?? ????????????cur?=?self.conn.cursor()?? ????????????cur.execute(sql)?? ????????????res?=?cur.fetchall()?? ????????????cur.close()?? ????????except:?? ????????????if?warning:?? ????????????????traceback.print_exc()?? ????????????return?None?? ????????return?res?? ?? ?? ????#特殊的提取方法，形成字典返回?? ????def?dquery(self,?sql,?warning=1):?? ????????self._check_alive()?? ????????try:?? ????????????cur?=?self.conn.cursor()?? ????????????cur.execute(sql)?? ?????????????? ????????????des?=?cur.description?#获取字段描述?? ????????????res?=?cur.fetchall()??#获取字段内容?? ????????????ret?=?[]?? ????????????if?des:?? ????????????????names?=?[x[0]?for?x?in?des]?#从des中提取每个元素（列表）的第一个元素（字符串）?? ????????????????for?line?in?res:?? ????????????????????ret.append(dict(zip(names,?line)))?#dict是形成字典的工厂函数，zip用于多个列表循环(name,?line是两个列表)?? ????????????e