port diesel cli

Author: Ten0

diesel_cli/src/infer_schema_internals/data_structures.rs

@@ -1,6 +1,6 @@
 #[cfg(feature = "uses_information_schema")]
 use diesel::backend::Backend;
-use diesel::deserialize::{FromStaticSqlRow, Queryable};
+use diesel::deserialize::{self, FromStaticSqlRow, Queryable};
 #[cfg(feature = "sqlite")]
 use diesel::sqlite::Sqlite;
 
@@ -80,8 +80,8 @@ where
 {
     type Row = (String, String, String);
 
-    fn build(row: Self::Row) -> Self {
-        ColumnInformation::new(row.0, row.1, row.2 == "YES")
+    fn build(row: Self::Row) -> deserialize::Result<Self> {
+        Ok(ColumnInformation::new(row.0, row.1, row.2 == "YES"))
     }
 }
 
@@ -92,8 +92,8 @@ where
 {
     type Row = (i32, String, String, bool, Option<String>, bool);
 
-    fn build(row: Self::Row) -> Self {
-        ColumnInformation::new(row.1, row.2, !row.3)
+    fn build(row: Self::Row) -> deserialize::Result<Self> {
+        Ok(ColumnInformation::new(row.1, row.2, !row.3))
     }
 }
 

diesel_cli/src/infer_schema_internals/table_data.rs

@@ -1,5 +1,5 @@
 use diesel::backend::Backend;
-use diesel::deserialize::{FromStaticSqlRow, Queryable};
+use diesel::deserialize::{self, FromStaticSqlRow, Queryable};
 use std::fmt;
 use std::str::FromStr;
 
@@ -60,8 +60,8 @@ where
 {
     type Row = (String, String);
 
-    fn build((name, schema): Self::Row) -> Self {
-        TableName::new(name, schema)
+    fn build((name, schema): Self::Row) -> deserialize::Result<Self> {
+        Ok(TableName::new(name, schema))
     }
 }