1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
package rides
import (
"database/sql"
"time"
"github.com/martinlehoux/kagamigo/kcore"
)
type Ride struct {
ID int64
ExternalID string
GPXPath string
Name string
Type string
StartDate time.Time
DistanceM float64
MovingTimeS int64
ElapsedTimeS int64
TotalElevationGainM float64
AverageSpeedMps float64
CreatedAt time.Time
UpdatedAt time.Time
}
const columns = "id, external_id, gpx_path, name, type, start_date, distance_m, moving_time_s, elapsed_time_s, total_elevation_gain_m, average_speed_mps, created_at, updated_at"
func Save(db *sql.DB, r Ride) error {
_, err := db.Exec(`
INSERT INTO rides (external_id, gpx_path, name, type, start_date, distance_m, moving_time_s, elapsed_time_s, total_elevation_gain_m, average_speed_mps)
VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT(external_id) DO UPDATE SET
gpx_path = excluded.gpx_path,
name = excluded.name,
type = excluded.type,
start_date = excluded.start_date,
distance_m = excluded.distance_m,
moving_time_s = excluded.moving_time_s,
elapsed_time_s = excluded.elapsed_time_s,
total_elevation_gain_m = excluded.total_elevation_gain_m,
average_speed_mps = excluded.average_speed_mps,
updated_at = strftime('%Y-%m-%dT%H:%M:%SZ', 'now')
`, r.ExternalID, r.GPXPath, r.Name, r.Type, r.StartDate.UTC().Format(time.RFC3339), r.DistanceM, r.MovingTimeS, r.ElapsedTimeS, r.TotalElevationGainM, r.AverageSpeedMps)
return err
}
func List(db *sql.DB) ([]Ride, error) {
rows, err := db.Query("SELECT " + columns + " FROM rides ORDER BY start_date DESC")
if err != nil {
return nil, err
}
defer rows.Close()
var rides []Ride
for rows.Next() {
ride, err := scanRide(rows)
if err != nil {
return nil, err
}
rides = append(rides, ride)
}
return rides, rows.Err()
}
func GetByExternalID(db *sql.DB, externalID string) (Ride, bool, error) {
row := db.QueryRow("SELECT "+columns+" FROM rides WHERE external_id = ?", externalID)
ride, err := scanRide(row)
if err == sql.ErrNoRows {
return Ride{}, false, nil
}
if err != nil {
return Ride{}, false, err
}
return ride, true, nil
}
type scanner interface {
Scan(dest ...any) error
}
func scanRide(s scanner) (Ride, error) {
var (
ride Ride
startDate string
createdAt string
updatedAt string
)
err := s.Scan(&ride.ID, &ride.ExternalID, &ride.GPXPath, &ride.Name, &ride.Type, &startDate, &ride.DistanceM, &ride.MovingTimeS, &ride.ElapsedTimeS, &ride.TotalElevationGainM, &ride.AverageSpeedMps, &createdAt, &updatedAt)
if err != nil {
return Ride{}, err
}
ride.StartDate, err = time.Parse(time.RFC3339, startDate)
if err != nil {
return Ride{}, kcore.Wrap(err, "invalid start_date in rides row")
}
ride.CreatedAt, err = time.Parse(time.RFC3339, createdAt)
if err != nil {
return Ride{}, kcore.Wrap(err, "invalid created_at in rides row")
}
ride.UpdatedAt, err = time.Parse(time.RFC3339, updatedAt)
if err != nil {
return Ride{}, kcore.Wrap(err, "invalid updated_at in rides row")
}
return ride, nil
}
|