diff --git a/connectorx/src/sources/mysql/typesystem.rs b/connectorx/src/sources/mysql/typesystem.rs index 105b7271c..d204d101b 100644 --- a/connectorx/src/sources/mysql/typesystem.rs +++ b/connectorx/src/sources/mysql/typesystem.rs @@ -116,6 +116,7 @@ impl<'a> From<(&'a ColumnType, &'a ColumnFlags)> for MySQLTypeSystem { ColumnType::MYSQL_TYPE_LONG_BLOB => LongBlob(null_ok), ColumnType::MYSQL_TYPE_JSON => Json(null_ok), ColumnType::MYSQL_TYPE_VARCHAR => VarChar(null_ok), + ColumnType::MYSQL_TYPE_NULL => VarChar(null_ok), _ => unimplemented!("{}", format!("{:?}", ty)), } }