Subversion Repositories SmartDukaan

import MySQLdb

db = MySQLdb.connect('localhost',"root","shop2020","warehouse" )

cursor = db.cursor()

def processPurchaseOrdersClosure():

    sql = "select id, poValidityLimit from supplier"

    print sql

    cursor.execute(sql)

    result = cursor.fetchall()

    for rec in result:

        updateSql = "update purchaseorder set status = 3 where supplierId = %d and DATE(createdAt) < DATE(SUBDATE(NOW(), %d))"%(rec[0],rec[1])

        print updateSql

        try:

            # Execute the update SQL command

            cursor.execute(updateSql)

            # Commit your changes in the database

            db.commit()

        except:

            # Rollback in case there is any error

            db.rollback()

def main():

    processPurchaseOrdersClosure()

if __name__=='__main__':

    main()