starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-08-19 00:02:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: add mysql decimal support (#3557)

Browse Source
This commit is contained in:
HugoCasa
2024-04-15 14:26:17 +02:00
committed by GitHub
parent d92df3f3cd
commit c23fdc1585
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-worker/src/mysql_executor.rs
+13 -1
View File
@@ -145,7 +145,16 @@ pub async fn do_mysql(
Value::Number(n) if n.is_u64() && arg_t == "uint" => {
mysql_async::Value::UInt(n.as_u64().unwrap())
}
Value::Number(n) if n.is_f64() && arg_t == "real" => n.as_f64().into(),
Value::Number(n)
if n.is_f64() && (arg_t == "real" || arg_t == "dec" || arg_t == "fixed") =>
{
n.as_f64().unwrap().into()
}
Value::Number(n)
if n.is_i64() && (arg_t == "real" || arg_t == "dec" || arg_t == "fixed") =>
{
(n.as_i64().unwrap() as f64).into()
}
value @ _ => {
return Err(Error::ExecutionErr(format!(
"Unsupported type in query: {:?} and signature {arg_t:?}",
@@ -272,6 +281,9 @@ fn convert_mysql_value_to_json(v: mysql_async::Value, c: ColumnType) -> serde_js
ColumnType::MYSQL_TYPE_FLOAT | ColumnType::MYSQL_TYPE_DOUBLE => {
conversion_error(f64::from_value_opt(v))
}
ColumnType::MYSQL_TYPE_DECIMAL | ColumnType::MYSQL_TYPE_NEWDECIMAL => {
conversion_error(rust_decimal::Decimal::from_value_opt(v))
}
ColumnType::MYSQL_TYPE_TINY
| ColumnType::MYSQL_TYPE_SHORT
| ColumnType::MYSQL_TYPE_LONG