itsscb/sqlx
1
0
Fork 0
mirror of https://github.com/launchbadge/sqlx.git synced 2025-12-29 21:00:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(mysql): expand MySqlRow to handle the binary format from prepared queries

Browse Source
This commit is contained in:
Ryan Leckey 2021-02-18 21:43:36 -08:00
parent f348a8f2ac
commit 9d448c8d8e
No known key found for this signature in database
GPG Key ID: F8AA68C235AB08C9
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
sqlx-mysql/src/row.rs
View File

@ -5,12 +5,15 @@ use crate::{protocol, MySql, MySqlColumn, MySqlRawValue, MySqlRawValueFormat};
#[allow(clippy::module_name_repetitions)]
pub struct MySqlRow {
format: MySqlRawValueFormat,
columns: Vec<MySqlColumn>,
values: Vec<Option<Bytes>>,
}
impl MySqlRow {
pub(crate) fn new(row: protocol::Row) -> Self {
Self { values: row.values }
// FIXME: Use Arc or some other way of sharing columns between rows
pub(crate) fn new(row: protocol::Row, columns: &Vec<MySqlColumn>) -> Self {
Self { values: row.values, columns: columns.clone(), format: row.format }
}
#[must_use]
@ -32,14 +35,14 @@ impl MySqlRow {
// noinspection RsNeedlessLifetimes
pub fn try_get_raw<'r>(&'r self, index: usize) -> sqlx_core::Result<MySqlRawValue<'r>> {
let format = MySqlRawValueFormat::Text;
let value = self
.values
.get(index)
.ok_or_else(|| Error::ColumnIndexOutOfBounds { len: self.len(), index })?;
Ok(MySqlRawValue::new(value, format))
let column = &self.columns[index];
Ok(MySqlRawValue::new(value, self.format, column.type_info()))
}
}