pgrx::datum

Struct Array

Source
pub struct Array<'mcx, T> { /* private fields */ }
Expand description

An array of some type (eg. TEXT[], int[])

While conceptually similar to a Vec<T>, arrays are lazy.

Using a Vec<T> here means each element of the passed array will be eagerly fetched and converted into a Rust type:

use pgrx::prelude::*;

#[pg_extern]
fn with_vec(elems: Vec<String>) {
    // Elements all already converted.
    for elem in elems {
        todo!()
    }
}

Using an array, elements are only fetched and converted into a Rust type on demand:

use pgrx::prelude::*;

#[pg_extern]
fn with_vec(elems: Array<String>) {
    // Elements converted one by one
    for maybe_elem in elems {
        let elem = maybe_elem.unwrap();
        todo!()
    }
}

Implementations§

Source§

impl<'mcx, T: UnboxDatum> Array<'mcx, T>

Source

pub fn iter(&self) -> ArrayIterator<'_, T>

Return an iterator of Option<T>.

Source

pub fn iter_deny_null(&self) -> ArrayTypedIterator<'_, T>

Return an iterator over the Array’s elements.

§Panics

This function will panic when called if the array contains any SQL NULL values.

Source

pub fn get<'arr>(&'arr self, index: usize) -> Option<Option<T::As<'arr>>>

Source§

impl<T> Array<'_, T>

Source

pub fn into_array_type(self) -> *const ArrayType

Rips out the underlying pg_sys::ArrayType pointer. Note that Array may have caused Postgres to allocate to unbox the datum, and this can hypothetically cause a memory leak if so.

Source

pub fn contains_nulls(&self) -> bool

Returns true if this Array contains one or more SQL “NULL” values

Source

pub fn len(&self) -> usize

Source

pub fn is_empty(&self) -> bool

Source§

impl Array<'_, f64>

Source

pub fn as_slice(&self) -> Result<&[f64], ArraySliceError>

Returns a slice of f64s which comprise this Array.

§Errors

Returns a ArraySliceError::ContainsNulls error if this Array contains one or more SQL “NULL” values. In this case, you’d likely want to fallback to using Array::iter().

Source§

impl Array<'_, f32>

Source

pub fn as_slice(&self) -> Result<&[f32], ArraySliceError>

Returns a slice of f32s which comprise this Array.

§Errors

Returns a ArraySliceError::ContainsNulls error if this Array contains one or more SQL “NULL” values. In this case, you’d likely want to fallback to using Array::iter().

Source§

impl Array<'_, i64>

Source

pub fn as_slice(&self) -> Result<&[i64], ArraySliceError>

Returns a slice of i64s which comprise this Array.

§Errors

Returns a ArraySliceError::ContainsNulls error if this Array contains one or more SQL “NULL” values. In this case, you’d likely want to fallback to using Array::iter().

Source§

impl Array<'_, i32>

Source

pub fn as_slice(&self) -> Result<&[i32], ArraySliceError>

Returns a slice of i32s which comprise this Array.

§Errors

Returns a ArraySliceError::ContainsNulls error if this Array contains one or more SQL “NULL” values. In this case, you’d likely want to fallback to using Array::iter().

Source§

impl Array<'_, i16>

Source

pub fn as_slice(&self) -> Result<&[i16], ArraySliceError>

Returns a slice of i16s which comprise this Array.

§Errors

Returns a ArraySliceError::ContainsNulls error if this Array contains one or more SQL “NULL” values. In this case, you’d likely want to fallback to using Array::iter().

Source§

impl Array<'_, i8>

Source

pub fn as_slice(&self) -> Result<&[i8], ArraySliceError>

Returns a slice of i8s which comprise this Array.

§Errors

Returns a ArraySliceError::ContainsNulls error if this Array contains one or more SQL “NULL” values. In this case, you’d likely want to fallback to using Array::iter().

Trait Implementations§

Source§

impl<'fcx, T> ArgAbi<'fcx> for Array<'fcx, T>
where T: ArgAbi<'fcx> + UnboxDatum,

Source§

unsafe fn unbox_arg_unchecked(arg: Arg<'_, 'fcx>) -> Self

Unbox an argument with a matching type. Read more
Source§

unsafe fn unbox_nullable_arg(arg: Arg<'_, 'fcx>) -> Nullable<Self>

Unbox a nullable arg Read more
Source§

fn is_virtual_arg() -> bool

“Is this a virtual arg?”
Source§

impl<T: UnboxDatum> Debug for Array<'_, T>
where for<'arr> <T as UnboxDatum>::As<'arr>: Debug,

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl<'a, T: UnboxDatum> FromDatum for Array<'a, T>

Source§

unsafe fn from_polymorphic_datum( datum: Datum, is_null: bool, _typoid: Oid, ) -> Option<Array<'a, T>>

Like from_datum for instantiating polymorphic types which require preserving the dynamic type metadata. Read more
Source§

