Python开发SQLite3数据库相关操作详解【连接,查询,插入,更新,删除,关闭等】
本文实例讲述了Python开发SQLite3数据库相关操作。分享给大家供大家参考,具体如下:
'''SQLite数据库是一款非常小巧的嵌入式开源数据库软件,也就是说
没有独立的维护进程,所有的维护都来自于程序本身。
在python中,使用sqlite3创建数据库的连接,当我们指定的数据库文件不存在的时候
连接对象会自动创建数据库文件;如果数据库文件已经存在,则连接对象不会再创建
数据库文件,而是直接打开该数据库文件。
连接对象可以是硬盘上面的数据库文件,也可以是建立在内存中的,在内存中的数据库
执行完任何操作后,都不需要提交事务的(commit)
创建在硬盘上面:conn=sqlite3.connect('c:\\test\\test.db')
创建在内存上面:conn=sqlite3.connect('"memory:')
下面我们一硬盘上面创建数据库文件为例来具体说明:
conn=sqlite3.connect('c:\\test\\hongten.db')
其中conn对象是数据库链接对象,而对于数据库链接对象来说,具有以下操作:
commit()--事务提交
rollback()--事务回滚
close()--关闭一个数据库链接
cursor()--创建一个游标
cu=conn.cursor()
这样我们就创建了一个游标对象:cu
在sqlite3中,所有sql语句的执行都要在游标对象的参与下完成
对于游标对象cu,具有以下具体操作:
execute()--执行一条sql语句
executemany()--执行多条sql语句
close()--游标关闭
fetchone()--从结果中取出一条记录
fetchmany()--从结果中取出多条记录
fetchall()--从结果中取出所有记录
scroll()--游标滚动
'''
下面是我做的demo,在demo中,我做了很详细的注释和功能的演示,详情如下:
当SHOW_SQL=False的时候:
Python3.3.2(v3.3.2:d047928ae3f6,May162013,00:03:43)[MSCv.160032bit(Intel)]onwin32 Type"copyright","credits"or"license()"formoreinformation. >>>================================RESTART================================ >>> show_sql:False 删除数据库表测试... 硬盘上面:[c:\test\hongten.db] 删除数据库表[student]成功! 创建数据库表测试... 硬盘上面:[c:\test\hongten.db] 创建数据库表[student]成功! 保存数据测试... 硬盘上面:[c:\test\hongten.db] 查询所有数据... 硬盘上面:[c:\test\hongten.db] (1,'Hongten','男',20,'广东省广州市','13423****62') (2,'Tom','男',22,'美国旧金山','15423****63') (3,'Jake','女',18,'广东省广州市','18823****87') (4,'Cate','女',21,'广东省广州市','14323****32') ################################################## 查询一条数据... 硬盘上面:[c:\test\hongten.db] (1,'Hongten','男',20,'广东省广州市','13423****62') ################################################## 更新数据... 硬盘上面:[c:\test\hongten.db] 查询所有数据... 硬盘上面:[c:\test\hongten.db] (1,'HongtenAA','男',20,'广东省广州市','13423****62') (2,'HongtenBB','男',22,'美国旧金山','15423****63') (3,'HongtenCC','女',18,'广东省广州市','18823****87') (4,'HongtenDD','女',21,'广东省广州市','14323****32') ################################################## 删除数据... 硬盘上面:[c:\test\hongten.db] 查询所有数据... 硬盘上面:[c:\test\hongten.db] (2,'HongtenBB','男',22,'美国旧金山','15423****63') (4,'HongtenDD','女',21,'广东省广州市','14323****32') >>>
当SHOW_SQL=True的时候:
Python3.3.2(v3.3.2:d047928ae3f6,May162013,00:03:43)[MSCv.160032bit(Intel)]onwin32
Type"copyright","credits"or"license()"formoreinformation.
>>>================================RESTART================================
>>>
show_sql:True
删除数据库表测试...
硬盘上面:[c:\test\hongten.db]
执行sql:[DROPTABLEIFEXISTSstudent]
删除数据库表[student]成功!
创建数据库表测试...
硬盘上面:[c:\test\hongten.db]
执行sql:[CREATETABLE`student`(
`id`int(11)NOTNULL,
`name`varchar(20)NOTNULL,
`gender`varchar(4)DEFAULTNULL,
`age`int(11)DEFAULTNULL,
`address`varchar(200)DEFAULTNULL,
`phone`varchar(20)DEFAULTNULL,
PRIMARYKEY(`id`)
)]
创建数据库表[student]成功!
保存数据测试...
硬盘上面:[c:\test\hongten.db]
执行sql:[INSERTINTOstudentvalues(?,?,?,?,?,?)],参数:[(1,'Hongten','男',20,'广东省广州市','13423****62')]
执行sql:[INSERTINTOstudentvalues(?,?,?,?,?,?)],参数:[(2,'Tom','男',22,'美国旧金山','15423****63')]
执行sql:[INSERTINTOstudentvalues(?,?,?,?,?,?)],参数:[(3,'Jake','女',18,'广东省广州市','18823****87')]
执行sql:[INSERTINTOstudentvalues(?,?,?,?,?,?)],参数:[(4,'Cate','女',21,'广东省广州市','14323****32')]
查询所有数据...
硬盘上面:[c:\test\hongten.db]
执行sql:[SELECT*FROMstudent]
(1,'Hongten','男',20,'广东省广州市','13423****62')
(2,'Tom','男',22,'美国旧金山','15423****63')
(3,'Jake','女',18,'广东省广州市','18823****87')
(4,'Cate','女',21,'广东省广州市','14323****32')
##################################################
查询一条数据...
硬盘上面:[c:\test\hongten.db]
执行sql:[SELECT*FROMstudentWHEREID=?],参数:[1]
(1,'Hongten','男',20,'广东省广州市','13423****62')
##################################################
更新数据...
硬盘上面:[c:\test\hongten.db]
执行sql:[UPDATEstudentSETname=?WHEREID=?],参数:[('HongtenAA',1)]
执行sql:[UPDATEstudentSETname=?WHEREID=?],参数:[('HongtenBB',2)]
执行sql:[UPDATEstudentSETname=?WHEREID=?],参数:[('HongtenCC',3)]
执行sql:[UPDATEstudentSETname=?WHEREID=?],参数:[('HongtenDD',4)]
查询所有数据...
硬盘上面:[c:\test\hongten.db]
执行sql:[SELECT*FROMstudent]
(1,'HongtenAA','男',20,'广东省广州市','13423****62')
(2,'HongtenBB','男',22,'美国旧金山','15423****63')
(3,'HongtenCC','女',18,'广东省广州市','18823****87')
(4,'HongtenDD','女',21,'广东省广州市','14323****32')
##################################################
删除数据...
硬盘上面:[c:\test\hongten.db]
执行sql:[DELETEFROMstudentWHERENAME=?ANDID=?],参数:[('HongtenAA',1)]
执行sql:[DELETEFROMstudentWHERENAME=?ANDID=?],参数:[('HongtenCC',3)]
查询所有数据...
硬盘上面:[c:\test\hongten.db]
执行sql:[SELECT*FROMstudent]
(2,'HongtenBB','男',22,'美国旧金山','15423****63')
(4,'HongtenDD','女',21,'广东省广州市','14323****32')
>>>
具体代码:
#pythonsqlite
#Author:Hongten
#Create:2013-08-09
#Version:1.0
#DB-API2.0interfaceforSQLitedatabases
importsqlite3
importos
'''SQLite数据库是一款非常小巧的嵌入式开源数据库软件,也就是说
没有独立的维护进程,所有的维护都来自于程序本身。
在python中,使用sqlite3创建数据库的连接,当我们指定的数据库文件不存在的时候
连接对象会自动创建数据库文件;如果数据库文件已经存在,则连接对象不会再创建
数据库文件,而是直接打开该数据库文件。
连接对象可以是硬盘上面的数据库文件,也可以是建立在内存中的,在内存中的数据库
执行完任何操作后,都不需要提交事务的(commit)
创建在硬盘上面:conn=sqlite3.connect('c:\\test\\test.db')
创建在内存上面:conn=sqlite3.connect('"memory:')
下面我们一硬盘上面创建数据库文件为例来具体说明:
conn=sqlite3.connect('c:\\test\\hongten.db')
其中conn对象是数据库链接对象,而对于数据库链接对象来说,具有以下操作:
commit()--事务提交
rollback()--事务回滚
close()--关闭一个数据库链接
cursor()--创建一个游标
cu=conn.cursor()
这样我们就创建了一个游标对象:cu
在sqlite3中,所有sql语句的执行都要在游标对象的参与下完成
对于游标对象cu,具有以下具体操作:
execute()--执行一条sql语句
executemany()--执行多条sql语句
close()--游标关闭
fetchone()--从结果中取出一条记录
fetchmany()--从结果中取出多条记录
fetchall()--从结果中取出所有记录
scroll()--游标滚动
'''
#globalvar
#数据库文件绝句路径
DB_FILE_PATH=''
#表名称
TABLE_NAME=''
#是否打印sql
SHOW_SQL=True
defget_conn(path):
'''获取到数据库的连接对象,参数为数据库文件的绝对路径
如果传递的参数是存在,并且是文件,那么就返回硬盘上面改
路径下的数据库文件的连接对象;否则,返回内存中的数据接
连接对象'''
conn=sqlite3.connect(path)
ifos.path.exists(path)andos.path.isfile(path):
print('硬盘上面:[{}]'.format(path))
returnconn
else:
conn=None
print('内存上面:[:memory:]')
returnsqlite3.connect(':memory:')
defget_cursor(conn):
'''该方法是获取数据库的游标对象,参数为数据库的连接对象
如果数据库的连接对象不为None,则返回数据库连接对象所创
建的游标对象;否则返回一个游标对象,该对象是内存中数据
库连接对象所创建的游标对象'''
ifconnisnotNone:
returnconn.cursor()
else:
returnget_conn('').cursor()
###############################################################
####创建|删除表操作START
###############################################################
defdrop_table(conn,table):
'''如果表存在,则删除表,如果表中存在数据的时候,使用该
方法的时候要慎用!'''
iftableisnotNoneandtable!='':
sql='DROPTABLEIFEXISTS'+table
ifSHOW_SQL:
print('执行sql:[{}]'.format(sql))
cu=get_cursor(conn)
cu.execute(sql)
conn.commit()
print('删除数据库表[{}]成功!'.format(table))
close_all(conn,cu)
else:
print('the[{}]isemptyorequalNone!'.format(sql))
defcreate_table(conn,sql):
'''创建数据库表:student'''
ifsqlisnotNoneandsql!='':
cu=get_cursor(conn)
ifSHOW_SQL:
print('执行sql:[{}]'.format(sql))
cu.execute(sql)
conn.commit()
print('创建数据库表[student]成功!')
close_all(conn,cu)
else:
print('the[{}]isemptyorequalNone!'.format(sql))
###############################################################
####创建|删除表操作END
###############################################################
defclose_all(conn,cu):
'''关闭数据库游标对象和数据库连接对象'''
try:
ifcuisnotNone:
cu.close()
finally:
ifcuisnotNone:
cu.close()
###############################################################
####数据库操作CRUDSTART
###############################################################
defsave(conn,sql,data):
'''插入数据'''
ifsqlisnotNoneandsql!='':
ifdataisnotNone:
cu=get_cursor(conn)
fordindata:
ifSHOW_SQL:
print('执行sql:[{}],参数:[{}]'.format(sql,d))
cu.execute(sql,d)
conn.commit()
close_all(conn,cu)
else:
print('the[{}]isemptyorequalNone!'.format(sql))
deffetchall(conn,sql):
'''查询所有数据'''
ifsqlisnotNoneandsql!='':
cu=get_cursor(conn)
ifSHOW_SQL:
print('执行sql:[{}]'.format(sql))
cu.execute(sql)
r=cu.fetchall()
iflen(r)>0:
foreinrange(len(r)):
print(r[e])
else:
print('the[{}]isemptyorequalNone!'.format(sql))
deffetchone(conn,sql,data):
'''查询一条数据'''
ifsqlisnotNoneandsql!='':
ifdataisnotNone:
#Dothisinstead
d=(data,)
cu=get_cursor(conn)
ifSHOW_SQL:
print('执行sql:[{}],参数:[{}]'.format(sql,data))
cu.execute(sql,d)
r=cu.fetchall()
iflen(r)>0:
foreinrange(len(r)):
print(r[e])
else:
print('the[{}]equalNone!'.format(data))
else:
print('the[{}]isemptyorequalNone!'.format(sql))
defupdate(conn,sql,data):
'''更新数据'''
ifsqlisnotNoneandsql!='':
ifdataisnotNone:
cu=get_cursor(conn)
fordindata:
ifSHOW_SQL:
print('执行sql:[{}],参数:[{}]'.format(sql,d))
cu.execute(sql,d)
conn.commit()
close_all(conn,cu)
else:
print('the[{}]isemptyorequalNone!'.format(sql))
defdelete(conn,sql,data):
'''删除数据'''
ifsqlisnotNoneandsql!='':
ifdataisnotNone:
cu=get_cursor(conn)
fordindata:
ifSHOW_SQL:
print('执行sql:[{}],参数:[{}]'.format(sql,d))
cu.execute(sql,d)
conn.commit()
close_all(conn,cu)
else:
print('the[{}]isemptyorequalNone!'.format(sql))
###############################################################
####数据库操作CRUDEND
###############################################################
###############################################################
####测试操作START
###############################################################
defdrop_table_test():
'''删除数据库表测试'''
print('删除数据库表测试...')
conn=get_conn(DB_FILE_PATH)
drop_table(conn,TABLE_NAME)
defcreate_table_test():
'''创建数据库表测试'''
print('创建数据库表测试...')
create_table_sql='''CREATETABLE`student`(
`id`int(11)NOTNULL,
`name`varchar(20)NOTNULL,
`gender`varchar(4)DEFAULTNULL,
`age`int(11)DEFAULTNULL,
`address`varchar(200)DEFAULTNULL,
`phone`varchar(20)DEFAULTNULL,
PRIMARYKEY(`id`)
)'''
conn=get_conn(DB_FILE_PATH)
create_table(conn,create_table_sql)
defsave_test():
'''保存数据测试...'''
print('保存数据测试...')
save_sql='''INSERTINTOstudentvalues(?,?,?,?,?,?)'''
data=[(1,'Hongten','男',20,'广东省广州市','13423****62'),
(2,'Tom','男',22,'美国旧金山','15423****63'),
(3,'Jake','女',18,'广东省广州市','18823****87'),
(4,'Cate','女',21,'广东省广州市','14323****32')]
conn=get_conn(DB_FILE_PATH)
save(conn,save_sql,data)
deffetchall_test():
'''查询所有数据...'''
print('查询所有数据...')
fetchall_sql='''SELECT*FROMstudent'''
conn=get_conn(DB_FILE_PATH)
fetchall(conn,fetchall_sql)
deffetchone_test():
'''查询一条数据...'''
print('查询一条数据...')
fetchone_sql='SELECT*FROMstudentWHEREID=?'
data=1
conn=get_conn(DB_FILE_PATH)
fetchone(conn,fetchone_sql,data)
defupdate_test():
'''更新数据...'''
print('更新数据...')
update_sql='UPDATEstudentSETname=?WHEREID=?'
data=[('HongtenAA',1),
('HongtenBB',2),
('HongtenCC',3),
('HongtenDD',4)]
conn=get_conn(DB_FILE_PATH)
update(conn,update_sql,data)
defdelete_test():
'''删除数据...'''
print('删除数据...')
delete_sql='DELETEFROMstudentWHERENAME=?ANDID=?'
data=[('HongtenAA',1),
('HongtenCC',3)]
conn=get_conn(DB_FILE_PATH)
delete(conn,delete_sql,data)
###############################################################
####测试操作END
###############################################################
definit():
'''初始化方法'''
#数据库文件绝句路径
globalDB_FILE_PATH
DB_FILE_PATH='c:\\test\\hongten.db'
#数据库表名称
globalTABLE_NAME
TABLE_NAME='student'
#是否打印sql
globalSHOW_SQL
SHOW_SQL=True
print('show_sql:{}'.format(SHOW_SQL))
#如果存在数据库表,则删除表
drop_table_test()
#创建数据库表student
create_table_test()
#向数据库表中插入数据
save_test()
defmain():
init()
fetchall_test()
print('#'*50)
fetchone_test()
print('#'*50)
update_test()
fetchall_test()
print('#'*50)
delete_test()
fetchall_test()
if__name__=='__main__':
main()
更多关于Python相关内容感兴趣的读者可查看本站专题:《Python常见数据库操作技巧汇总》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。