mirrors/sqlxmq
1
0
Fork 0
mirror of https://github.com/Diggsey/sqlxmq.git synced 2025-02-17 18:45:19 +00:00
Code Issues Projects Releases Packages Wiki Activity

Retry on foreign key violation

Browse source
This commit is contained in:
Diggory Blake 2021-09-21 12:14:32 +01:00
parent 08b71b59ae
commit 9424605cfb
No known key found for this signature in database
GPG key ID: E6BDFA83146ABD40
3 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
Cargo.toml
View file

@ -1,6 +1,6 @@
[package] [package]
name = "sqlxmq" name = "sqlxmq"
version = "0.3.0" version = "0.3.1"
authors = ["Diggory Blake <diggsey@googlemail.com>"] authors = ["Diggory Blake <diggsey@googlemail.com>"]
edition = "2018" edition = "2018"
license = "MIT OR Apache-2.0" license = "MIT OR Apache-2.0"
@ -23,7 +23,7 @@ uuid = { version = "0.8.2", features = ["v4"] }
log = "0.4.14" log = "0.4.14"
serde_json = "1.0.64" serde_json = "1.0.64"
serde = "1.0.124" serde = "1.0.124"
sqlxmq_macros = { version = "0.3.0", path = "sqlxmq_macros" } sqlxmq_macros = { version = "0.3.1", path = "sqlxmq_macros" }
anymap2 = "0.13.0" anymap2 = "0.13.0"
[features] [features]

2
sqlxmq_macros/Cargo.toml
View file

@ -1,6 +1,6 @@
[package] [package]
name = "sqlxmq_macros" name = "sqlxmq_macros"
version = "0.3.0" version = "0.3.1"
authors = ["Diggory Blake <diggsey@googlemail.com>"] authors = ["Diggory Blake <diggsey@googlemail.com>"]
edition = "2018" edition = "2018"
license = "MIT OR Apache-2.0" license = "MIT OR Apache-2.0"

2
src/lib.rs
View file

@ -243,6 +243,8 @@ pub fn should_retry(error: &sqlx::Error) -> bool {
// It's more readable as a match // It's more readable as a match
#[allow(clippy::match_like_matches_macro)] #[allow(clippy::match_like_matches_macro)]
match (db_error.code().as_deref(), db_error.constraint().as_deref()) { match (db_error.code().as_deref(), db_error.constraint().as_deref()) {
// Foreign key constraint violation on ordered channel
(Some("23503"), Some("mq_msgs_after_message_id_fkey")) => true,
// Unique constraint violation on ordered channel // Unique constraint violation on ordered channel
(Some("23505"), Some("mq_msgs_channel_name_channel_args_after_message_id_idx")) => true, (Some("23505"), Some("mq_msgs_channel_name_channel_args_after_message_id_idx")) => true,
// Serialization failure // Serialization failure