首页 > 数据库技术 > 详细

SQLite3 of python

时间:2019-05-27 00:38:20      阅读:76      评论:0      收藏:0      [点我收藏+]

标签:mat   实现   练手   execute   csv文件   建数据库   esc   turn   sqlite3   

SQLite3 of python

一、SQLite3 数据库

  SQLite3 可使用 sqlite3 模块与 Python 进行集成,一般 python 2.5 以上版本默认自带了sqlite3模块,因此不需要用户另外下载。

在 学习基本语法之前先来了解一下数据库是使用流程吧 ↓↓↓

技术分享图片

所以,首先要创建一个数据库的连接对象,即connection对象,语法如下:

sqlite3.connect(database [,timeout,其他可选参数])

function: 此API打开与SQLite数据库文件的连接。如果成功打开数据库,则返回一个连接对象。

database: 数据库文件的路径,或 “:memory:” ,后者表示在RAM中创建临时数据库。

timeout: 指定连接在引发异常之前等待锁定消失的时间,默认为5.0(秒)

 

有了connection对象,就能创建游标对象了,即cursor对象,如下:

connection.cursor([cursorClass])

function: 创建一个游标,返回游标对象游标将在Python的整个数据库编程中使用。

 

接下来,看看connection对象 和 cursor对象的 “技能” 吧  ↓↓↓

connection对象的方法
方法 说明
connect.cursor() 上述,返回游标对象
connect.execute(sql [,parameters]) 创建中间游标对象执行一个sql命令
connect.executemany(sql [,parameters]) 创建中间游标对象执行一个sql命令
connect.executescript(sql_script) 创建中间游标对象, 以脚本的形式执行sql命令
connect.total_changes() 返回自打开数据库以来,已增删改的行的总数
connect.commit() 提交当前事务,不使用时为放弃所做的修改,即不保存
connect.rollback() 回滚自上次调用commit()以来所做的修改,即撤销
connect.close() 断开数据库连接

 

cursor对象的方法
方法 说明
cursor.execute(sql [,parameters]) 执行一个sql命令
cursor.executemany(sql,seq_of_parameters) 对 seq_of_parameters 中的所有参数或映射执行一个sql命令
cursor.executescript(sql_script) 以脚本的形式一次执行多个sql命令
cursor.fetchone() 获取查询结果集中的下一行,返回一个单一的序列,当没有更多可用的数据时,则返回 None。
cursor.fetchmany([size=cursor.arraysize]) 获取查询结果集中的下一行组,返回一个列表。当没有更多的可用的行时,则返回一个空的列表。size指定特定行数。
cursor.fetchall() 获取查询结果集中所有(剩余)的行,返回一个列表。当没有可用的行时,则返回一个空的列表。

下面用一个简单实例作为介绍 >>>

 1 def SQLite_Test():
 2     # =========== 连接数据库 ============
 3     # 1. 连接本地数据库
 4     connectA = sqlite3.connect("example.db")
 5     # 2. 连接内存数据库,在内存中创建临时数据库
 6     connectB = sqlite3.connect(":memory:")
 7 
 8     # =========== 创建游标对象 ============
 9     cursorA = connectA.cursor()
10     cursorB = connectB.cursor()
11 
12     # =========== 创建表 ============
13     cursorA.execute("CREATE TABLE class(id real, name text, age real, sex text)")
14     cursorB.execute("CREATE TABLE family(relation text, job text, age real)")
15 
16     # =========== 插入数据 ============
17     cursorA.execute("INSERT INTO class VALUES(1,‘Jock‘,8,‘M‘)")
18     cursorA.execute("INSERT INTO class VALUES(2,‘Mike‘,10,‘M‘)")
19     # 使用 ? 占位符
20     cursorA.execute("INSERT INTO class VALUES(?,?,?,?)", (3,Sarah,9,F))
21 
22     families = [
23         [Dad, CEO, 35],
24         [Mom, singer, 33],
25         [Brother, student, 8]
26     ]
27     cursorB.executemany("INSERT INTO family VALUES(?,?,?)",families)
28 
29     # =========== 查找数据 ============
30     # 使用 命名变量 占位符
31     cursorA.execute("SELECT * FROM class WHERE sex=:SEX", {"SEX":M})
32     print("TABLE class: >>>select Male\n", cursorA.fetchone())
33     cursorA.close()
34     
35     cursorB.execute("SELECT * FROM family ORDER BY relation")
36     print("TABLE family:\n", cursorB.fetchall())
37     cursorB.close()
38 
39     # =========== 断开连接 ============
40     connectA.close()
41     connectB.close()
42 
43 SQLite_Test()

  运行结果:

TABLE class: >>>select Male
(1.0, ‘Jock‘, 8.0, ‘M‘)
TABLE family:
[(‘Brother‘, ‘student‘, 8.0), (‘Dad‘, ‘CEO‘, 35.0), (‘Mom‘, ‘singer‘, 33.0)]

 

 二、小练手

使用目前学的sqlite3数据库知识,对一些数据进行增删查改的操作。此处选择来自下面网站的数据

url = http://www.zuihaodaxue.cn/zuihaodaxuepaiming2016.html 

先将数据从网站上爬取下来,存储为csv文件,然后再保存到数据库中,接着进行数据的操作。对于如何存储为csv文件,请查看 >>> 《此处的最后一个小主题

对于本次小练习的介绍:

目的:对已爬取的数据进行数据库管理和简单操作

步骤: 创建数据库文件 >>> 创建表 >>> 保存数据到数据库 >>> 对数据进行简单操作

方法:我采用的方法是:

