使用django.db.connection在Django中执行原始SQL查询

在Django中，可以使用django.db.connection来执行原始的SQL查询。django.db.connection是一个表示与数据库连接的对象。它提供了访问数据库和执行SQL查询的方法。

要使用django.db.connection，首先需要导入它：

from django.db import connection

然后，可以使用connection对象执行SQL查询。下面是一些常用的方法：

1. cursor(): 返回一个游标对象，可以用于执行SQL查询和获取结果。

cursor = connection.cursor()

2. execute(query, params=None): 执行一个SQL查询。

query = "SELECT * FROM my_table WHERE id = %s"
params = [1]
cursor.execute(query, params)

3. executemany(query, param_list): 执行多个参数化的SQL查询。

query = "INSERT INTO my_table (name, age) VALUES (%s, %s)"
param_list = [("John", 25), ("Jane", 30), ("Jim", 35)]
cursor.executemany(query, param_list)

4. fetchone(): 获取查询结果的下一行。

row = cursor.fetchone()

5. fetchmany(size=None): 获取查询结果的多行，数量由size参数指定。

rows = cursor.fetchmany(10)

6. fetchall(): 获取查询结果的所有行。

rows = cursor.fetchall()

注意：在使用完cursor对象后，应该关闭它来释放数据库资源。

cursor.close()

下面是一个完整的示例，演示如何使用django.db.connection执行原始的SQL查询：

from django.db import connection

def get_users():
    # 获取游标
    cursor = connection.cursor()

    try:
        # 执行SQL查询
        query = "SELECT id, name, age FROM users"
        cursor.execute(query)

        # 获取查询结果
        rows = cursor.fetchall()

        # 处理查询结果
        users = []
        for row in rows:
            user = {
                'id': row[0],
                'name': row[1],
                'age': row[2],
            }
            users.append(user)

        return users
    finally:
        # 关闭游标
        cursor.close()

在这个例子中，我们定义了一个get_users函数，它使用django.db.connection执行一个简单的SELECT查询来获取数据库中的用户列表。获取的结果会被处理为一个包含用户信息的字典的列表。最后，我们关闭了游标以释放数据库。

这就是如何使用django.db.connection在Django中执行原始SQL查询的一个例子。通过与Django ORM的结合使用，您可以更灵活地操作数据库，执行更复杂的查询和操作。但是请注意，使用原始SQL查询时，要小心防止SQL注入攻击，并确保数据的安全性。