mysql查询更新

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

☕ 请作者喝杯咖啡

微信支付 支付宝

长按识别 或 截图后微信扫一扫

长按识别 或 截图后支付宝扫一扫