① 编写一个函数( get_data(fileName) ):读取csv文件中的数据,主要完成对数据的格式转换,以便适合保存到数据库中

② 编写一个函数类( class SQL_method ):对数据库进行简单操作,主要完成数据库的创建和数据的保存

③ 尝试其他操作:

a. 在数据库中查找某一项记录

b. 对数据按照某种排序输出

c. 对数据进行增加权值操作,实现重新排序

d. 删除数据库中的某些记录

e. 删除数据库中的表

好了,有了前进的方向,那我们杨帆 ----- 起航 >>>

  1 # -*- coding: utf-8 -*-
  2 ‘‘‘
  3 使用 url = "http://www.zuihaodaxue.cn/zuihaodaxuepaiming2016.html" 的数据进行SQLite3数据库的练习使用
  4 @author: bpf
  5 ‘‘‘
  6 
  7 import sqlite3
  8 
  9 class SQL_method:
 10     ‘‘‘
 11     function: 可以实现对数据库的基本操作
 12     ‘‘‘
 13     def __init__(self, dbName, tableName, data, columns, Read_All=True):
 14         ‘‘‘
 15         function: 初始化参数
 16         dbName: 数据库文件名 
 17         tableName: 表的名称
 18         data: 从csv文件中读取且经过处理的数据
 19         columns: 表的第一行
 20         ‘‘‘
 21         self.dbName = dbName
 22         self.tableName = tableName
 23         self.data = data
 24         self.columns = columns
 25         self.Read_All = Read_All
 26     
 27     def creatTable(self):
 28         ‘‘‘
 29         function: 创建数据库文件及相关的表
 30         ‘‘‘
 31         # 连接数据库
 32         connect = sqlite3.connect(self.dbName)
 33         # 创建表
 34         connect.execute("CREATE TABLE {}{}".format(self.tableName, self.columns))
 35         # 提交事务
 36         connect.commit()
 37         # 断开连接
 38         connect.close()
 39     
 40     def destroyTable(self):
 41         ‘‘‘
 42         function: 删除数据库文件中的表
 43         ‘‘‘
 44         # 连接数据库
 45         connect = sqlite3.connect(self.dbName)
 46         # 删除表
 47         connect.execute("DROP TABLE {}".format(self.tableName))
 48         # 提交事务
 49         connect.commit()
 50         # 断开连接
 51         connect.close()
 52     
 53     def insertDataS(self):
 54         ‘‘‘
 55         function: 向数据库文件中的表插入多条数据
 56         ‘‘‘
 57         # 连接数据库
 58         connect = sqlite3.connect(self.dbName)
 59         # 插入多条数据
 60         connect.executemany("INSERT INTO {} VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)".format(self.tableName), self.data)
 61         #for i in range(len(self.data)):
 62         #    connect.execute("INSERT INTO university VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)", data[i])
 63         # 提交事务
 64         connect.commit()
 65         # 断开连接
 66         connect.close()
 67     
 68     def getAllData(self):
 69         ‘‘‘
 70         function: 得到数据库文件中的所有数据
 71         ‘‘‘
 72         # 连接数据库
 73         connect = sqlite3.connect(self.dbName)
 74         # 创建游标对象
 75         cursor = connect.cursor()
 76         # 读取数据
 77         cursor.execute("SELECT * FROM {}".format(self.tableName))
 78         dataList = cursor.fetchall()
 79         # 断开连接
 80         connect.close()
 81         return dataList
 82         
 83     def run(self):
 84         try:
 85             # 创建数据库文件
 86             self.creatTable()
 87             print("SQL creats successfully!")
 88             # 保存数据到数据库
 89             self.insertDataS()
 90             print("Insert data successfully!")
 91         except:
 92             print("SQL has created!")
 93         # 读取所有数据
 94         if self.Read_All:
 95             for i in self.getAllData():
 96                 print(i)
 97 
 98 def get_data(fileName):
 99     ‘‘‘
100     function: 读取获得大学排名的数据 并 将结果返回
101     ‘‘‘
102     data = []
103     # 打开文件
104     f = open(fileName, r, encoding=utf-8)
105     # 按行读取文件
106     for line in f.readlines():
107         # 替换掉其中的换行符
108         line = line.replace(\n, ‘‘)
109         # 将列表转化为元组
110         li = tuple(line.split(,))
111         data.append(li)
112     columns = ("Rank text", "University text", "Province text", "Grade text", "SourseQuality text", "TrainingResult text", "ResearchScale text", 
113     "ReserchQuality text", "TopResult text", "TopTalent text", "TechnologyService text", "Cooperation text", "TransformationResults text")
114     # 分别对应: ["排名", "学校名称", "省市", "总分", "生涯质量", "培养结果", "科研规模", "科研质量", "顶尖成果", "顶尖人才", "科技服务", "产学研合作", "成果转化"]
115     return columns, data[1:]
116 
117 if __name__ == "__main__":
118     # 设置和得到基本数据
119     fileName = "D:\\University_Rank.csv"
120     columns, data = get_data(fileName)
121     dbName = "university.db"
122     tableName = "university"
123     # 创建SQL_method的一个对象
124     SQL = SQL_method(dbName, tableName, data, columns, False)
125     # 创建数据库文件和保存数据
126     SQL.run()

 

 未完待续 。。。

 

 

 

 

SQLite3 of python

标签:mat   实现   练手   execute   csv文件   建数据库   esc   turn   sqlite3   

原文:https://www.cnblogs.com/bpf-1024/p/10928456.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 bubuko.com 版权所有 鲁ICP备09046678号-4
打开技术之扣,分享程序人生!
             

鲁公网安备 37021202000002号