diff options
| author | Dan Goodliffe <dan.goodliffe@octal.co.uk> | 2026-05-19 12:12:28 +0100 |
|---|---|---|
| committer | Dan Goodliffe <dan.goodliffe@octal.co.uk> | 2026-05-19 12:12:28 +0100 |
| commit | a3d868ca57591a6d977da8a7e9ec5c14976e73ec (patch) | |
| tree | 803085077c0a4ad148359738b985e117dff75c42 /src/sql | |
| parent | 29f458117184af5b1507cac01b48b41bfbad568a (diff) | |
| parent | cabd894779c2d2e453c8ed7771fdbd17c881bc2c (diff) | |
| download | webstat-a3d868ca57591a6d977da8a7e9ec5c14976e73ec.tar.bz2 webstat-a3d868ca57591a6d977da8a7e9ec5c14976e73ec.tar.xz webstat-a3d868ca57591a6d977da8a7e9ec5c14976e73ec.zip | |
Merge remote-tracking branch 'origin/retry-store'
Diffstat (limited to 'src/sql')
| -rw-r--r-- | src/sql/deleteEntity.sql | 2 | ||||
| -rw-r--r-- | src/sql/markEntityRetried.sql | 6 | ||||
| -rw-r--r-- | src/sql/selectUninsertableLines.sql | 11 | ||||
| -rw-r--r-- | src/sql/setEntityType.sql | 6 |
4 files changed, 25 insertions, 0 deletions
diff --git a/src/sql/deleteEntity.sql b/src/sql/deleteEntity.sql new file mode 100644 index 0000000..e201384 --- /dev/null +++ b/src/sql/deleteEntity.sql @@ -0,0 +1,2 @@ +DELETE FROM entities +WHERE id = ? diff --git a/src/sql/markEntityRetried.sql b/src/sql/markEntityRetried.sql new file mode 100644 index 0000000..6ec2263 --- /dev/null +++ b/src/sql/markEntityRetried.sql @@ -0,0 +1,6 @@ +UPDATE + entities +SET + detail = jsonb_build_object('retriedAt', CURRENT_TIMESTAMP at time zone 'utc', 'error', ?::text) +WHERE + id = ? diff --git a/src/sql/selectUninsertableLines.sql b/src/sql/selectUninsertableLines.sql new file mode 100644 index 0000000..5c07791 --- /dev/null +++ b/src/sql/selectUninsertableLines.sql @@ -0,0 +1,11 @@ +SELECT + id, + value +FROM + entities +WHERE + type = 'uninsertable_line' + AND detail IS NULL +ORDER BY + id +LIMIT ? diff --git a/src/sql/setEntityType.sql b/src/sql/setEntityType.sql new file mode 100644 index 0000000..5c981b9 --- /dev/null +++ b/src/sql/setEntityType.sql @@ -0,0 +1,6 @@ +UPDATE + entities +SET + type = ?::entity +WHERE + id = ? |