Skip to content

Commit 20a68b0

Browse files
authored
fix(connector): improve mysql error message (#20135)
1 parent 7e26b2f commit 20a68b0

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

src/connector/src/parser/mysql.rs

+8-8
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,8 @@ use risingwave_common::types::{
3232
use rust_decimal::Decimal as RustDecimal;
3333

3434
macro_rules! handle_data_type {
35-
($row:expr, $i:expr, $name:expr, $type:ty) => {{
36-
match $row.take_opt::<Option<$type>, _>($i) {
35+
($row:expr, $i:expr, $name:expr, $typ:ty) => {{
36+
match $row.take_opt::<Option<$typ>, _>($i) {
3737
None => bail!("no value found at column: {}, index: {}", $name, $i),
3838
Some(Ok(val)) => Ok(val.map(|v| ScalarImpl::from(v))),
3939
Some(Err(e)) => Err(anyhow::Error::new(e.clone())
@@ -42,21 +42,21 @@ macro_rules! handle_data_type {
4242
"column: {}, index: {}, rust_type: {}",
4343
$name,
4444
$i,
45-
stringify!($type),
45+
stringify!($typ),
4646
))),
4747
}
4848
}};
49-
($row:expr, $i:expr, $name:expr, $type:ty, $rw_type:ty) => {{
50-
match $row.take_opt::<Option<$type>, _>($i) {
49+
($row:expr, $i:expr, $name:expr, $typ:ty, $rw_type:ty) => {{
50+
match $row.take_opt::<Option<$typ>, _>($i) {
5151
None => bail!("no value found at column: {}, index: {}", $name, $i),
5252
Some(Ok(val)) => Ok(val.map(|v| ScalarImpl::from(<$rw_type>::from(v)))),
5353
Some(Err(e)) => Err(anyhow::Error::new(e.clone())
54-
.context("failed to deserialize MySQL value into rust value")
54+
.context("failed to deserialize MySQL value into rw value")
5555
.context(format!(
56-
"column: {}, index: {}, rust_type: {}",
56+
"column: {}, index: {}, rw_type: {}",
5757
$name,
5858
$i,
59-
stringify!($ty),
59+
stringify!($rw_type),
6060
))),
6161
}
6262
}};

0 commit comments

Comments
 (0)