def createInsertSQLQueries()

in src/ddb-stream-processor/lambda_function.py [0:0]

• 16 lines of code
• 2 McCabe index (conditional complexity)

def createInsertSQLQueries(completedTripList):
    insertSQLQuries = []
    
    queryStringBase = """INSERT INTO public.trips (
            rider_id, driver_id, rider_name, rider_mobile, rider_email, trip_info, driver_name,
            driver_email, driver_mobile, vehicle_id, cab_type_id, vendor_id, pickup_datetime,
            dropoff_datetime, store_and_fwd_flag, rate_code_id, pickup_longitude, pickup_latitude,
            dropoff_longitude, dropoff_latitude, passenger_count, trip_distance, fare_amount, extra,
            mta_tax, tip_amount, tolls_amount, ehail_fee, improvement_surcharge, total_amount, payment_type,
            trip_type, pickup_location_id, dropoff_location_id, status)"""
            
    for tripInfo in completedTripList:
        queryString = queryStringBase + " VALUES(" 
        queryString += tripInfo['riderId'] + "," + tripInfo['driver_id'] + ",'" + tripInfo['rider_name'] + "','" + tripInfo['rider_mobile'] + "','" + tripInfo['rider_email'] + "','" + tripInfo['trip_Info'] + "','"
        queryString += tripInfo['driver_name'] + "','" + tripInfo['driver_email'] + "','" + tripInfo['driver_mobile'] + "','" + tripInfo['vehicle_id'] + "'," + tripInfo['cab_type_id'] + ","
        queryString += tripInfo['vendor_id'] + ",'" + tripInfo['pickup_datetime'] + "','" + tripInfo['dropoff_datetime'] + "','" + tripInfo['store_and_fwd_flag'] + "'," + tripInfo['rate_code_id'] + ","
        queryString += tripInfo['pickup_longitude'] + "," + tripInfo['pickup_latitude'] + "," + tripInfo['dropoff_longitude'] + "," + tripInfo['dropoff_latitude'] + "," + tripInfo['passenger_count'] + ","
        queryString += tripInfo['trip_distance'] + "," + tripInfo['fare_amount'] + "," + tripInfo['extra'] + "," + tripInfo['mta_tax'] + "," + tripInfo['tip_amount'] + ","
        queryString += tripInfo['tolls_amount'] + "," + "0" + "," + tripInfo['improvement_surcharge'] + "," + tripInfo['total_amount'] + "," + tripInfo['payment_type'] + ","
        queryString += tripInfo['trip_type'] + "," + "0" + "," + "0" + ",'" + tripInfo['status'] + "');"
        
        print("Trip information =" + json.dumps(tripInfo, indent = 2))
        print ("Insert query string =" + queryString)
        
        insertSQLQuries.append(queryString)
        
    return insertSQLQuries