veryroundbird.house
1package db
2
3type DbWrapper struct {
4 Execer
5}
6
7func (db DbWrapper) SaveLastTimeUs(lastTimeUs int64) error {
8 _, err := db.Exec(`insert into _jetstream (last_time_us) values (?)`, lastTimeUs)
9 return err
10}
11
12func (db DbWrapper) UpdateLastTimeUs(lastTimeUs int64) error {
13 _, err := db.Exec(`update _jetstream set last_time_us = ? where rowid = 1`, lastTimeUs)
14 if err != nil {
15 return err
16 }
17 return nil
18}
19
20func (db DbWrapper) GetLastTimeUs() (int64, error) {
21 var lastTimeUs int64
22 row := db.QueryRow(`select last_time_us from _jetstream`)
23 err := row.Scan(&lastTimeUs)
24 return lastTimeUs, err
25}