diff --git a/connectorx/src/sources/mysql/typesystem.rs b/connectorx/src/sources/mysql/typesystem.rs index 105b7271ca..1f1a3a69a9 100644 --- a/connectorx/src/sources/mysql/typesystem.rs +++ b/connectorx/src/sources/mysql/typesystem.rs @@ -31,6 +31,7 @@ pub enum MySQLTypeSystem { MediumBlob(bool), LongBlob(bool), Json(bool), + Bit(bool) } impl_typesystem! { @@ -51,7 +52,7 @@ impl_typesystem! { { Time => NaiveTime } { Decimal => Decimal } { Char | VarChar | Enum => String } - { TinyBlob | Blob | MediumBlob | LongBlob => Vec} + { TinyBlob | Blob | MediumBlob | LongBlob | Bit => Vec} { Json => Value } } } @@ -116,6 +117,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_BIT => Bit(null_ok), _ => unimplemented!("{}", format!("{:?}", ty)), } } diff --git a/connectorx/src/transports/mysql_arrow.rs b/connectorx/src/transports/mysql_arrow.rs index 1885c05dd1..0311826e66 100644 --- a/connectorx/src/transports/mysql_arrow.rs +++ b/connectorx/src/transports/mysql_arrow.rs @@ -62,6 +62,7 @@ impl_transport!( { MediumBlob[Vec] => LargeBinary[Vec] | conversion none } { LongBlob[Vec] => LargeBinary[Vec] | conversion none } { Json[Value] => LargeUtf8[String] | conversion option } + { Bit[Vec] => LargeBinary[Vec] | conversion none } } );