社区所有版块导航
Python
python开源   Django   Python   DjangoApp   pycharm  
DATA
docker   Elasticsearch  
aigc
aigc   chatgpt  
WEB开发
linux   MongoDB   Redis   DATABASE   NGINX   其他Web框架   web工具   zookeeper   tornado   NoSql   Bootstrap   js   peewee   Git   bottle   IE   MQ   Jquery  
机器学习
机器学习算法  
Python88.com
反馈   公告   社区推广  
产品
短视频  
印度
印度  
Py学习  »  Python

Python 中查询 sqlite3 的一些小技巧

编程派 • 7 年前 • 557 次点击  

我最近在涉及大量数据处理的项目中频繁使用 sqlite3。我最初的尝试根本不涉及任何数据库,所有的数据都将保存在内存中,包括字典查找、迭代和条件等查询。这很好,但可以放入内存的只有那么多,并且将数据从磁盘重新生成或加载到内存是一个繁琐又耗时的过程。

我决定试一试sqlite3。因为只需打开与数据库的连接,这样可以增加可处理的数据量,并将应用程序的加载时间减少到零。此外,我可以通过 SQL 查询替换很多Python逻辑语句。

我想分享一些关于这次经历的心得和发现。

TL;DR

  1. 使用大量操作 (又名 executemany)。

  2. 你不需要使用光标 (大部分时间)。

  3. 光标可被迭代。

  4. 使用上下文管理器。

  5. 使用编译指示 (当它有意义)。

  6. 推迟索引创建。

  7. 使用占位符来插入 python 值。

如果你需要在数据库中一次性插入很多行,那么你真不应该使用 execute。sqlite3 模块提供了批量插入的方式:executemany。

而不是像这样做:

  1. for row in iter_data():

  2.    connection.execute('INSERT INTO my_table VALUES (?)', row)

你可以利用这个事实,即 executemany 接受元组的生成器作为参数:

  1. connection.executemany(

  2.    'INSERT INTO my_table VALUE (?)',

  3.    iter_data()

  4. )

这不仅更简洁,而且更高效。实际上,sqlite3 在幕后利用 executemany 实现 execute,但后者插入一行而不是多行。

我写了一个小的基准测试,将一百万行插入空表(数据库在内存中):

  • executemany: 1.6 秒

  • execute: 2.7 秒

一开始我经常搞混的事情就是,光标管理。在线示例和文档中通常如下:

  1. connection = sqlite3.connect(':memory:')

  2. cursor = connection.cursor()

  3. # Do something with cursor

但大多数情况下,你根本不需要光标,你可以直接使用连接对象(本文末尾会提到)。 
像execute和executemany类似的操作可以直接在连接上调用。以下是一个证明此事的示例:

  1. import sqlite3

  2. connection = sqlite3(':memory:')

  3. # Create a table

  4. connection.execute('CREATE TABLE events(ts, msg)')

  5. # Insert values

  6. connection.executemany(

  7.    'INSERT INTO events VALUES (?,?)',

  8.    [

  9.        (1, 'foo'),

  10.        (2, 'bar'),

  11.        (3, 'baz')

  12.    ]

  13. )

  14. # Print inserted rows

  15. for row in connnection.execute('SELECT * FROM events'):

  16.    print(row)

你可能经常会看到使用fetchone或fetchall来处理SELECT查询结果的示例。但是我发现处理这些结果的最自然的方式是直接在光标上迭代:

  1. for row in connection.execute('SELECT * FROM events'):

  2.    print(row)

这样一来,只要你得到足够的结果,你就可以终止查询,并且不会引起资源浪费。当然,如果事先知道你需要多少结果,可以改用LIMIT SQL语句,但Python生成器是非常方便的,可以让你将数据生成与数据消耗分离。

即使在处理SQL事务的中间,也会发生讨厌的事情。为了避免手动处理回滚或提交,你可以简单地使用连接对象作为上下文管理器。 在以下示例中,我们创建了一个表,并错误地插入了重复的值:

  1. import sqlite3

  2. connection = sqlite3.connect(':memory:')

  3. with connection:

  4.    connection.execute(

  5.        'CREATE TABLE events(ts, msg, PRIMARY KEY(ts, msg))' )

  6. try:

  7.    with connection:

  8.        connection.executemany('INSERT INTO events VALUES (?, ?)', [

  9.            (1, 'foo'),

  10.            (2, 'bar'),

  11.            (3, 'baz'),

  12.            (1, 'foo'),

  13.        ])

  14. except (sqlite3.OperationalError, sqlite3.IntegrityError) as e:

  15.    print('Could not complete operation:', e)

  16. # No row was inserted because transaction failed

  17. for row in connection.execute('SELECT * FROM events'):

  18.    print(row)  

  19. connection.close()

…当它真的有用时

在你的程序中有几个 pragma 可用于调整 sqlite3 的行为。特别地,其中一个可以改善性能的是synchronous:

  1. connection.execute('PRAGMA synchronous = OFF')

你应该知道这可能是危险的。如果应用程序在事务中间意外崩溃,数据库可能会处于不一致的状态。所以请小心使用! 但是如果你要更快地插入很多行,那么这可能是一个选择。

假设你需要在数据库上创建几个索引,而你需要在插入很多行的同时创建索引。把索引的创建推迟到所有行的插入之后可以导致实质性的性能改善。

使用 Python 字符串操作将值包含到查询中是很方便的。但是这样做非常不安全,而 sqlite3 给你提供了更好的方法来做到这一点:

  1. # Do not do this!

  2. my_timestamp = 1

  3. c.execute("SELECT * FROM events WHERE ts = '%s'" % my_timestamp)

  4. # Do this instead

  5. my_timestamp = (1,)

  6. c. execute('SELECT * FROM events WHERE ts = ?', my_timestamp)

此外,使用Python%s(或格式或格式的字符串常量)的字符串插值对于executemany来说并不是总是可行。所以在此尝试没有什么真正意义!

请记住,这些小技巧可能会(也可能不会)给你带来好处,具体取决于特定的用例。你应该永远自己去尝试,决定是否值得这么做。

译者:圣洁之子, Tocy

原文:https://remusao.github.io/posts/2017-10-21-few-tips-sqlite-perf.html

译文:https://www.oschina.net/translate/few-tips-sqlite-perf


题图:pexels,CC0 授权。

点击阅读原文,查看更多 Python 教程和资源。


今天看啥 - 高品质阅读平台
本文地址:http://www.jintiankansha.me/t/c3xRuj5RXq
Python社区是高质量的Python/Django开发社区
本文地址:http://www.python88.com/topic/7931
 
557 次点击