Skip to content

Commit

Permalink
spi-stats:fix record modify.
Browse files Browse the repository at this point in the history
  • Loading branch information
ljl committed Dec 13, 2024
1 parent beb736f commit e138c80
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions backend/spi/spi-stats/src/serv/pg/stats_pg_record_serv.rs
Original file line number Diff line number Diff line change
Expand Up @@ -532,7 +532,7 @@ async fn fact_records_modify(
));
};
// TODO check value enum when stable_ds = true
sql_sets.push(format!("{} = ${}", req_fact_col_key, params.len() + 1));
sql_sets.push(format!("{} = ${}", fact_col_conf.key, params.len() + 1));
if fact_col_conf.dim_multi_values.unwrap_or(false) {
params.push(dim_conf.data_type.json_to_sea_orm_value_array(&req_fact_col_value, false)?);
} else {
Expand All @@ -547,7 +547,7 @@ async fn fact_records_modify(
"400-spi-stats-invalid-request",
));
};
sql_sets.push(format!("{} = ${}", req_fact_col_key, params.len() + 1));
sql_sets.push(format!("{} = ${}", fact_col_conf.key, params.len() + 1));
params.push(mes_data_type.json_to_sea_orm_value(&req_fact_col_value, false)?);
} else {
let Some(req_fact_col_value) = req_fact_col_value.as_str() else {
Expand All @@ -558,7 +558,7 @@ async fn fact_records_modify(
"400-spi-stats-invalid-request",
));
};
sql_sets.push(format!("{} = ${}", req_fact_col_key, params.len() + 1));
sql_sets.push(format!("{} = ${}", fact_col_conf.key, params.len() + 1));
params.push(req_fact_col_value.into());
}
}
Expand Down

0 comments on commit e138c80

Please sign in to comment.