浏览量 4850
2018/01/03 02:30
from django.db import connection
## 查询接口 ##
def cursorQuery( sql, parlist):
cursor = connection.cursor()
try:
cursor.execute(sql, parlist)
except Exception, e:
print "Catch exception : " + str(e)
return cursor.fetchall()
## 更新接口 ##
def cursorUpdate(sql,parlist):
cursor = connection.cursor()
try:
# 执行sql语句
cursor.execute(sql,parlist)
# 提交到数据库执行
connection.commit()
except:
# 发生错误时回滚
connection.rollback()
# 关闭数据库连接
connection.close()
上一篇 搜索 下一篇