diff --git a/database/EstimatedVehicleJourney.go b/database/EstimatedVehicleJourney.go index 57692fe..4efa54a 100644 --- a/database/EstimatedVehicleJourney.go +++ b/database/EstimatedVehicleJourney.go @@ -7,8 +7,8 @@ import ( func InsertOrUpdateEstimatedVehicleJourney(db *sql.DB, values []interface{}) (int, string, error) { query := ` - INSERT INTO estimatedvehiclejourney (servicedelivery, recordedattime, lineref, directionref, datasource, datedvehiclejourneyref, vehiclemode, dataframeref, originref, destinationref, operatorref, vehicleref, cancellation, other) - VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14) + INSERT INTO estimatedvehiclejourney (servicedelivery, recordedattime, lineref, directionref, datasource, datedvehiclejourneyref, vehiclemode, dataframeref, originref, destinationref, operatorref, vehicleref, cancellation, other, firstservicedelivery) + VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $1) ON CONFLICT (lineref, directionref, datasource, datedvehiclejourneyref) DO UPDATE SET servicedelivery = EXCLUDED.servicedelivery, diff --git a/main.go b/main.go index 3519749..50c7804 100644 --- a/main.go +++ b/main.go @@ -21,4 +21,5 @@ func main() { //log.Printf("Data fetched successfully: %+v", data) //export.PrintData(data) + }