葫芦的运维日志

下一篇 搜索 上一篇

---

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()

 

葫芦的运维日志

打赏

上一篇 搜索 下一篇