Fix bug in remove_deleted_messages SQL that caused it too fail.
This commit is contained in:
parent
513cb8cb65
commit
86bbd250f9
|
|
@ -39,11 +39,11 @@
|
||||||
|
|
||||||
--get messages
|
--get messages
|
||||||
local sql = [[SELECT * FROM v_voicemail_messages
|
local sql = [[SELECT * FROM v_voicemail_messages
|
||||||
WHERE message_status = 'deleted'
|
WHERE message_status = 'deleted' ]]
|
||||||
AND (update_date + interval ':retention_hours hours') < now()
|
sql = sql .. "AND (update_date + interval '" .. deletion_queue_retention_hours .. " hours') < now() "
|
||||||
AND voicemail_uuid = :voicemail_uuid
|
sql = sql .. [[AND voicemail_uuid = :voicemail_uuid
|
||||||
AND domain_uuid = :domain_uuid]];
|
AND domain_uuid = :domain_uuid]];
|
||||||
local params = {retention_hours = deletion_queue_retention_hours, voicemail_uuid = db_voicemail_uuid, domain_uuid = domain_uuid}
|
local params = {voicemail_uuid = db_voicemail_uuid, domain_uuid = domain_uuid}
|
||||||
messages_to_delete = {};
|
messages_to_delete = {};
|
||||||
dbh:query(sql, params, function(row)
|
dbh:query(sql, params, function(row)
|
||||||
table.insert(messages_to_delete, row);
|
table.insert(messages_to_delete, row);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue