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对象的 “技能” 吧 ↓↓↓
| 方法 | 说明 |
| 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.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 =
先将数据从网站上爬取下来，存储为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()
未完待续 。。。