update

Documentation

Index

• Constants
• func ClearBefore(ctx context.Context, db database.Database, days int) (int64, error)
• func Records(ctx context.Context, db database.Database, records []model.Record) (int64, error)
• func Stations(ctx context.Context, db database.Database, stations []model.Station) (int64, error)

Constants

const (
	UpsertStationQuery = "INSERT INTO realtime_weather_station (id, name, altitude, has_rain_sensor, address) " +
		"VALUES (:id, :name, :altitude, :has_rain_sensor, :address) " +
		"ON CONFLICT (id) " +
		"DO UPDATE SET name = excluded.name, altitude = excluded.altitude, has_rain_sensor = excluded.has_rain_sensor, address = excluded.address"
	UpsertRecordQuery = "INSERT INTO realtime_weather_record(rain_acc, rain_fifteen, rain_hour, rain_three_hour, rain_six_hour, rain_twelve_hour, temperature, wind_avg_minute, wind_avg_minute_deg, wind_avg_ten_minute, wind_avg_ten_minute_deg, moisture, sea_level_air_pressure, station_id, time) " +
		"VALUES (:rain_acc, :rain_fifteen, :rain_hour, :rain_three_hour, :rain_six_hour, :rain_twelve_hour, :temperature, :wind_avg_minute, :wind_avg_minute_deg, :wind_avg_ten_minute, :wind_avg_ten_minute_deg, :moisture, :sea_level_air_pressure, :station_id, :time) " +
		"ON CONFLICT (time, station_id) " +
		"DO UPDATE SET rain_acc=excluded.rain_acc, rain_fifteen=excluded.rain_fifteen, rain_hour=excluded.rain_hour, rain_three_hour=excluded.rain_three_hour, rain_six_hour=excluded.rain_six_hour, rain_twelve_hour=excluded.rain_twelve_hour, temperature=excluded.temperature, wind_avg_minute=excluded.wind_avg_minute, wind_avg_minute_deg=excluded.wind_avg_minute_deg, wind_avg_ten_minute=excluded.wind_avg_ten_minute, wind_avg_ten_minute_deg=excluded.wind_avg_ten_minute_deg, moisture=excluded.moisture, sea_level_air_pressure=excluded.sea_level_air_pressure"
	DeleteOlderThanThreeDaysQuery = "DELETE FROM realtime_weather_record WHERE time < NOW() - interval '%d days';"
)

Functions

func ClearBefore

func ClearBefore(ctx context.Context, db database.Database, days int) (int64, error)

func Records

func Records(ctx context.Context, db database.Database, records []model.Record) (int64, error)

func Stations

func Stations(ctx context.Context, db database.Database, stations []model.Station) (int64, error)