Django框架orM与自定义SQL语句混合事务控制操作

2019-11-25 12:36:51

字体：大中小

来源：转载

供稿：网友

本文实例讲述了Django框架orM与自定义SQL语句混合事务控制操作。分享给大家供大家参考，具体如下：

用单纯的ORM 或者单纯的自定义SQL语句，都比较好控制事务。在前面的一篇文章中已经讲过Django事务小结 ,但里面没有提到在同一个方法里面既有ORM 又有自定义SQL 语句的情况。

如果是单纯的ORM ,可以这样做,假设已经定义好model, User,Category。

from django.db import transaction...@commit_on_successdef save_test(request):  user=User(name="aaa",age=30)  user.save()  cat=Category(id=2,name="cat001")  cat.save()  .......

只有在程序成功执行，没错时，才会commit. 比如如果cat 保存出错，那么user 就会回滚。

如果是单纯的自定义SQL语句,可以通过如下方式实现

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 retsqlarray=[]sqlarray.append("insert into table .......")sqlarray.append("update table set.......")ret=batch_execsql(sqlarray)

用这种方式，实现自定义SQL语句的事务，只要任何一条语句出错，就会回滚.

那么，如果ORM 与自定义SQL 语句混合如何做呢，我在项目中结合了上面两种方式。比如按如下的方式

@commit_on_successdef 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方式，因为我自己需要，但总体上ORM 与自定义SQL混合事务，就可以这么控制了。

希望本文所述对大家基于Django框架的Python程序设计有所帮助。

上一篇：Python批量查询关键词微信指数实例方法

下一篇：Pycharm保存不能自动同步到远程服务器的解决方法