Python中的数据库处理：SQLite和Redis

@H_404_0@在我们生活的信息时代，我们可以看到世界正在交换多少数据。我们基本上是在广泛地创建、存储和检索数据！应该有一种方法来处理这一切——如果没有任何管理，它就不可能到处传播，对吗？这里是数据库管理系统（DBMS）。

@H_404_0@DBMS 是一个软件系统，可让您创建、存储、修改、检索和以其他方式处理数据库中的数据。此类系统的大小也各不相同，从仅在个人计算机上运行的小型系统到在大型机上运行的大型系统。

@H_404_0@本教程的重点是 Python，而不是数据库设计。是的，Python 非常能够与数据库交互，这就是我将在本教程中向您展示的内容。您将学习如何使用 Python 处理 sqlite 和 Redis 数据库。

@H_404_0@让我们开始吧！

Python 数据库 API

@H_404_0@如上所述，Python 能够与数据库交互。但是，它怎么能做到这一点呢？ Python 使用所谓的 Python Database API 来与数据库进行交互。该 API 允许我们对不同的数据库管理系统 (DBMS) 进行编程。然而，对于不同的 DBMS，代码级别遵循的过程是相同的，如下所示：

1. 与您选择的数据库建立连接。
2. 创建一个光标来与数据进行通信。
3. 使用 sql 操作数据（交互）。
4. 告诉连接将 sql 操作应用于数据并使它们永久化（提交），或者告诉它中止这些操作（回滚），从而返回将数据恢复到交互发生之前的状态。
5. 关闭与数据库的连接。

sqlite

@H_404_0@sqlite 是一个开源、功能齐全、独立（几乎不需要外部库的支持）、无服务器（不需要服务器来运行数据库引擎，并且是本地存储的数据库）、零配置（无需安装或配置）、基于 sql 的轻量级数据库管理系统（可以在 sqlite 表上运行 sql 查询），并使用一个数据文件来存储数据。

@H_404_0@值得一提的是，sqlite 被 Google、Apple、Microsoft 等大公司使用，这使得它非常可靠。在本教程中，我们将使用 sqlite 与数据库交互，更具体地说，我们将使用 Python 中的 sqlite3 模块。

Python 和 sqlite

@H_404_0@如上所述，使用数据库涉及五个个主要步骤。让我们看看这些步骤的实际效果。

1.建立与您选择的数据库的连接

@H_404_0@该步骤实现如下：

@H_404_0@conn = sqlite3.connect('company.db')

@H_404_0@正如 sqlite3 文档中所述：

要使用该模块，您必须首先创建一个表示数据库的 Connection 对象。

@H_404_0@在上面的代码中，请注意数据将存储在文件 company.db 中。

2.创建游标来与数据通信

@H_404_0@使用数据库的下一步是创建游标，如下所示：

@H_404_0@curs = conn.cursor()

3.使用 sql 操作数据

@H_404_0@连接数据库并创建游标后，我们现在就可以处理（交互）数据了。换句话说，我们现在可以在数据库 company.db 上运行 sql 命令。

@H_404_0@假设我们要在数据库 company 中创建一个新表 employee。在这种情况下，我们需要运行 sql 命令。为此，我们将使用 sqlite3 模块的 execute() 方法。因此，Python 语句将如下所示：

@[e-mail]('创建表员工(姓名，年龄)')

@H_404_0@此语句将运行一个 sql 命令，该命令将创建一个名为 employee 的表，其中包含两列（字段）name 和 age。

@H_404_0@我们现在可以运行一个新的 sql 命令来在表中插入数据，如下所示：

@[e-mail]("插入员工值('Ali', 28)")

@H_404_0@您还可以一次插入多个值，如下所示：

@H_404_0@值 = [('Brad',54), ('Ross', 34), ('Muhammad', 28), ('Bilal', 44)]

@H_404_0@在这种情况下，我们将使用方法execute()，而不是使用方法executemany()来执行上述多个值。

@[e-mail]('插入员工值(?,?)', value)

4.提交更改

@H_404_0@在此步骤中，我们希望应用（提交）我们在上一步中所做的更改。这很简单，如下所示：

@[e-mail]()

5.关闭与数据库的连接

@H_404_0@执行操作并提交更改后，最后一步是关闭连接：

@[e-mail]()

@H_404_0@让我们将所有步骤放在一个脚本中。该程序将如下所示（请注意，我们必须首先导入 sqlite3 模块）：

import sqlite3
conn = sqlite3.connect('company.db')
curs = conn.cursor()
curs.execute('create table employee (name, age)')
curs.execute("insert into employee values ('Ali', 28)")
values = [('Brad',54), ('Ross', 34), ('Muhammad', 28), ('Bilal', 44)]
curs.executemany('insert into employee values(?,?)', values)
conn.commit()
conn.close()

@H_404_0@如果运行该脚本，您应该在当前目录中获得一个名为 company.db 的文件。下载此文件，因为我们将在下一步中使用它。

6.让我们浏览一下数据库

@H_404_0@创建了数据库和表并添加了一些数据后，让我们看看 company.db （您在上一节中下载的文件）里面有什么。为此，我们将使用一个很好的工具：DB browser for sqlite。继续将该工具下载到您的计算机上。打开程序后，您应该看到如下所示的屏幕：

@H_404_0@

@H_404_0@使用顶部的打开数据库按钮打开数据库，在这种情况下，您应该获得数据库结构，如下所示：

@H_404_0@

@H_404_0@请注意，我们列出了表 employee，其中包含两个字段：name 和 age。

@H_404_0@要确认上面的代码有效并且数据已添加到表中，请单击浏览数据选项卡。您应该看到类似以下内容：

@H_404_0@

@H_404_0@可以看到，数据库（company）和表（employee）已经创建完成，并且数据已成功添加到表中。

Redis

@H_404_0@远程词典服务器，简称为Redis，是一个强大的 Nosql 数据库，也能够充当内存缓存。 Redis 由 Salvatore Sanfilippo 开发，目前由 Redis Labs 维护。该软件使用C编程语言编写，并且是开源的（BSD许可证）。

@H_404_0@Redis 最显着的特点之一就是它的数据结构存储机制。您可以使用 Python 中的相同数据类型（字符串、集合、整数、列表、字典等）在 Redis 中存储数据。 这使得 Redis 成为 Python 开发人员的热门选择。

Redis 和 Python

@H_404_0@除了其数据结构存储机制之外，Python 开发人员还因为 Redis 拥有大量 Python 客户端而更喜欢 Redis 而不是其他 Nosql 数据库，其中最受欢迎的选择可能是 redis-py。 Redis-py 提供了用于在 Redis 服务器中存储各种数据的内置命令。

@H_404_0@现在我们对 Redis 有了基本的了解，让我们学习如何在其中存储数据。在继续之前，请确保您的计算机上安装了 Redis 服务器。

1.安装Redis.py客户端

@H_404_0@首先，为您的 Python 脚本创建一个名为 redis-python 的新文件夹。接下来，使用命令终端 cd 到该文件夹​​，然后运行以下命令来安装 Redis 客户端：

pip install redis

@H_404_0@然后，在 redis-python 中创建一个名为 app.py 的文件，并使用文本编辑器打开该文件。下一步是创建用于将数据添加到数据库的 Python 脚本。

2.将Redis客户端连接到Redis服务器

@H_404_0@首先，在app.py中，导入redis并设置Redis服务器主机和端口地址的变量：

import redis
redis_host = 'localhost'
redis_port = 6379

@H_404_0@接下来，定义要添加到数据库的数据。在本例中，我们将创建一个简单的 Python 字典：

user = {
    'ID': 1,
    'name': 'Kingsley Ubah',
    'email': '[email protected]',
    'role': 'Tech Writing',
}

@H_404_0@接下来，使用 try... except 定义 add_to_db 函数。在 try 块中，我们连接到本地 Redis 服务器并将上述字典存储在数据库中，然后在控制台上输出值。如果代码失败，我们会在 except 块中打印错误对象。最后一部分将运行该函数：

def add_to_db():
    try:
        r = redis.StrictRedis(host = redis_host, port = redis_port, decode_responses=True)
        r.hmset("newUserOne", user)
        msg = r.hgetall("newUserOne")
        print(msg)
    except Exception as e:
        print(f"Something went wrong {e}")
 
# Runs the function:
if __name__ == "__main__":
    add_to_db()

3.启动服务器并运行代码

@H_404_0@首先，通过在命令终端上执行以下命令来运行 Redis 服务器：

redis-cli

@H_404_0@一旦服务器处于活动状态，您就可以使用以下命令运行 Python 脚本：

python app.py

@H_404_0@如果一切顺利，包含用户配置文件的字典将使用 newUserOne 键添加到 Redis。此外，您应该在终端控制台上看到以下输出：

{
  'ID': '1', 
  'name': 'Kingsley Ubah', 
  'email': '[email protected]', 
  'role': 'Tech Writing', 
}

@H_404_0@这就是 Redis 的全部内容！

结论

@H_404_0@本教程仅触及使用 Python 处理数据库的皮毛。您可以从 sqlite3 模块了解更多方法，您可以在其中执行不同的数据库操作，例如更新和查询数据库。

@H_404_0@要了解有关 redis-py 的更多信息，请立即阅读其完整文档。玩得开心！

@H_404_0@以上就是Python中的数据库处理：sqlite和Redis的详细内容，更多请关注编程之家其它相关文章！