您好,登錄后才能下訂單哦!
本文實(shí)例講述了Django框架orM與自定義SQL語句混合事務(wù)控制操作。分享給大家供大家參考,具體如下:
用單純的ORM 或者單純的自定義SQL語句,都比較好控制事務(wù)。在前面的一篇文章中已經(jīng)講過Django事務(wù)小結(jié) ,但里面沒有提到在同一個(gè)方法里面既有ORM 又有 自定義SQL 語句的情況。
如果是單純的ORM ,可以這樣做,假設(shè)已經(jīng)定義好model, User,Category。
from django.db import transaction ... @commit_on_success def save_test(request): user=User(name="aaa",age=30) user.save() cat=Category(id=2,name="cat001") cat.save() .......
只有在程序成功執(zhí)行,沒錯(cuò)時(shí),才會(huì)commit. 比如如果cat 保存出錯(cuò),那么user 就會(huì)回滾。
如果是單純的自定義SQL語句,可以通過如下方式實(shí)現(xiàn)
from django.db import connection, transaction ... def batch_execsql(sqlarray): print sqlarray cursor = connection.cursor() ret="" try: for sql in sqlarray: cursor.execute(sql) transaction.commit_unless_managed() except Exception,e: ret=str(e) cursor.close() return ret sqlarray=[] sqlarray.append("insert into table .......") sqlarray.append("update table set.......") ret=batch_execsql(sqlarray)
用這種方式,實(shí)現(xiàn)自定義SQL語句的事務(wù),只要任何一條語句出錯(cuò),就會(huì)回滾.
那么,如果ORM 與 自定義SQL 語句混合如何做呢,我在項(xiàng)目中結(jié)合了上面兩種方式。比如按如下的方式
@commit_on_success def save_company_callinfo(request): response=HttpResponse() try: #==orm 保存部分====== .... model1.save() .... model2.save() ... #==自定義SQL 部分==== sqlarray=[] sqlarray.append("insert into table .......") sqlarray.append("update table set.......") ret=batch_execsql(sqlarray) if len(ret)>0: transaction.rollback() response.write('{"status":"no","error":"%s"}' % ('add call information error',)) else: response.write('{"status":"no","error":"%s"}' % ('',)) except Exception,e: response.write('{"status":"no","error":"%s"}' % (str(e),)) return response
這上面的過程可以自己修改成自己需要的,我用的是AJAX方式,因?yàn)槲易约盒枰?,但總體上ORM 與自定義SQL混合事務(wù),就可以這么控制了。
希望本文所述對大家基于Django框架的Python程序設(shè)計(jì)有所幫助。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。