Merge pull request #825 from quixoten/dc/bq-datetime-err

try an additional format to parse bq timestamps

Author: wangxiaoying

connectorx/src/sources/bigquery/mod.rs

@@ -768,6 +768,7 @@ impl<'r, 'a> Produce<'r, NaiveDateTime> for BigQuerySourceParser {
             .as_str()
             .ok_or_else(|| anyhow!("cannot get str from json value"))?;
         NaiveDateTime::parse_from_str(s, "%Y-%m-%dT%H:%M:%S")
+            .or_else(|_| NaiveDateTime::parse_from_str(s, "%Y-%m-%dT%H:%M:%S%.f"))
             .map_err(|_| ConnectorXError::cannot_produce::<NaiveDateTime>(Some(s.into())))?
     }
 }
@@ -838,9 +839,11 @@ impl<'r, 'a> Produce<'r, Option<NaiveDateTime>> for BigQuerySourceParser {
                     .as_str()
                     .ok_or_else(|| anyhow!("cannot get str from json value"))?;
                 Some(
-                    NaiveDateTime::parse_from_str(s, "%Y-%m-%dT%H:%M:%S").map_err(|_| {
-                        ConnectorXError::cannot_produce::<NaiveDateTime>(Some(s.into()))
-                    })?,
+                    NaiveDateTime::parse_from_str(s, "%Y-%m-%dT%H:%M:%S")
+                        .or_else(|_| NaiveDateTime::parse_from_str(s, "%Y-%m-%dT%H:%M:%S%.f"))
+                        .map_err(|_| {
+                            ConnectorXError::cannot_produce::<NaiveDateTime>(Some(s.into()))
+                        })?,
                 )
             }
         }