I am designing a fairly complex database, and know that some of my queries will be far outside the scope of Django’s ORM. Has anyone integrated SP’s with Django’s ORM successfully? If so, what RDBMS and how did you do it?
Advertisement
Answer
We (musicpictures.com / eviscape.com) wrote that django snippet but its not the whole story (actually that code was only tested on Oracle at that time).
Stored procedures make sense when you want to reuse tried and tested SP code or where one SP call will be faster than multiple calls to the database – or where security requires moderated access to the database – or where the queries are very complicated / multistep. We’re using a hybrid model/SP approach against both Oracle and Postgres databases.
The trick is to make it easy to use and keep it “django” like. We use a make_instance function which takes the result of cursor and creates instances of a model populated from the cursor. This is nice because the cursor might return additional fields. Then you can use those instances in your code / templates much like normal django model objects.
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
# Use it like this:
pictures = [make_instance(Pictures(), item) for item in picture_dict]
# And here are some helper functions:
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]
cheers, Simon.