一、Python操作SQLite3数据库的基本流程
1.导入相关库或模块
2.使用connect()连接数据库并获取数据库连接对象，它有以下方法：
| 方法 | 说明 | | .cursor() | 创建一个游标对象 | | .commit() | 处理事务提交 | | .rollback() | 处理事务回滚 | | .close() | 关闭一个数据库连接 |
3.使用con.cursor()方法获取游标对象
4.使用游标对象的方法（execute()、executemany()、fetchall()等）操作数据库，实现插入、修改、删除等相关操作，并查询获取相关记录，连接函数sqlite3.connect()有以下两个参数
database:表示要访问的数据库名
timeout:表示访问数据的超时设定
5、使用close()关闭游标对象和数据库连接，数据库操作完成后，必须及时调用close()方法关闭数据库连接，以减轻数据库服务器压力
二、使用SQLite3创建表
'''
1.导入sqlite3模块
2.sqlite3.connect()创建连接
3.创建游标对象
4.编写创建表的sql语句
5.执行sql
6.关闭连接
'''
import sqlite3
con=sqlite3.connect('D:/sqlite3Demo/demo.db')
cur=con.cursor()
sql='''create table t_person(
pno INTEGER primary key autoincrement,
pname VARCHAR not null,
age INTEGER
)'''
try:
cur.execute(sql)
print("创建成功")
except Exception as e:
print(e)
print("创建失败")
finally:
cur.close()
con.close()
三、使用SQLite3插入数据
1.使用游标对象的execute()执行插入sql语句，使用executemany()执行多条sql语句，使用executemany()比循环使用execute()执行多条sql语句效率高
2.示例插入一条数据：
#导入模块
import sqlite3
#创建连接
con=sqlite3.connect('D:/sqlite3Demo/demo.db')
#创建游标对象
cur=con.cursor()
#编写插入sql
sql='insert into t_person(pname,age) values(?,?)'
try:
#执行sql
cur.execute(sql,('小明，18'))
#提交事务
con.commit()
print("插入数据成功")
except Exception as e:
print(e)
con.rollback()
print("插入失败")
finally:
#关闭游标连接
cur.close()
#关闭数据库连接
con.close()
3.示例插入多条数据：
#导入模块
import sqlite3
#创建连接
con=sqlite3.connect('D:/sqlite3Demo/demo.db')
#创建游标对象
cur=con.cursor()
#编写插入sql
sql='insert into t_person(pname,age) values(?,?)'
try:
#执行插入多条数据的sql
cur.executemany(sql,[('小李，18'),("小红",19),("小芳",20)])
#提交事务
con.commit()
print("插入多条数据成功")
except Exception as e:
print(e)
con.rollback()
print("插入多条数据失败")
finally:
#关闭游标连接
cur.close()
#关闭数据库连接
con.close()
三、使用SQLite3查询数据
1.对于查询数据，游标对象提供了fetchall()和fetchone()方法，其中fetchall()方法获取所有数据，返回一个列表，fetchone()方法获取其中一个结果，返回一个元组
2示例fetchall()：
#导入模块
import sqlite3
#创建连接
con=sqlite3.connect('D:/sqlite3Demo/demo.db')
#创建游标对象
cur=con.cursor()
#创建查询sql
sql='select * from t_person'
try:
cur.execute(sql)
#获取结果集
person_all=cur.fetchall()
print(person_all)
for person in person_all: #循环遍历
print(person)
except Exception as e:
print(e)
print("查询所有数据失败")
finally:
#关闭游标对象
cur.close()
#关闭连接
con.close()
(1,'小明',18)
(2,'小李',18)
(3,'小红',19)
(4,'小芳',20)
3.示例fetchone():
#导入模块
import sqlite3
#创建连接
con=sqlite3.connect('D:/sqlite3Demo/demo.db')
#创建游标对象
cur=con.cursor()
#创建查询sql
sql='select * from t_person'
try:
cur.execute(sql)
#获取一条数据
person=cur.fetchone()
print(person)
except Exception as e:
print(e)
print("查询所有数据失败")
finally:
#关闭游标对象
cur.close()
#关闭连接
con.close()
(1,'小明',18)
四、SQLite3修改、删除数据
1.利用SQLite3修改数据:
#导入模块
import sqlite3
#创建连接
con=sqlite3.connect('D:/sqlite3Demo/demo.db')
#创建游标对象
cur=con.cursor()
#编写sql修改语句
sql='update t_person set pname=? where pno=?'
#执行sql
try:
cur.execute(sql,('小王',1))
#提交事务
con.commit()
print("修改成功")
except Exception as e:
print(e)
print("修改失败")
con.rollback()
finally:
#关闭游标对象
cur.close()
#关闭连接
con.close()
2.利用SQLite3删除数据：
#导入模块
import sqlite3
#创建连接
con=sqlite3.connect('D:/sqlite3Demo/demo.db')
#创建游标对象
cur=con.cursor()
#编写sql删除语句
sql='delete from t_person where pno=?'
#执行sql
try:
cur.execute(sql,(1,)) #元组中一个元素后面要加，
#提交事务
con.commit()
print("删除成功")
except Exception as e:
print(e)
print("删除失败")
con.rollback()
finally:
#关闭游标对象
cur.close()
#关闭连接
con.close()
|