1 介绍

SQLite是一个C库，它提供了一个轻量级的基于磁盘的数据库，它不需要单独的服务器进程，并且允许使用SQL查询语言的非标准格式来访问数据库。一些应用程序可以使用SQLite进行内部数据存储。还可以使用SQLite对应用程序进行原型化，然后将代码移植到更大的数据库，如PostgreSQL或Oracle。

2 sqlite3简单使用

sqlite3模块是由Gerhard H?ring写的，它提供了与PEP 249所描述的db-api 2.0规范兼容的SQL接口。要使用这个模块，首先必须创建一个表示数据库的连接对象。这里的数据将存储在示例中。db文件:

<code># -*- coding: utf-8 -*-
import sqlite3
# 创建数据库连接对象，存储在test.db中
conn = sqlite3.connect(‘test.db‘)
</code>

您还可以提供特殊的名称:memory:在RAM中创建一个数据库。
有了连接对象后，就可以创建一个Cursor对象，并调用它的execute()方法来执行SQL命令:

<code># -*- coding: utf-8 -*-
import sqlite3
conn = sqlite3.connect(‘test.db‘)
# 创建游标对象
c = conn.cursor()
# 创建表
c.execute("CREATE TABLE stocks(data TEXT, trans TEXT, symbol TEXT, qty REAL, price REAL)")
# 插入数据
c.execute("INSERT INTO stocks VALUES (‘2018-01-14‘, ‘buy‘, ‘rhat‘, 100, 35.14)")
# 保存数据
conn.commit()
# 关闭连接
conn.close()</code>

执行完后会在本地生成一个test.db文件，保存的数据是持久性的，并且在后续的会话中可用（我是用的win10 + pycharm环境），可以下载一个数据库工具navicat premium来查看test.db文件的内容，安装软件网上很好搜，不讲解，我把连接数据库操作截图说明：

通常，您的SQL操作需要使用来自Python变量的值。您不应该使用Python的字符串操作来组装您的查询，因为这样做是不安全的，它使您的程序容易受到SQL注入攻击。相反，使用DB-api的参数替换。把?作为您想要使用一个值的占位符，然后提供一个元组作为第二个参数，作为光标的execute()方法的第二个参数。(其他数据库模块可能使用不同的占位符，比如%s)例如:

<code>
# 不要这么做
# 定义变量
symbol = ‘rhat‘
# 获取查询结果
dbs = c.execute("SELECT * FROM stocks WHERE symbol=‘%s‘" % symbol)
# 打印出数据
for db in dbs:
    print(db)
# 正确做法
t = (‘rhat‘, )
c.execute(‘SELECT * FROM stocks WHERE symbol=?‘, t)
print(c.fetchone())
# 插入多条数据
purchases = [(‘2006-03-28‘, ‘BUY‘, ‘IBM‘, 1000, 45.00),
             (‘2006-03-29‘, ‘BUY‘, ‘ThinkPad‘, 5000, 55.00),
             (‘2006-03-30‘, ‘SELL‘, ‘IBM‘, 100, 33.00),
             ]
c.executemany(‘INSERT INTO stocks VALUES (?, ?, ?, ?, ?)‘, purchases)
conn.commit()
conn.close()</code>

在执行一个SELECT语句之后检索数据，您可以将光标视为迭代器获取内容，也可以调用游标的fetchone()方法来检索单个匹配的行，或者调用fetchall()来获取所有匹配行的列表。

<code># 迭代器方式获取内容
for row in c.execute(‘SELECT * FROM stocks ORDER BY price‘):
    print(row)
# fetchone和fetchall方式获取内容
c.execute(‘SELECT * FROM stocks ORDER BY price‘)
print(c.fetchone())
print(c.fetchall())</code>

3 Sqlite3常用模块

4 示例

连接及游标确定

<code>import sqlite3
# 创建conn实例
conn = sqlite3.connect(‘test.db‘)
# 创建游标对象
c = conn.cursor()</code>

增

<code># 创建表
c.execute("CREATE TABLE stocks(data TEXT, trans TEXT, symbol TEXT, qty REAL, price REAL)")
# 插入单条数据
c.execute("INSERT INTO stocks VALUES (‘2018-01-14‘, ‘buy‘, ‘rhat‘, 100, 35.14)")
# 插入多条数据
purchases = [(‘2006-03-28‘, ‘BUY‘, ‘IBM‘, 1000, 45.00),
             (‘2006-03-29‘, ‘BUY‘, ‘ThinkPad‘, 5000, 55.00),
             (‘2006-03-30‘, ‘SELL‘, ‘IBM‘, 100, 33.00),
             ]
c.executemany(‘INSERT INTO stocks VALUES (?, ?, ?, ?, ?)‘, purchases)</code>

删

<code># 删除
c.execute("DELETE from stocks WHERE data=‘2018-01-14‘;")</code>

改

<code># 修改数据
c.execute("UPDATE stocks set price = 25000.00 where symbol=‘ThinkPad‘")</code>

查

<code># 迭代器方式获取内容
for row in c.execute(‘SELECT * FROM stocks ORDER BY price‘):
    print(row)
# fetchone和fetchall方式获取内容
c.execute(‘SELECT * FROM stocks ORDER BY price‘)
print(c.fetchone())
print(c.fetchall())</code>

以上就是基本的增删改查操作，记住一定要commit，并且正常close方式关闭，以免造成资源泄露。

运维学python之爬虫中级篇（七）Sqlite3

标签：下载   memory   images   upd   描述   指定   可见   navicat   sql脚本