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程序设计有所帮助。