本模块主要提供了对SQLite数据库进行操作的接口。SQLite数据库是一个C写的轻量级的文件型数据库,它不需要独立的进程运行,可以直接嵌入应用程序里的数据库。本模块提供的数据库接口,与其它大型的数据库接口是一样的,因此编写的SQL语句是可以直接应用于PostgreSQL或者Oracle数据库。
为了使用本模块,需要先创建一个Connection对象,用来表示数据库接口,下面来访问数据库exampldb作为例子:
也可以使用参数:memory:来创建一个内存数据库。
一旦成功创建Connection对象,就可以使用这个对象来创建Cursor对象,并调用方法execute()来执行合法的SQL语句。
创建数据库的例子:
#创建数据库连接对象
c=concursor()
#创建数据库表
#插入一行数据
execute('INSERTINTOstocksVALUES('2016-02-16','BUY','RHAT',100,31')
#提交
#关闭连接
查询数据库的例子:
#打开数据库查询相关内容
c=concursor()
t=('RHAT',)
print(fetchone())
结果输出如下:
('2016-02-16','BUY','RHAT',100.0,31
在数据库里经常要使用SQL语句,而SQL语句又经常需要并接参数,如果使用Python里的字符串连接方式,会非常不安全,导致SQL语句注入式攻击。因此DB-API提供了问号?替换符方式来达到拼接字符串,主要使用函数execute()来实现,例子如下:
purchases=[('2006-03-28','BUY','IBM',1000,400),
('2006-04-05','BUY','MSFT',1000,700),
('2006-04-06','SELL','IBM',500,500),
]
通上面的方式可以同时插入多条数据。如果通过SELECT语句返回多条数据,可以使用迭代器的方式来访问所有返回的数据,也可以使用函数fetchone()来一条数据一条数据地返回,也可以使用函数fetchall()获取所有数据返回。下面是使用迭代器的例子:
print(row)
('2006-01-05','BUY','RHAT',100,31
('2006-03-28','BUY','IBM',1000,40)
('2006-04-06','SELL','IBM',500,50)
('2006-04-05','BUY','MSFT',1000,70)
模块函数和常量
本模块的版本号,以字符串方式返回,要注意的是,它不是SQLite数据库的版本号。
例子:
结果输出如下:
本模块的版本号,以元组方式返回,要注意的是,它不是SQLite数据库的版本号。
例子:
结果输出如下:
返回SQLite数据库的版本号,以元组的方式返回。
例子:
结果输出如下:
本常量使用在函数connect()里,设置在关键字参数detect_types上面。表示在返回一行值时,是否分析这列值的数据类型定义。如果设置了本参数,就进行分析数据表列的类型,并返回此类型的对象,并不是返回字符串的形式。
本常量使用在函数connect()里,设置在关键字参数detect_types上面。表示在返回一行值时,是否分析这列值的名称。如果设置了本参数,就进行分析数据表列的名称,并返回此类型的名称。
sqliteconnect(database[,timeout,detect_types,isolation_level,check_same_thread,factory,cached_statements,uri])
打开一个SQLite的数据库的文件连接。当参数database名称为“:memory:”时,表示创建一个内存数据库,不会在硬盘上生成文件。当有多个连接访问一个数据库时,如果其中一个进程修改这个数据库,SQLite数据库会锁这个数据库,直到这个数据库的事务完成为止。如果不想被锁住时间过长,可以使用参数timeout来设置等待超时时间,默认的值是5秒,当超时没有打开这个数据库时,就会抛出异常。
参数detect_types是用来指明前面介绍的两个参数。
参数isolation_level是同Conectioisolation_level的属性意义一样。
参数check_same_thread是用来判断是否一个线程只能使用当前线程打开的数据库连接,如果设置为False,就不判断这个。
参数factory是用来设置是否使用派生类。
参数cached_statements是用来设置SQL语句分析的缓冲大小,默认是100条语句。
参数uri设置为True时,表示按URI解析数据库名称,比如:
例子:
c=dcursor()
#插入date对象到数据库
execute('''INSERTINTOexample(created_at)VALUES(?)''',(today,))
#返回插入的对象
print('Thedateis{0}andthedatatypeis{1}'.format(row[0],type(row[0])))
dclose()
结果输出如下:
注册一个从数据库bytestring转换为自定义Python类型的调用对象。这个调用对象当数据库在读取这个类型的值时被调用。
注册一个从自定义Python类型转换为SQLite支持的数据类型。参数callable是一个单参数的调用对象,然后它把这个参数的值转换为int,float,str或者bytes类型。
如果sql包含有一条或多条完整的SQL语句,就返回True。不过本函数不会检查SQL语句的合法性。
例子:
buffer=''
line=input()
ifline=='':
print('Anerroroccurred:',args[0])
buffer=''
默认下,不能查看任何用户自定义的回调函数的输出。如果想查看相关的输出,需要调用本函数设置参数flag为True才可以。
蔡军生QQ:9073204深圳
文章为作者独立观点,不代表 股票程序化软件自动交易接口观点