文章目录
- 1. 简介
- 1.1. 使用
- 1.1.1. 创建
- 1.1.2. 插入
- 1.1.2.1. 插入一条数据
- 1.1.3. 查询
- 1.1.3.1. 查询所有数据
- 查询一条数据
- 1.1.3.2. 读取特定位置的数据
- 1.1.4. 修改数据
- 1.1.5. 删除数据
1. 简介
- 从Python3.x版本开始,在标准库中已经内置了SQLlite3模块,它可以支持SQLite3数据库的访问和相关的数据库操作。在需要操作SQLite3数据库数据时,只须在程序中导入SQLite3模块即可。
1.1. 使用
1.1.1. 创建
代码
#导入sqllite3模块 import sqlite3 # 1.硬盘上创建连接 con = sqlite3.connect('first.db') # 获取cursor对象 cur = con.cursor() # 执行sql创建表 sql = 'create table t_person(pno INTEGER PRIMARY KEY AUTOINCREMENT ,pname varchar(30) NOT NULL ,age INTEGER)' try: cur.execute(sql) except Exception as e: print(e) print('创建表失败') finally: # 关闭游标 cur.close() # 关闭连接 con.close()
1.1.2. 插入
1.1.2.1. 插入一条数据
#导入sqllite3模块 import sqlite3 # 1.硬盘上创建连接 con = sqlite3.connect('first.db') # 获取cursor对象 cur = con.cursor() # 执行sql创建表 sql = 'insert into t_person(pname,age) values(" /> 查询一条数据
fetchone()查询一条数据
按顺序进行读取
#导入sqllite3模块 import sqlite3 # 1.硬盘上创建连接 con = sqlite3.connect('first.db') # 获取cursor对象 cur = con.cursor() # 执行sql创建表 sql = 'select * from t_person' try: cur.execute(sql) # 获取一条数据 person = cur.fetchone() print(person) person = cur.fetchone() print(person) person = cur.fetchone() print(person) person = cur.fetchone() print(person) except Exception as e: print(e) print('查询失败') finally: # 关闭游标 cur.close() # 关闭连接 con.close()
1.1.3.2. 读取特定位置的数据
- 需要把读取的信息放到sql语句中
获得最新一条数据 - 代码
def sqlite3_get_last_data(db_path,sql): # 导入sqllite3模块 import sqlite3 # 1.硬盘上创建连接 con = sqlite3.connect(db_path) # 获取cursor对象 cur = con.cursor() # 执行sql创建表 try: cur.execute(sql) # 获取所有数据 person_all = cur.fetchall() last_data = person_all[-1] # print(last_data) # print("type(last_data):", type(last_data)) # print("last_data:", ) last_text = last_data[6] return last_text except Exception as e: print(e) print('查询失败') finally: # 关闭游标 cur.close() # 关闭连接 con.close() db_path = 'D:\MailMasterData\hengzhe19711121@163.com_1414\search.db' sql = 'select * from Search_content' last_text = sqlite3_get_last_data(db_path,sql) print("last_text:", last_text)
1.1.4. 修改数据
代码
#导入sqllite3模块 import sqlite3 #1.硬盘上创建连接 con=sqlite3.connect('first.db') #获取cursor对象 cur=con.cursor() try: #执行sql创建表 update_sql = 'update t_person set pname=" /> 1.1.5. 删除数据
代码
#导入sqllite3模块 import sqlite3 #1.硬盘上创建连接 con=sqlite3.connect('first.db') #获取cursor对象 cur=con.cursor() #执行sql创建表 delete_sql = 'delete from t_person where pno=?' try: cur.execute(delete_sql, (2,)) #提交事务 con.commit() print('删除成功') except Exception as e: print(e) print('删除失败') con.rollback() finally: # 关闭游标 cur.close() # 关闭连接 con.close()
:
cur.execute(delete_sql, (2,))
#提交事务
con.commit()
print(‘删除成功’)
except Exception as e:
print(e)
print(‘删除失败’)
con.rollback()
finally:
# 关闭游标
cur.close()
# 关闭连接
con.close()
- ![](https://img-blog.csdnimg.cn/img_convert/7fb8efddb56baf993b17041d70b8e908.png)