python处理SQLite数据库的方法
作者:Crayon鑫 发布时间:2024-01-14 12:03:44
前言:
数据库非常重要,程序的数据增删改查需要数据库支持。python处理数据库非常简单。而且不同类型的数据库处理逻辑方式大同小异。本文以sqlite
数据库为例,介绍一下python操作数据库的方法。
python sqlite3 官方文档
一、安装
pip3 install pysqlite3
三、数据库连接、关闭等
import sqlite3
# 连接数据库(如果不存在则创建)
conn = sqlite3.connect('test.db')
print("Opened database successfully")
# 创建游标
cursor = conn.cursor()
# 关闭游标
cursor.close()
# 提交事物
conn.commit()
# 关闭连接
conn.close()
四、表操作
1、创建数据表
import sqlite3
conn = sqlite3.connect('test.db')
print ("数据库打开成功")
c = conn.cursor()
c.execute('''CREATE TABLE COMPANY
(ID INT PRIMARY KEY NOT NULL,
NAME TEXT NOT NULL,
AGE INT NOT NULL,
ADDRESS CHAR(50),
SALARY REAL);''')
print ("数据表创建成功")
conn.commit()
conn.close()
2、显示数据表数目
sql="select name from sqlite_master where type='table' order by name"
tables=cursor.execute(sql).fetchall()
print(len(tables))
3、删除数据表
sql="DROP TABLE database_name.table_name"
cursor.execute(sql)
五、Cusor的一些方法
fetchone()
获取查询结果集的下一行
fetchmany(size=cursor.arraysize)
获取查询结果的下一组行,返回一个列表。
fetchall()
取查询结果的所有(剩余)行,返回一个列表。请注意,游标的 arraysize 属性会影响此操作的性能。当没有行可用时返回一个空列表。
注:fetchall()用来统计表记录时,在开头用一次,再用则查询为空
.description显示字段信息,返回列表。
六、SQL操作
1、查
...
# 创建游标
cursor = conn.cursor()
# 查询数据
sql = "select * from Student"
values = cursor.execute(sql)
for i in values:
print(i)
# 查询数据 2
sql = "select * from Student where id=?"
values = cursor.execute(sql, (1,))
for i in values:
print('id:', i[0])
print('name:', i[1])
print('age:', i[2])
# 提交事物
conn.commit()
...
2、增
...
# 创建游标
cursor = conn.cursor()
# 插入数据
sql = "INSERT INTO Student(Name, Age) VALUES(\'love\', 22)"
cursor.execute(sql)
# 插入数据 2
data = ('love2', 2221) # or ['love2', 2221]
sql = "INSERT INTO Student(Name, Age) VALUES(?, ?)"
cursor.execute(sql, data)
# 提交事物
conn.commit()
...
3、删
sql语句换一下即可,看下一节的SQL语句。
4、改
sql语句换一下即可,看下一节的SQL语句。
七、SQL常用语句
# 增 两种方法
sql1="INSERT INTO table_name VALUES (value1,value2,value3,...);"
sql2='''INSERT INTO table_name
(column1,column2,column3,...)
VALUES (value1,value2,value3,...);'''
# 删
sql="DELETE FROM table_name WHERE [condition];"
# 改
sql="UPDATE table_name SET column1 = value1, column2 = value2...., columnN = valueN WHERE [condition];"
# 查
sql="SELECT * FROM table_name;"
# 重命名
sql="ALTER TABLE 老表名 RENAME TO 新表名;"
# 添加字段
sql="ALTER TABLE 表名 ADD COLUMN 新列 TEXT;"
# 查看所有字段名
sql="PRAGMA table_info([表名])"
八、row_factory 高级操作
这是对row_factory的官方解释(官方解释直接忽略就好,看我下面的解释):A Row instance serves as a highly optimized row_factory for Connection objects. It tries to mimic a tuple in most of its features.
It supports mapping access by column name and index, iteration, representation, equality testing and len().
If two Row objects have exactly the same columns and their members are equal, they compare equal.
基础Cursor
对象只能通过数字索引来获取值,但是我想通过列名来获取值是做不到的。虽然可以使用Cursor.description
来获取字段名称,但是自己做映射写代码很麻烦。
本着简约代码(懒)的原则,python推出了Cursor.Row
对象。其实就是列名和值做了个映射,可以通过字符索引来获取值。很方便。
升级过程也简单,就加一句话:conn.row_factory = sqlite3.Row
看例子:
1、使用
import sqlite3
conn=connectSqlite("myDB.db")
conn.row_factory = sqlite3.Row # 这句一定要加
cursor=conn.cursor()
rows=cursor.execute("SELECT * from myTable ")
row=rows.fetchone()
row.key() # 返回所有字段名,
print(row[0]) # 输出第一个字段
print(row["field1"]) # 输出字段名为field1的值
2、循环输出所有值
# ...上接上面的第一块内容
s=0
for row in rows:# 迭代就不用fetchone()了
s+=1
print("打印第{}个数据".format(s))
for r in row:
print(r)
九、实例
1、从sqlite数据库中返回json格式数据
'''
description: 根据输入条件,从sqlite数据库中返回JSON数据
param {*} db_name:str 数据库名称
param {*} fields:list 筛选的字段
param {*} table_name:str 要查询的表名
param {*} condition:str 查询的条件,注意条件的值是字符串的话需要转义
return {*} json
author: https://blog.csdn.net/Crayonxin2000
'''
def returnJsonFromSqlite(db_name,fields,table_name,condition):
data = {}
rows = [] # 数据
conn = connectSqlite(db_name)
conn.row_factory = sqlite3.Row
cursor = conn.cursor()
fields_str = ",".join(fields) # 列表转字段,fields为所有的字段
if condition=="" or condition==None:
sql="SELECT {} from {} ".format(fields_str,table_name)
else:
sql="SELECT {} from {} WHERE {}".format(fields_str,table_name,condition)
print(sql)
result=cursor.execute(sql)
for item in result:
row = []
for field in fields:
row.append(item[field])
rows.append(row)
data["header"] = fields
data["rows"] = rows
# 关闭数据库
cursor.close()
conn.close()
return jsonify(data)
注:data是字典,我用flask的jsonify工具JSON化了,你可以使用其他工具。
来源:https://blog.csdn.net/Crayonxin2000/article/details/122506157
猜你喜欢
- 前言在跑模型的时候,遇到如下报错UserWarning: To copy construct from a tensor, it is re
- python程序运行中,可由程序抛出异常。异常触发:使用raise命令抛出异常,即可使用异常基类Exception,也可使用自定义异常类(继
- 最近使用pymysql写脚本的情况越来越多了,刚好整理,简单封装一个pymysql的操作类import pymysqlclass Mysql
- Python socket C/S结构的聊天室应用服务端:#!/usr/bin/env python#coding:utf8 import
- Python进程池是Python标准库中multiprocessing模块提供的一种用于管理进程的方式。它可以使Python程序以并行的方式
- 测试函数主要是用来评估优化算法特性的,这里我用python3绘制了部分测试函数的图像。具体的测试函数可以结合 * 来了解。想要显示某个测试
- 1、引言小丝:鱼哥,2023年了, 你有啥愿望啊?小鱼:这, 我可以选择不告诉你吗?小丝:可以选择不告诉我,但是,你自己憋着,不难受吗?小鱼
- 一、变量创建过程首先,当我们定义了一个变量name = 'Kwan'的时候,在内存中其实是做了这样一件事:程序开辟了一块内存
- 昨日晚平台升级,我们成功送BUG上线,今天系统问题又多了起来,大多数时候的运维问题需要根据业务反馈的#订单号# 查询到当前状态,然后再进行反
- 一、前言在学习深度学习会发现都比较爱用python这个argparse,虽然基本能理解,但没有仔细自己动手去写,因此这里写下来作为自己本人的
- 现在我主要教大家如何去实战,做一个简易的知乎日报API 首先你要熟悉django的基本用法,会写模型,会写视图函数,会配置url。1.配置字
- 不知不觉,玩爬虫玩了一个多月了。我愈发觉得,爬虫其实并不是什么特别高深的技术,它的价值不在于你使用了什么特别牛的框架,用了多么了不起的技术,
- 注册模块default.asp 代码如下:<!DOCTYPE html PUBLIC "-//
- 如何实现动态单行刷新,答案是——覆盖但是怎么实现覆盖呢关键在于不换行而且能回退到开始位置那么就要用到 \r这个东西就是让光标回退到
- 本文实例讲述了python实现把二维列表变为一维列表的方法。分享给大家供大家参考,具体如下:c = [[1,2,3], [4,5,6], [
- 由于工作对人的眼球和精神都会带来一定的疲劳,所以在界面设计中,希望用户能够准确的关注重要的信息,而不因为用户的长期使用而流失信息。最近在看《
- 一、问题描述SQL Server 的master数据库不能像其他用户或 系统数据库一样恢复, 因为没有活动的master数据库 SQL Se
- juypter notebook中直接使用log_device_placement=True打印不出来device信息# Creates a
- Selenium中的鼠标和键盘事件被封装在ActionChains类中,使用方法:ActionChains(driver).click(bt
- 在python2.x中 ,异常是这样的处理的,异常基类后面加一个逗号“ ,” 然后跟着异常类型import tracebackt