Fix type info access in Any database driver

sqlx-core/src/any/error.rs

@@ -0,0 +1,16 @@
+use std::any::type_name;
+
+use crate::any::type_info::AnyTypeInfo;
+use crate::any::Any;
+use crate::error::BoxDynError;
+use crate::type_info::TypeInfo;
+use crate::types::Type;
+
+pub(super) fn mismatched_types<T: Type<Any>>(ty: &AnyTypeInfo) -> BoxDynError {
+    format!(
+        "mismatched types; Rust type `{}` is not compatible with SQL type `{}`",
+        type_name::<T>(),
+        ty.name()
+    )
+    .into()
+}

sqlx-core/src/any/mod.rs

@@ -15,6 +15,7 @@ mod arguments;
 pub(crate) mod column;
 mod connection;
 mod database;
+mod error;
 mod kind;
 mod options;
 mod query_result;

sqlx-core/src/any/row.rs

@@ -1,8 +1,13 @@
+use crate::any::error::mismatched_types;
 use crate::any::{Any, AnyColumn, AnyColumnIndex};
 use crate::column::ColumnIndex;
 use crate::database::HasValueRef;
+use crate::decode::Decode;
 use crate::error::Error;
 use crate::row::Row;
+use crate::type_info::TypeInfo;
+use crate::types::Type;
+use crate::value::ValueRef;
 
 #[cfg(feature = "postgres")]
 use crate::postgres::PgRow;
@@ -67,6 +72,25 @@ impl Row for AnyRow {
             AnyRowKind::Mssql(row) => row.try_get_raw(index).map(Into::into),
         }
     }
+
+    fn try_get<'r, T, I>(&'r self, index: I) -> Result<T, Error>
+    where
+        I: ColumnIndex<Self>,
+        T: Decode<'r, Self::Database> + Type<Self::Database>,
+    {
+        let value = self.try_get_raw(&index)?;
+        let ty = value.type_info();
+
+        if !value.is_null() && !ty.is_null() && !T::compatible(&ty) {
+            Err(mismatched_types::<T>(&ty))
+        } else {
+            T::decode(value)
+        }
+        .map_err(|source| Error::ColumnDecode {
+            index: format!("{:?}", index),
+            source,
+        })
+    }
 }
 
 impl<'i> ColumnIndex<AnyRow> for &'i str

sqlx-core/src/any/value.rs

@@ -1,7 +1,13 @@
+use std::borrow::Cow;
+
+use crate::any::error::mismatched_types;
 use crate::any::{Any, AnyTypeInfo};
 use crate::database::HasValueRef;
+use crate::decode::Decode;
+use crate::error::Error;
+use crate::type_info::TypeInfo;
+use crate::types::Type;
 use crate::value::{Value, ValueRef};
-use std::borrow::Cow;
 
 #[cfg(feature = "postgres")]
 use crate::postgres::{PgValue, PgValueRef};
@@ -91,6 +97,21 @@ impl Value for AnyValue {
             AnyValueKind::Mssql(value) => value.is_null(),
         }
     }
+
+    fn try_decode<'r, T>(&'r self) -> Result<T, Error>
+    where
+        T: Decode<'r, Self::Database> + Type<Self::Database>,
+    {
+        if !self.is_null() {
+            let ty = self.type_info();
+
+            if !ty.is_null() && !T::compatible(&ty) {
+                return Err(Error::Decode(mismatched_types::<T>(&ty)));
+            }
+        }
+
+        self.try_decode_unchecked()
+    }
 }
 
 impl<'r> ValueRef<'r> for AnyValueRef<'r> {