Каков наилучший способ доступа к хранимым процедурам в Django ORM

Мы (musicpictures.com/eviscape.com) написали этот фрагмент django, но это не вся история (на самом деле этот код в то время тестировался только на Oracle).

Хранимые процедуры имеют смысл, когда вы хотите повторно использовать испытанный и проверенный код SP или когда один вызов SP будет быстрее, чем несколько вызовов к базе данных, или когда безопасность требует модерируемого доступа к базе данных, или когда запросы очень сложные/многошаговые. Мы используем подход гибридной модели/SP к базам данных Oracle и Postgres.

Хитрость заключается в том, чтобы сделать его простым в использовании и сохранить его как «джанго». Мы используем функцию make_instance, которая берет результат курсора и создает экземпляры модели, заполненные курсором. Это хорошо, потому что курсор может возвращать дополнительные поля. Затем вы можете использовать эти экземпляры в своем коде/шаблоне так же, как обычные объекты модели django.

def make_instance(instance, values):
    '''
    Copied from eviscape.com

    generates an instance for dict data coming from an sp

    expects:
        instance - empty instance of the model to generate
        values -   dictionary from a stored procedure with keys that are named like the
                   model's attributes
    use like:
        evis = InstanceGenerator(Evis(), evis_dict_from_SP)

    >>> make_instance(Evis(), {'evi_id': '007', 'evi_subject': 'J. Bond, Architect'})
    <Evis: J. Bond, Architect>

    '''
    attributes = filter(lambda x: not x.startswith('_'), instance.__dict__.keys())

    for a in attributes:
        try:
            # field names from oracle sp are UPPER CASE
            # we want to put PIC_ID in pic_id etc.
            setattr(instance, a, values[a.upper()])
            del values[a.upper()]
        except:
            pass

    #add any values that are not in the model as well
    for v in values.keys():
        setattr(instance, v, values[v])
        #print 'setting %s to %s' % (v, values[v])

    return instance

# Используйте это так:

pictures = [make_instance(Pictures(), item) for item in picture_dict]

# А вот и вспомогательные функции:

def call_an_sp(self, var):
    cursor = connection.cursor()
    cursor.callproc("fn_sp_name", (var,))
    return self.fn_generic(cursor)


def fn_generic(self, cursor):
    msg = cursor.fetchone()[0]
    cursor.execute('FETCH ALL IN "%s"' % msg)
    thing = create_dict_from_cursor(cursor)
    cursor.close()
    return thing

def create_dict_from_cursor(cursor):
    rows = cursor.fetchall()
    # DEBUG settings (used to) affect what gets returned. 
    if DEBUG:
        desc = [item[0] for item in cursor.cursor.description]
    else:
        desc = [item[0] for item in cursor.description]
    return [dict(zip(desc, item)) for item in rows]    

привет, Саймон.

Вы должны использовать утилиту подключения в Django:

from django.db import connection

with connection.cursor() as cursor:
    cursor.execute("SQL STATEMENT CAN BE ANYTHING")
    data = cursor.fetchone()

Если вы ожидаете более одной строки, используйте cursor.fetchall() для получения их списка.

Дополнительная информация здесь: http://docs.djangoproject.com/en/dev/topics/db/sql/

Не.

Шутки в сторону.

Переместите логику хранимой процедуры в свою модель, где ей и место.

Размещение некоторого кода в Django и некоторого кода в базе данных — это кошмар обслуживания. Я провел слишком много из своих 30 с лишним лет в ИТ, пытаясь навести порядок в этом беспорядке.

Хороший пример: https://djangosnippets.org/snippets/118/

from django.db import connection


cursor = connection.cursor()
ret = cursor.callproc("MY_UTIL.LOG_MESSAGE", (control_in, message_in))# calls PROCEDURE named LOG_MESSAGE which resides in MY_UTIL Package
cursor.close()

Если вы хотите взглянуть на реально работающий проект, в котором используется SP, ознакомьтесь с мини-книгами. Много пользовательского SQL и использует Postgres pl/pgsql для SP. Я думаю, что в конечном итоге они собираются удалить SP (обоснование в trac ticket 92).

Я предполагаю, что улучшенная поддержка исходного набора запросов sql в Django 1.2 может упростить эту задачу, поскольку вам не нужно будет создавать собственный код типа make_instance.

Можно использовать Cx_Oracle. Кроме того, это довольно полезно, когда у нас нет доступа к производственному развернутому коду и возникает необходимость внести серьезные изменения в базу данных.

import cx_Oracle
try:
    db = dev_plng_con
    con = cx_Oracle.connect(db)
    cur = con.cursor()
    P_ERROR = str(error)
    cur.callproc('NAME_OF_PACKAGE.PROCEDURENAME', [P_ERROR])

except Exception as error:
    error_logger.error(message)