python+sqlite3-数据库增删改查操作

目录

01、sqlite数据库

简介：SQLite，是一款轻型的数据库，它包含在一个相对小的C库中，很多嵌入式产品中使用了它，其中python就嵌入了它。 至2021年已经接近有21个年头，SQLite也迎来了一个版本 SQLite 3已经发布。

02、下载数据库可视化工具

简称：DB4S

全称：DB Browser for SQLite

简介：(DB4S) 是一种高质量、可视化、开源的工具，用于创建、设计和编辑与 SQLite 兼容的数据库文件。DB4S 适用于想要创建、搜索和编辑数据库的用户和开发人员。DB4S 使用熟悉的类似电子表格的界面，无需学习复杂的 SQL 命令。

下载连接：DB Browser for SQLite

03、创建数据库

注：本文以学生信息为数据库进行讲解

保存路径：python项目文件夹

数据库名：student_data

文件扩展名：.db

表名：student

创建数据库-student表

字段：

名称类型非空主键自增注释
idINTEGER√√√序号，自增，无需用户添加
snameTEXT√××学生姓名
sageINTEGER√××学生年龄

手动添加测试数据：

snamesage
张三18
李四19
王五20

图示：

测试数据

04、python连接数据库
# 导入sqlite3模块
from sqlite3 import Error
import sqlite3


# try-except:防止因连接失败导致程序崩溃
try:
    # 数据库文件路径
    db_file = 'student_data.db'
    # 连接数据库
    conn = sqlite3.connect(db_file)
    # 创建游标
    cour = conn.cursor()
    # 测试是否连接成功
    print('连接成功')
    # 关闭游标
    cour.close()
    # 关闭连接
    conn.close()
except Error as e:
    print('连接失败')
05、查询数据

(1)、查询所有student信息

# 导入sqlite3模块
from sqlite3 import Error
import sqlite3


# try-except:防止因连接失败导致程序崩溃
try:
    # 数据库文件路径
    db_file = 'student_data.db'
    # 连接数据库
    conn = sqlite3.connect(db_file)
    # 创建游标
    cour = conn.cursor()
    # 编写sql语句
    # 查询语句sql：select 列名(*-所有列) from 表名 [where 条件]
    sql = 'select * from student'
    # 执行sql语句
    cour.execute(sql)
    # 打印查询结果
    print(cour.fetchall())
    # 关闭游标
    cour.close()
    # 关闭连接
    conn.close()
except Error as e:
    print('连接失败')

(2)、条件查询student信息

# 导入sqlite3模块
from sqlite3 import Error
import sqlite3


# try-except:防止因连接失败导致程序崩溃
try:
    # 数据库文件路径
    db_file = 'student_data.db'
    # 连接数据库
    conn = sqlite3.connect(db_file)
    # 创建游标
    cour = conn.cursor()
    # 编写sql语句
    # 查询语句sql：select 列名(*-所有列) from 表名 [where 条件]
    # ?-占位符，在cour.execute()参数中，传入数据元组
    sql = 'select * from student where sname=?'
    # 构建数据元组
    name = ('张三',)
    # 执行sql语句
    cour.execute(sql, name)
    # 打印查询结果
    print(cour.fetchall())
    # 关闭游标
    cour.close()
    # 关闭连接
    conn.close()
except Error as e:
    print('连接失败')
06、增加数据

(1)、增加单条student信息

# 导入sqlite3模块
from sqlite3 import Error
import sqlite3


