addCamera.py 文件源码

def insert_into_non_ip(sourceName,db):
    cursor = db.cursor()
    print '---------------------------------------------------------------------------------'
    print "STEP 5 : insert into non_ip_camera table"
    sql = "INSERT IGNORE INTO non_ip_camera (camera_id, snapshot_url) SELECT id, camera_key FROM camera WHERE source ="+"'"+sourceName+"'"
    print sql
    print '---------------------------------------------------------------------------------'
    isSuccess =True
    try:
        print "inserting into non_ip_camera table"
        cursor.execute(sql)
        num_record = cursor.rowcount
        print "%d row affected"%(int(num_record))
    except MySQLdb.Error, e:
        print "MySQL Error [%d]: %s" % (e.args[0], e.args[1])
        isSuccess = False
    except MySQLdb.Warning,e:
        print "MYSQL Warning : %s"%e
        #print "MySQL Warning[%d]: %s"% (e.args[0], e.args[1])
        isSuccess = False
    return isSuccess