|
|
|
@ -469,23 +469,19 @@ fn convert_column_value_to_string(row: &PgRow, column: &PgColumn) -> anyhow::Res
|
|
|
|
|
let column_name = column.name();
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<i16> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<i32> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<i64> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<rust_decimal::Decimal> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<&[u8]> = value;
|
|
|
|
|
return Ok(value.map_or("NULL".to_string(), |values| {
|
|
|
|
|
Ok(value.map_or("NULL".to_string(), |values| {
|
|
|
|
|
format!(
|
|
|
|
|
"\\x{}",
|
|
|
|
|
values
|
|
|
|
@ -493,51 +489,42 @@ fn convert_column_value_to_string(row: &PgRow, column: &PgColumn) -> anyhow::Res
|
|
|
|
|
.map(|v| format!("{:02x}", v))
|
|
|
|
|
.collect::<String>()
|
|
|
|
|
)
|
|
|
|
|
}));
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
}))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<NaiveDate> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: String = value;
|
|
|
|
|
return Ok(value);
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(value)
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<chrono::DateTime<chrono::Utc>> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<chrono::DateTime<chrono::Local>> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<NaiveDateTime> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<NaiveDate> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<NaiveTime> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<serde_json::Value> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get::<Option<bool>, _>(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get::<Option<bool>, _>(column_name) {
|
|
|
|
|
let value: Option<bool> = value;
|
|
|
|
|
get_or_null!(value)
|
|
|
|
|
}
|
|
|
|
|
if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
Ok(get_or_null!(value))
|
|
|
|
|
} else if let Ok(value) = row.try_get(column_name) {
|
|
|
|
|
let value: Option<Vec<String>> = value;
|
|
|
|
|
return Ok(value.map_or("NULL".to_string(), |v| v.join(",")));
|
|
|
|
|
Ok(value.map_or("NULL".to_string(), |v| v.join(",")))
|
|
|
|
|
} else {
|
|
|
|
|
anyhow::bail!(
|
|
|
|
|
"column type not implemented: `{}` {}",
|
|
|
|
|
column_name,
|
|
|
|
|
column.type_info().clone().name()
|
|
|
|
|
)
|
|
|
|
|
}
|
|
|
|
|
Err(anyhow::anyhow!(
|
|
|
|
|
"column type not implemented: `{}` {}",
|
|
|
|
|
column_name,
|
|
|
|
|
column.type_info().clone().name()
|
|
|
|
|
))
|
|
|
|
|
}
|
|
|
|
|