Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-08 17:36:29 +03:00
Code Issues Packages Projects Releases Wiki Activity

try fix sql

Browse Source
This commit is contained in:
dignifiedquire
2019-11-27 22:36:38 +01:00
parent 10925bd5e1
commit 718f4507b1
1 changed files with 23 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
src/job.rs
View File

@@ -754,45 +754,36 @@ fn job_perform(context: &Context, thread: ThreadExecutor, probe_network: bool) {
")" ")"
}; };
let query_start = concat!(
"SELECT ",
"j.id AS id, ",
"j.action AS action, ",
"j.foreign_id AS foreign_id, ",
"j.param AS param, ",
"j.added_timestamp AS added_timestamp, ",
"j.desired_timestamp AS desired_timestamp, ",
"j.tries AS tries ",
"FROM jobs j ",
"LEFT JOIN msgs m",
)
.to_string();
let query = if !probe_network { let query = if !probe_network {
// processing for first-try and after backoff-timeouts: // processing for first-try and after backoff-timeouts:
// process jobs in the order they were added. // process jobs in the order they were added.
format!( query_start
"SELECT \ + "WHERE j.thread=? AND j.desired_timestamp<=? "
j.id AS id, \ + "((j.foreign_id IS NOT NULL AND m.server_folder=?) "
j.action AS action, \ + fallback
j.foreign_id AS foreign_id, \ + "ORDER BY j.action DESC, j.added_timestamp;"
j.param AS param, \
j.added_timestamp AS added_timestamp, \
j.desired_timestamp AS desired_timestamp, \
j.tries AS tries \
FROM jobs j \
LEFT JOIN msgs m\
WHERE j.thread=? AND j.desired_timestamp<=? \
((j.foreign_id IS NOT NULL AND m.server_folder=?) {} \
ORDER BY j.action DESC, j.added_timestamp;",
fallback
)
} else { } else {
// processing after call to dc_maybe_network(): // processing after call to dc_maybe_network():
// process _all_ pending jobs that failed before // process _all_ pending jobs that failed before
// in the order of their backoff-times. // in the order of their backoff-times.
format!( query_start
"SELECT \ + "WHERE j.thread=? AND j.tries>0 AND "
j.id AS id, \ + "((j.foreign_id IS NOT NULL AND m.server_folder=?) "
j.action AS action, \ + fallback
j.foreign_id AS foreign_id, \ + "ORDER BY j.desired_timestamp, j.action DESC;"
j.param AS param, \
j.added_timestamp AS added_timestamp, \
j.desired_timestamp AS desired_timestamp, \
j.tries AS tries \
FROM jobs j \
LEFT JOIN msgs m \
WHERE j.thread=? AND j.tries>0 AND \
((j.foreign_id IS NOT NULL AND m.server_folder=?) {} \
ORDER BY j.desired_timestamp, j.action DESC;",
fallback
)
}; };
let params_no_probe = params![thread as i64, time(), folder]; let params_no_probe = params![thread as i64, time(), folder];