Python数据库读写函数:用于连接和控制数据库、执行SQL查询或更新语句、读取和写入数据、删除元素等。

发布时间：2023-06-05 07:00:34

Python是一种绝佳的编程语言，它广泛用于数据分析和机器学习等领域。在这些领域中，数据通常保存在数据库中。因此，了解如何连接和控制数据库、执行SQL查询或更新语句、读取和写入数据、删除元素等是非常重要的，这些都可以通过Python的数据库读写函数完成。

Python提供了许多数据库读写函数库来进行这些操作。在这篇文章中，我们将重点介绍几个常用的Python数据库读写函数库和它们的具体用法。

1. sqlite3

sqlite3是Python自带的轻量级数据库，可以直接连接和操作SQLite数据库。

首先，我们需要导入sqlite3：

import sqlite3

接下来，我们需要连接到数据库。SQLite数据库是一种本地文件数据库，因此我们需要使用以下代码：

conn = sqlite3.connect('database.db')

其中，'database.db'是我们连接并存储数据库的文件名。

现在我们已经连接到了数据库，可以开始执行查询或更新语句，例如：

c = conn.cursor()
c.execute("SELECT * FROM table_name")

其中，'table_name'是我们查询的表名。我们可以将查询结果存储在变量中：

rows = c.fetchall()

这里的'rows'是存储查询结果的变量。我们可以使用for循环将结果打印出来：

for row in rows:
    print(row)

接下来，我们可以执行更新语句：

c.execute("UPDATE table_name SET column_name = 'new_value' WHERE column_name = 'old_value'")

其中，'column_name'是我们要更新的列名，'new_value'是我们要更新为的新值，'old_value'是我们要更新的旧值。

最后，我们需要提交更改并关闭连接：

conn.commit()
conn.close()

2. pymongo

pymongo是Python的MongoDB数据库驱动程序，可以直接连接和操作MongoDB数据库。

首先，我们需要导入pymongo：

from pymongo import MongoClient

接下来，我们需要连接到数据库。我们可以使用以下代码：

client = MongoClient('mongodb://localhost:27017/')

其中，'localhost'是我们所连接的主机名，'27017'是我们所连接的端口号。如果是远程主机，我们可以使用IP地址或域名代替'localhost'。

现在我们已经连接到了数据库，可以开始执行查询或更新操作，例如：

db = client['database_name']
collection = db['collection_name']

其中，'database_name'是我们查询或更新的数据库名，'collection_name'是我们查询或更新的集合名。

我们可以执行以下查询操作：

result = collection.find({})
for item in result:
    print(item)

其中，'{}'表示我们要查询整个集合中的元素。我们可以通过添加查询条件来筛选集合中的元素。

接下来，我们可以执行更新操作：

collection.update_one({'_id': 'item_id'}, {'$set': {'key': 'value'}})

其中，'item_id'是我们要更新的元素ID，'$set'是我们要更新的键名和键值（这里是'key'和'value'）。

最后，我们需要关闭连接：

client.close()

3. MySQLdb

MySQLdb是Python的MySQL数据库驱动程序，可以直接连接和操作MySQL数据库。

首先，我们需要导入MySQLdb：

import MySQLdb