Implement NamedRow changes for mysql

diesel-rs · Jun 10, 2020 · c8bfe3b · c8bfe3b
1 parent 43d9d8a
commit c8bfe3b
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/diesel/src/mysql/connection/stmt/iterator.rs b/diesel/src/mysql/connection/stmt/iterator.rs
@@ -119,6 +119,7 @@ impl<'a> NamedStatementIterator<'a> {
             Ok(Some(())) => Some(Ok(NamedMysqlRow {
                 binds: &self.output_binds,
                 column_indices: self.metadata.column_indices(),
+                metadata: &self.metadata,
             })),
             Ok(None) => None,
             Err(e) => Some(Err(e)),
@@ -129,6 +130,7 @@ impl<'a> NamedStatementIterator<'a> {
 pub struct NamedMysqlRow<'a> {
     binds: &'a Binds,
     column_indices: &'a HashMap<&'a str, usize>,
+    metadata: &'a StatementMetadata,
 }
 
 impl<'a> NamedRow<Mysql> for NamedMysqlRow<'a> {
@@ -141,6 +143,11 @@ impl<'a> NamedRow<Mysql> for NamedMysqlRow<'a> {
     }
 
     fn field_names(&self) -> Vec<&str> {
-        todo!()
+        self.metadata
+            .fields()
+            .iter()
+            .filter_map(|f| f.field_name())
+            .collect()
     }
 }
+