# try-except:防止因连接失败导致程序崩溃
try:
    # 数据库文件路径
    db_file = 'student_data.db'
    # 连接数据库
    conn = sqlite3.connect(db_file)
    # 创建游标
    cour = conn.cursor()
    # 编写sql语句
    # 添加语句sql：INSERT INTO 表名(列名)
    # VALUES (<列1的值>,[<列2的值>,<列3的值>]);
    # ?-占位符，在cour.execute()参数中，传入数据元组
    # 由于id设置了自增，不需要我们进行输入
    sql = 'INSERT INTO student(sname, sage) VALUES (?, ?);'
    # 构建数据元组
    student_data = ('沐沐',18)
    # 执行sql语句
    cour.execute(sql, student_data)
    # 提交数据-同步到数据库文件-增删改查，除了查询以外有需要进行提交
    conn.commit()
    # 打印受影响的行数
    print(cour.rowcount)
    # 关闭游标
    cour.close()
    # 关闭连接
    conn.close()
except Error as e:
    print('连接失败')

(2)、增加多条student信息

# 导入sqlite3模块
from sqlite3 import Error
import sqlite3


# try-except:防止因连接失败导致程序崩溃
try:
    # 数据库文件路径
    db_file = 'student_data.db'
    # 连接数据库
    conn = sqlite3.connect(db_file)
    # 创建游标
    cour = conn.cursor()
    # 编写sql语句
    # 添加语句sql：INSERT INTO 表名(列名)
    # VALUES (<列1的值>,[<列2的值>,<列3的值>]);
    # ?-占位符，在cour.execute()参数中，传入数据元组
    # 由于id设置了自增，不需要我们进行输入
    sql = 'INSERT INTO student(sname, sage) VALUES (?, ?);'
    # 构建数据元组列表
    student_data = [('沐风', 18), ('若若', 19), ('柜子', 20)]
    # 执行sql语句
    cour.executemany(sql, student_data)
    # 提交数据-同步到数据库文件-增删改查，除了查询以外有需要进行提交
    conn.commit()
    # 打印受影响的行数
    print(cour.rowcount)
    # 关闭游标
    cour.close()
    # 关闭连接
    conn.close()
except Error as e:
    print('连接失败')
07、修改数据
# 导入sqlite3模块
from sqlite3 import Error
import sqlite3


# try-except:防止因连接失败导致程序崩溃
try:
    # 数据库文件路径
    db_file = 'student_data.db'
    # 连接数据库
    conn = sqlite3.connect(db_file)
    # 创建游标
    cour = conn.cursor()
    # 编写sql语句
    # 修改语句sql：UPDATE  <表名>
    # SET  <列名1>=<值1>[,<列名2>=<值2>]
    # [WHERE <条件>];
    # ?-占位符，在cour.execute()参数中，传入数据元组
    # 由于id设置了主键、自增，不能修改
    sql = 'update student set sname=?, sage=? where id=?'
    # 构建数据元组
    student_data = ('小小', 18, 1)
    # 执行sql语句
    cour.execute(sql, student_data)
    # 提交数据-同步到数据库文件-增删改查，除了查询以外有需要进行提交
    conn.commit()
    # 打印受影响的行数
    print(cour.rowcount)
    # 关闭游标
    cour.close()
    # 关闭连接
    conn.close()
except Error as e:
    print('连接失败')
08、删除数据

(1)、删除单条student信息

# 导入sqlite3模块
from sqlite3 import Error
import sqlite3


# try-except:防止因连接失败导致程序崩溃
try:
    # 数据库文件路径
    db_file = 'student_data.db'
    # 连接数据库
    conn = sqlite3.connect(db_file)
    # 创建游标
    cour = conn.cursor()
    # 编写sql语句
    # 删除语句sql：DELETE FROM 表名
    # WHERE <列名1>=<值1>
    # ?-占位符，在cour.execute()参数中，传入数据元组
    sql = 'delete from student where id=?'
    # 构建数据元组
    student_data = (1,)
    # 执行sql语句
    cour.execute(sql, student_data)
    # 提交数据-同步到数据库文件-增删改查，除了查询以外有需要进行提交
    conn.commit()
    # 打印受影响的行数
    print(cour.rowcount)
    # 关闭游标
    cour.close()
    # 关闭连接
    conn.close()