unsafe fn from_datum_in_memory_context( memory_context: PgMemoryContexts, datum: Datum, is_null: bool, typoid: Oid, ) -> Option<Self>
where Self: Sized,

Default implementation switched to the specified memory context and then simply calls FromDatum::from_datum(...) from within that context. Read more
Source§

const GET_TYPOID: bool = false

Should a type OID be fetched when calling from_datum?
Source§

unsafe fn from_datum(datum: Datum, is_null: bool) -> Option<Self>

Safety Read more
Source§

unsafe fn try_from_datum( datum: Datum, is_null: bool, type_oid: Oid, ) -> Result<Option<Self>, TryFromDatumError>
where Self: IntoDatum,

try_from_datum is a convenience wrapper around FromDatum::from_datum that returns a a Result around an Option, as a Datum can be null. It’s intended to be used in situations where the caller needs to know whether the type conversion succeeded or failed. Read more
Source§

unsafe fn try_from_datum_in_memory_context( memory_context: PgMemoryContexts, datum: Datum, is_null: bool, type_oid: Oid, ) -> Result<Option<Self>, TryFromDatumError>
where Self: IntoDatum,

A version of try_from_datum that switches to the given context to convert from Datum
Source§

impl<T: IntoDatum> IntoDatum for Array<'_, T>

Source§

fn into_datum(self) -> Option<Datum>

Source§

fn type_oid() -> Oid

Source§

fn composite_type_oid(&self) -> Option<Oid>

Source§

fn is_compatible_with(other: Oid) -> bool

Is a Datum of this type compatible with another Postgres type? Read more
Source§

impl<'mcx, T> IntoIterator for Array<'mcx, T>
where for<'arr> T: UnboxDatum<As<'arr> = T> + 'static,

Source§

type Item = Option<<T as UnboxDatum>::As<'mcx>>

The type of the elements being iterated over.
Source§

type IntoIter = ArrayIntoIterator<'mcx, T>

Which kind of iterator are we turning this into?
Source§

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value. Read more
Source§

impl<'mcx, T> IntoNullableIterator<<T as UnboxDatum>::As<'mcx>> for &'mcx Array<'mcx, T>
where T: UnboxDatum,

Source§

impl<'mcx, T: UnboxDatum> NullableContainer<'mcx, usize, <T as UnboxDatum>::As<'mcx>> for Array<'mcx, T>

Source§

type Layout = MaybeStrictNulls<BitSliceNulls<'mcx>>

Source§

