Python自带一个轻量级的关系型数据库SQLite。这一数据库使用SQL语言。SQLite作为后端数据库,可以搭配Python建网站,或者制作有数据存储需求的工具。SQLite还在其它领域有广泛的应用,比如HTML5和移动端。Python标准库中的sqlite3提供该数据库的接口。
我将创建一个简单的关系型数据库,为一个书店存储书的分类和价格。数据库中包含两个表:category用于记录分类,book用于记录某个书的信息。一本书归属于某一个分类,因此book有一个外键(foreign key),指向catogory表的主键id。
创建数据库
我首先来创建数据库,以及数据库中的表。在使用connect()连接数据库后,我就可以通过定位指针cursor,来执行SQL命令:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
# By Vamei import sqlite3 # test.db is a file in the working directory. conn = sqlite3.connect( "test.db" ) c = conn.cursor() # create tables c.execute( '''CREATE TABLE category (id int primary key, sort int, name text)''' ) c.execute( '''CREATE TABLE book (id int primary key, sort int, name text, price real, category int, FOREIGN KEY (category) REFERENCES category(id))''' ) # save the changes conn.commit() # close the connection with the database conn.close() |
SQLite的数据库是一个磁盘上的文件,如上面的test.db,因此整个数据库可以方便的移动或复制。test.db一开始不存在,所以SQLite将自动创建一个新文件。
利用execute()命令,我执行了两个SQL命令,创建数据库中的两个表。创建完成后,保存并断开数据库连接。
插入数据
上面创建了数据库和表,确立了数据库的抽象结构。下面将在同一数据库中插入数据:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
# By Vamei import sqlite3 conn = sqlite3.connect( "test.db" ) c = conn.cursor() books = [( 1 , 1 , 'Cook Recipe' , 3.12 , 1 ), ( 2 , 3 , 'Python Intro' , 17.5 , 2 ), ( 3 , 2 , 'OS Intro' , 13.6 , 2 ), ] # execute "INSERT" c.execute( "INSERT INTO category VALUES (1, 1, 'kitchen')" ) # using the placeholder c.execute( "INSERT INTO category VALUES (?, ?, ?)" , [( 2 , 2 , 'computer' )]) # execute multiple commands c.executemany( 'INSERT INTO book VALUES (?, ?, ?, ?, ?)' , books) conn.commit() conn.close() |
插入数据同样可以使用execute()来执行完整的SQL语句。SQL语句中的参数,使用"?"作为替代符号,并在后面的参数中给出具体值。这里不能用Python的格式化字符串,如"%s",因为这一用法容易受到SQL注入攻击。
我也可以用executemany()的方法来执行多次插入,增加多个记录。每个记录是表中的一个元素,如上面的books表中的元素。
查询
在执行查询语句后,Python将返回一个循环器,包含有查询获得的多个记录。你循环读取,也可以使用sqlite3提供的fetchone()和fetchall()方法读取记录:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
# By Vamei import sqlite3 conn = sqlite3.connect( 'test.db' ) c = conn.cursor() # retrieve one record c.execute( 'SELECT name FROM category ORDER BY sort' ) print (c.fetchone()) print (c.fetchone()) # retrieve all records as a list c.execute( 'SELECT * FROM book WHERE book.category=1' ) print (c.fetchall()) # iterate through the records for row in c.execute( 'SELECT name, price FROM book ORDER BY sort' ): print (row) |
更新与删除
你可以更新某个记录,或者删除记录:
1
2
3
4
5
6
7
8
9
10
|
# By Vamei conn = sqlite3.connect( "test.db" ) c = conn.cursor() c.execute( 'UPDATE book SET price=? WHERE id=?' ,( 1000 , 1 )) c.execute( 'DELETE FROM book WHERE id=2' ) conn.commit() conn.close() |
你也可以直接删除整张表:
1
|
c.execute( 'DROP TABLE book' ) |
如果删除test.db,那么整个数据库会被删除。
总结
sqlite3只是一个SQLite的接口。想要熟练的使用SQLite数据库,还需要学习更多的关系型数据库的知识。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:http://www.cnblogs.com/vamei/p/3794388.html