except Error as e:
    print('连接失败')

(2)、删除多条student信息

# 导入sqlite3模块
from sqlite3 import Error
import sqlite3


# try-except:防止因连接失败导致程序崩溃
try:
    # 数据库文件路径
    db_file = 'student_data.db'
    # 连接数据库
    conn = sqlite3.connect(db_file)
    # 创建游标
    cour = conn.cursor()
    # 编写sql语句
    # 删除语句sql：DELETE FROM 表名
    # WHERE <列名1>=<值1>
    # ?-占位符，在cour.execute()参数中，传入数据元组
    sql = 'delete from student where id=?'
    # 构建数据元组列表
    student_data = [(2,), (3,), (4,)]
    # 执行sql语句
    cour.executemany(sql, student_data)
    # 提交数据-同步到数据库文件-增删改查，除了查询以外有需要进行提交
    conn.commit()
    # 打印受影响的行数
    print(cour.rowcount)
    # 关闭游标
    cour.close()
    # 关闭连接
    conn.close()
except Error as e:
    print('连接失败')
09、数据库通用工具封装

注：以查询student数据为例

封装原因：由于建立数据库连接和关闭游标、数据库连接等都是相同的执行语句，为了防止代码冗余，体现面向对象的编程思想

# 导入sqlite3模块
from sqlite3 import Error
import sqlite3


# 连接数据库，返回连接对象-conn
def db_conn(db_file):
    # try-except:防止因连接失败导致程序崩溃
    try:
        # 连接数据库
        conn = sqlite3.connect(db_file)
        return conn
    except Error as e:
        print('连接失败')
        return None

# 关闭数据库，关闭游标
def close_db(cour, conn):
    close_cour = cour
    close_conn = conn
    if close_cour != None:
        close_cour.close()
        close_conn.close()
        return True
    else:
        return False



if __name__ == '__main__':
    # 数据库文件路径
    db_file = 'student_data.db'
    stu_conn = db_conn(db_file)
    # 创建游标
    stu_cour = stu_conn.cursor()
    # 编写sql语句
    sql = 'select * from student'
    # 执行sql语句
    stu_cour.execute(sql)
    # 打印查询结果
    print(stu_cour.fetchall())
    # 关闭游标和数据库连接
    result = close_db(stu_cour, stu_conn)
    # 打印关闭结果
    print(result)
10、完结
恭喜你-学完了本教程-完结撒花-★,°:.☆(￣▽￣)/$:.°★ 。
# sqlite # 数据库 # python
Logo
亚马逊云科技技术品牌专区

更多推荐

cover

企业物联网平台如何选择？

avatar 亚马逊云科技技术品牌专区

STM32节点移植lorawan协议连接腾讯云物联网开发平台（IoT Explorer）

STM32移植lorawan协议连接腾讯云物联网开发平台（IoT Explorer）前言前言在移植协议之前，先给大家科普一下Lora 和 lorawan 的区别。LoRa 是LPWAN通信技术中的一种，是美国Semtech公司采用和推广的一种基于扩频技术的超远距离无线传输方案。这一方案改变了以往关于传输距离与功耗的折衷考虑方式为用户提供一种简单的能实现远距离、长电池寿命、大容量的系统，进而扩...

avatar 亚马逊云科技技术品牌专区

从华为的MQTT到TdEngineRPC，解读物联网时代的分布式

今天中秋节，笔者首先祝各位读者们中秋快乐，之所以在今天这个团圆节来谈分布式的话题，就是要聊聊物联网是如何通过MQTT连接各类终端，如何通过RPC整合各种数据的。下面就通过代码+动图的方式来解读一下华为LiteOS的MQTT与TD的RPC。MQTT协议MQTT是一个客户机服务器发布/订阅消息传输协议。它重量轻、开放、简单、易于实现。这些特性使其非常适合在物联网的低带宽、...

avatar 亚马逊云科技技术品牌专区