fn get_layout(&'mcx self) -> &'mcx Self::Layout

Source§

unsafe fn get_raw(&'mcx self, idx: usize) -> <T as UnboxDatum>::As<'mcx>

For internal use - implement this over underlying data types Used to implement NullableIter. Read more
Source§

fn len(&'mcx self) -> usize

Total array length - doesn’t represent the length of the backing array (as in, the thing accessed by get_raw) but instead represents the length of the array including skipped nulls.
Source§

impl<'mcx, T: UnboxDatum> Serialize for Array<'mcx, T>
where for<'arr> <T as UnboxDatum>::As<'arr>: Serialize,

Source§

fn serialize<S>( &self, serializer: S, ) -> Result<<S as Serializer>::Ok, <S as Serializer>::Error>
where S: Serializer,

Serialize this value into the given Serde serializer. Read more
Source§

impl<T> SqlTranslatable for Array<'_, T>
where T: SqlTranslatable,

Source§

impl<T: FromDatum + UnboxDatum> UnboxDatum for Array<'_, T>

Source§

type As<'src> = Array<'src, T> where Self: 'src

Self with the lifetime 'src Read more
Source§

unsafe fn unbox<'src>(d: Datum<'src>) -> Array<'src, T>
where Self: 'src,

Convert from Datum<'src> to T::As<'src> Read more

Auto Trait Implementations§

§

impl<'mcx, T> Freeze for Array<'mcx, T>

§

impl<'mcx, T> !RefUnwindSafe for Array<'mcx, T>

§

impl<'mcx, T> !Send for Array<'mcx, T>

§

impl<'mcx, T> !Sync for Array<'mcx, T>

§

impl<'mcx, T> Unpin for Array<'mcx, T>

§

impl<'mcx, T> !UnwindSafe for Array<'mcx, T>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> Conv for T

Source§

fn conv<T>(self) -> T
where Self: Into<T>,

Converts self into T using Into<T>. Read more
Source§

impl<T> FmtForward for T

Source§

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

Causes self to use its Binary implementation when Debug-formatted.
Source§

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

Causes self to use its Display implementation when Debug-formatted.
Source§

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

Causes self to use its LowerExp implementation when Debug-formatted.
Source§

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

Causes self to use its LowerHex implementation when Debug-formatted.
Source§

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

Causes self to use its Octal implementation when Debug-formatted.
Source§

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

Causes self to use its Pointer implementation when Debug-formatted.
Source§

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

Causes self to use its UpperExp implementation when Debug-formatted.
Source§

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

Causes self to use its UpperHex implementation when Debug-formatted.
Source§

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

Formats each item in a sequence. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Pipe for T
where T: ?Sized,

Source§

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

Pipes by value. This is generally the method you want to use. Read more
Source§

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

Borrows self and passes that borrow into the pipe function. Read more
Source§

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

Mutably borrows self and passes that borrow into the pipe function. Read more
Source§

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

Borrows self, then passes self.borrow() into the pipe function. Read more
Source§

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more
Source§

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

Borrows self, then passes self.as_ref() into the pipe function.
Source§

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.as_mut() into the pipe function.
Source§

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

Borrows self, then passes self.deref() into the pipe function.
Source§

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.deref_mut() into the pipe function.
Source§

impl<T> Tap for T

Source§

fn tap(self, func: impl FnOnce(&Self)) -> Self

Immutable access to a value. Read more
Source§

fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self

Mutable access to a value. Read more
Source§

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Immutable access to the Borrow<B> of a value. Read more
Source§

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Mutable access to the BorrowMut<B> of a value. Read more
Source§

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Immutable access to the AsRef<R> view of a value. Read more
Source§

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Mutable access to the AsMut<R> view of a value. Read more
Source§

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Immutable access to the Deref::Target of a value. Read more
Source§

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Mutable access to the Deref::Target of a value. Read more
Source§

fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self

Calls .tap() only in debug builds, and is erased in release builds.
Source§

fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self

Calls .tap_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Calls .tap_borrow() only in debug builds, and is erased in release builds.
Source§

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Calls .tap_borrow_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Calls .tap_ref() only in debug builds, and is erased in release builds.
Source§

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Calls .tap_ref_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Calls .tap_deref() only in debug builds, and is erased in release builds.
Source§

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Calls .tap_deref_mut() only in debug builds, and is erased in release builds.
Source§

impl<T> TryConv for T

Source§

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

Attempts to convert self into T using TryInto<T>. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithTypeIds for T
where T: ?Sized,

Source§

const ITEM_ID: Lazy<TypeId> = const ITEM_ID: Lazy<TypeId> = Lazy::new(|| nonstatic_typeid::<T>());

Source§

const OPTION_ID: Lazy<Option<TypeId>> = const OPTION_ID: Lazy<Option<TypeId>> = Lazy::new(|| None);

Source§

const VEC_ID: Lazy<Option<TypeId>> = const VEC_ID: Lazy<Option<TypeId>> = Lazy::new(|| None);

Source§

const VEC_OPTION_ID: Lazy<Option<TypeId>> = const VEC_OPTION_ID: Lazy<Option<TypeId>> = Lazy::new(|| None);

Source§

const OPTION_VEC_ID: Lazy<Option<TypeId>> = const OPTION_VEC_ID: Lazy<Option<TypeId>> = Lazy::new(|| None);

Source§

const OPTION_VEC_OPTION_ID: Lazy<Option<TypeId>> = const OPTION_VEC_OPTION_ID: Lazy<Option<TypeId>> = Lazy::new(|| None);

Source§

const ARRAY_ID: Lazy<Option<TypeId>> = const ARRAY_ID: Lazy<Option<TypeId>> = Lazy::new(|| None);

Source§

const OPTION_ARRAY_ID: Lazy<Option<TypeId>> = const OPTION_ARRAY_ID: Lazy<Option<TypeId>> = Lazy::new(|| None);

Source§

const VARIADICARRAY_ID: Lazy<Option<TypeId>> = const VARIADICARRAY_ID: Lazy<Option<TypeId>> = Lazy::new(|| None);

Source§

const OPTION_VARIADICARRAY_ID: Lazy<Option<TypeId>> = const OPTION_VARIADICARRAY_ID: Lazy<Option<TypeId>> = Lazy::new(|| None);

Source§

const VARLENA_ID: Lazy<Option<TypeId>> = const VARLENA_ID: Lazy<Option<TypeId>> = Lazy::new(|| None);

Source§

const OPTION_VARLENA_ID: Lazy<Option<TypeId>> = const OPTION_VARLENA_ID: Lazy<Option<TypeId>> = Lazy::new(|| None);

Source§

fn register_with_refs(map: &mut HashSet<RustSqlMapping>, single_sql: String)

Source§

fn register_sized_with_refs( _map: &mut HashSet<RustSqlMapping>, _single_sql: String, )

Source§

fn register_sized(_map: &mut HashSet<RustSqlMapping>, _single_sql: String)

Source§

fn register_varlena_with_refs( _map: &mut HashSet<RustSqlMapping>, _single_sql: String, )

Source§

fn register_varlena(_map: &mut HashSet<RustSqlMapping>, _single_sql: String)

Source§

fn register_array_with_refs( _map: &mut HashSet<RustSqlMapping>, _single_sql: String, )

Source§

fn register_array(_map: &mut HashSet<RustSqlMapping>, _single_sql: String)

Source§

fn register(set: &mut HashSet<RustSqlMapping>, single_sql: String)