Вызов хранимых процедур из Django

В этой статье объясняется, как создавать и вызывать хранимые процедуры SQL Server из приложений Django с использованием бэкенда mssql-django.

Создайте хранимую процедуру в миграции

Используйте migrations.RunSQL для создания хранимой процедуры в рамках рабочего процесса миграции Django:

from django.db import migrations

class Migration(migrations.Migration):

    dependencies = [
        ("myapp", "0001_initial"),
    ]

    operations = [
        migrations.RunSQL(
            sql="""
                CREATE PROCEDURE GetProductsByCategory
                    @CategoryName NVARCHAR(100)
                AS
                BEGIN
                    SET NOCOUNT ON;
                    SELECT id, name, price
                    FROM myapp_product
                    WHERE category = @CategoryName;
                END;
            """,
            reverse_sql="DROP PROCEDURE IF EXISTS GetProductsByCategory;",
        ),
    ]

Примените миграцию:

python manage.py migrate

Вызов хранимой процедуры

Используйте Django connection.cursor() для вызова хранимых процедур с необработанным SQL:

from django.db import connection

def get_products_by_category(category_name):
    with connection.cursor() as cursor:
        cursor.execute("EXECUTE GetProductsByCategory @CategoryName = %s;", [category_name])
        results = cursor.fetchall()
    return results

Вызов хранимой процедуры с несколькими параметрами

Передайте несколько параметров в виде списка:

from django.db import connection

def search_products(category_name, min_price):
    with connection.cursor() as cursor:
        cursor.execute(
            "EXECUTE SearchProducts @CategoryName = %s, @MinPrice = %s;",
            [category_name, min_price],
        )
        results = cursor.fetchall()
    return results

Считывать имена столбцов в результатах

Получение имен столбцов из cursor.description:

from django.db import connection

def get_products_as_dicts(category_name):
    with connection.cursor() as cursor:
        cursor.execute("EXECUTE GetProductsByCategory @CategoryName = %s;", [category_name])
        columns = [col[0] for col in cursor.description]
        results = [dict(zip(columns, row)) for row in cursor.fetchall()]
    return results

Обработка нескольких результирующих наборов

Некоторые хранимые процедуры возвращают несколько результирующих наборов. Используйте cursor.nextset() для перехода между ними:

from django.db import connection

def get_dashboard_data():
    with connection.cursor() as cursor:
        cursor.execute("EXECUTE GetDashboardData;")

        # First result set
        products = cursor.fetchall()

        # Move to second result set
        cursor.nextset()
        categories = cursor.fetchall()

    return products, categories

Обернуть в менеджер Django

Инкапсулировать вызовы хранимых процедур в специальном менеджере для более чистой структуры кода:

from django.db import connection, models

class ProductManager(models.Manager):
    def by_category(self, category_name):
        with connection.cursor() as cursor:
            cursor.execute(
                "EXECUTE GetProductsByCategory @CategoryName = %s;",
                [category_name],
            )
            columns = [col[0] for col in cursor.description]
            return [dict(zip(columns, row)) for row in cursor.fetchall()]

class Product(models.Model):
    name = models.CharField(max_length=100)
    price = models.DecimalField(max_digits=10, decimal_places=2)
    category = models.CharField(max_length=100)

    objects = ProductManager()

Использование:

products = Product.objects.by_category("Electronics")

Связанный контент

  • Last updated on