Handle errors on insert to 'events' 'eventsFTS' 'tags'
This commit is contained in:
parent
292010b830
commit
93eaa61e1e
|
@ -428,10 +428,9 @@ impl SqliteDb {
|
||||||
])
|
])
|
||||||
.build_sqlx(sea_query::SqliteQueryBuilder);
|
.build_sqlx(sea_query::SqliteQueryBuilder);
|
||||||
|
|
||||||
let results = sqlx::query_with(&sql, values)
|
if let Err(e) = sqlx::query_with(&sql, values).execute(&self.pool).await {
|
||||||
.execute(&self.pool)
|
log::error!("Error inserting event into 'events' table: {}", e);
|
||||||
.await
|
}
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
// Insert into EventsFTS table
|
// Insert into EventsFTS table
|
||||||
dbg!("inserting new event into eventsFTS");
|
dbg!("inserting new event into eventsFTS");
|
||||||
|
@ -441,10 +440,9 @@ impl SqliteDb {
|
||||||
.values_panic([id.clone().into(), content.into()])
|
.values_panic([id.clone().into(), content.into()])
|
||||||
.build_sqlx(sea_query::SqliteQueryBuilder);
|
.build_sqlx(sea_query::SqliteQueryBuilder);
|
||||||
|
|
||||||
let results = sqlx::query_with(&sql, values)
|
if let Err(e) = sqlx::query_with(&sql, values).execute(&self.pool).await {
|
||||||
.execute(&self.pool)
|
log::error!("Error inserting event into 'eventsFTS' table: {}", e);
|
||||||
.await
|
}
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
// Insert into Tags table
|
// Insert into Tags table
|
||||||
dbg!("inserting new event into tags");
|
dbg!("inserting new event into tags");
|
||||||
|
@ -460,10 +458,9 @@ impl SqliteDb {
|
||||||
.values_panic([tag_name.into(), tag_value.into(), id.clone().into()])
|
.values_panic([tag_name.into(), tag_value.into(), id.clone().into()])
|
||||||
.build_sqlx(sea_query::SqliteQueryBuilder);
|
.build_sqlx(sea_query::SqliteQueryBuilder);
|
||||||
|
|
||||||
let results = sqlx::query_with(&sql, values)
|
if let Err(e) = sqlx::query_with(&sql, values).execute(&self.pool).await {
|
||||||
.execute(&self.pool)
|
log::error!("Error inserting event into 'tags' table: {}", e);
|
||||||
.await
|
}
|
||||||
.unwrap();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue