diff options
Diffstat (limited to 'src/sql')
| -rw-r--r-- | src/sql/accessLogPurgeOld.sql | 2 | ||||
| -rw-r--r-- | src/sql/deleteEntity.sql | 2 | ||||
| -rw-r--r-- | src/sql/markEntityRetried.sql | 6 | ||||
| -rw-r--r-- | src/sql/selectUninsertableLines.sql | 12 | ||||
| -rw-r--r-- | src/sql/setEntityType.sql | 6 |
5 files changed, 26 insertions, 2 deletions
diff --git a/src/sql/accessLogPurgeOld.sql b/src/sql/accessLogPurgeOld.sql index 00e55b5..616b3a6 100644 --- a/src/sql/accessLogPurgeOld.sql +++ b/src/sql/accessLogPurgeOld.sql @@ -5,8 +5,6 @@ WITH delete_batch AS ( access_log WHERE request_time < CURRENT_DATE - ?::interval - ORDER BY - request_time FOR UPDATE LIMIT ?) DELETE FROM access_log AS al USING delete_batch AS del 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..894ab67 --- /dev/null +++ b/src/sql/selectUninsertableLines.sql @@ -0,0 +1,12 @@ +SELECT + id, + value +FROM + entities +WHERE + type = 'uninsertable_line' + AND detail IS NULL +ORDER BY + id +LIMIT ? +FOR UPDATE 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 = ? |