Struct MsSQLSourceParser 

pub struct MsSQLSourceParser { /* private fields */ }

Trait Implementations

impl<'a> PartitionParser<'a> for MsSQLSourceParser

type TypeSystem = MsSQLTypeSystem

The type system of the parent Source.

type Error = MsSQLSourceError

The error type of the parent Source.

fn fetch_next(&mut self) -> Result<(usize, bool), MsSQLSourceError>

Fetch next batch of rows from database, return (number of rows fetched to local, whether all rows are fechted from database). There might be rows that are not consumed yet when calling the next fetch_next. The function might be called even after the last batch is fetched.

fn parse<'r, T>(&'r mut self) -> Result<T, <Self as PartitionParser<'a>>::Error>

where T: TypeAssoc<Self::TypeSystem>, Self: Produce<'r, T, Error = <Self as PartitionParser<'a>>::Error>,

Read a value T by calling Produce<T>::produce. Usually this function does not need to be implemented.

impl<'r> Produce<'r, &'r [u8]> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<&'r [u8], MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, &'r str> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<&'r str, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, DateTime<Utc>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<DateTime<Utc>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Decimal> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Decimal, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, FloatN> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<FloatN, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, IntN> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<IntN, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, NaiveDate> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<NaiveDate, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, NaiveDateTime> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<NaiveDateTime, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, NaiveTime> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<NaiveTime, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<&'r [u8]>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<&'r [u8]>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<&'r str>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<&'r str>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<DateTime<Utc>>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<DateTime<Utc>>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<Decimal>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<Decimal>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<FloatN>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<FloatN>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<IntN>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<IntN>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<NaiveDate>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<NaiveDate>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<NaiveDateTime>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<NaiveDateTime>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<NaiveTime>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<NaiveTime>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<Uuid>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<Uuid>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<bool>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<bool>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<f32>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<f32>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<f64>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<f64>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<i16>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<i16>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<i32>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<i32>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<i64>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<i64>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Option<u8>> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Option<u8>, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, Uuid> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<Uuid, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, bool> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<bool, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, f32> for MsSQLSourceParser

f32 needs a hand-written impl (rather than the generic macro) to accept TdsCell::F64 as well: a genuinely non-nullable smallmoney column (fixed Money4 wire type) maps to the SmallMoney/f32 destination, but its value is decoded and stored here as a full-precision TdsCell::F64 (see column_value_to_cell), so it must be narrowed on the way out.

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<f32, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, f64> for MsSQLSourceParser

f64 needs a hand-written impl (rather than the generic macro) because it also has to accept TdsCell::F32: a nullable smallmoney column decodes its per-row wire value as ColumnValues::SmallMoney (4 bytes, stored here as TdsCell::F32), yet the typesystem maps it to the same Money/f64 destination as regular money - matching Tiberius, which always reports its nullable MONEYN wire type as F64 regardless of the per-row byte length (see typesystem.rs’s TdsDataType::MoneyN arm).

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<f64, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, i16> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<i16, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, i32> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<i32, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, i64> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<i64, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.

impl<'r> Produce<'r, u8> for MsSQLSourceParser

type Error = MsSQLSourceError

The error returned when the next value cannot be produced as T.

fn produce(&'r mut self) -> Result<u8, MsSQLSourceError>

Produce the next value from the buffer as T and advance past it.