Struct pgx::datum::PgVarlena

source ·
pub struct PgVarlena<T>where
    T: Copy + Sized,{ /* private fields */ }
Expand description

Wraps a Postgres varlena *, presenting it as if it’s a Rust type of a fixed size.

The wrapped varlena * is behind a Rust alloc::borrow:Cow which ensures that in the common-use case of creating a PgVarlena from a Postgres-provided Datum, it’s not possible to scribble on that Postgres-allocated memory.

Generally, PgVarlena is meant to be used in conjunction with pgx’s PostgresType derive macro to provide transparent mapping of fixed-size Rust types as Postgres datums.

Example

use std::str::FromStr;

use pgx::prelude::*;

#[derive(Copy, Clone, PostgresType)]
#[pgvarlena_inoutfuncs]
struct MyType {
   a: f32,
   b: f32,
   c: i64
}

impl PgVarlenaInOutFuncs for MyType {
    fn input(input: &core::ffi::CStr) -> PgVarlena<Self> {
        let mut iter = input.to_str().unwrap().split(',');
        let (a, b, c) = (iter.next(), iter.next(), iter.next());

        let mut result = PgVarlena::<MyType>::new();
        result.a = f32::from_str(a.unwrap()).expect("a is not a valid f32");
        result.b = f32::from_str(b.unwrap()).expect("b is not a valid f32");
        result.c = i64::from_str(c.unwrap()).expect("c is not a valid i64");

        result
    }

    fn output(&self, buffer: &mut pgx::StringInfo) {
        buffer.push_str(&format!("{},{},{}", self.a, self.b, self.c));
    }
}

#[pg_extern]
fn do_a_thing(mut input: PgVarlena<MyType>) -> PgVarlena<MyType> {
    input.c += 99;  // performs a copy-on-write
    input
}

Implementations§

source§

impl<T> PgVarlena<T>where T: Copy + Sized,

source

pub fn new() -> Self

Create a new PgVarlena representing a Rust type. The backing varlena is allocated by Postgres and initially zero’d (using pg_sys::palloc0). Unless .into_pg() is called, the Postgres-allocated memory will follow Rust’s drop semantics.

Example
use pgx::prelude::*;

#[derive(Copy, Clone)]
struct MyType {
   a: f32,
   b: f32,
   c: i64
}

let mut v = PgVarlena::<MyType>::new();
v.a = 42.0;
v.b = 0.424242;
v.c = 42;
source

pub unsafe fn from_datum(datum: Datum) -> Self

Construct a PgVarlena from a known-to-be-non-null pg_sys::Datum. As FromDatum for PgVarlena<T> where T: Copy + Sized is already implemented, it is unlikely that this function will need to be called directly.

The provided datum is automatically detoasted and the returned PgVarlena will either be considered borrowed or owned based on if detoasting actually needed to allocate memory. If it didn’t, then we’re borrowed, otherwise we’re owned.

Safety

This function is considered unsafe as it cannot guarantee the provided pg_sys::Datum is a valid *mut pg_sys::varlena.

source

pub fn into_pg(self) -> *mut varlena

Use when you need to pass the backing *mut pg_sys::varlena to a Postgres function.

This method is also used by the IntoDatum for PgVarlena<T> where T: Copy + Sized implementation.

Trait Implementations§

source§

impl<T> AsMut<T> for PgVarlena<T>where T: Copy + Sized,

Does a copy-on-write if the backing varlena pointer is borrowed

source§

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

Converts this type into a mutable reference of the (usually inferred) input type.
source§

impl<T> AsRef<T> for PgVarlena<T>where T: Copy + Sized,

source§

fn as_ref(&self) -> &T

Converts this type into a shared reference of the (usually inferred) input type.
source§

impl<T> Default for PgVarlena<T>where T: Default + Copy,

source§

fn default() -> Self

Returns the “default value” for a type. Read more
source§

impl<T> Deref for PgVarlena<T>where T: Copy + Sized,

§

type Target = T

The resulting type after dereferencing.
source§

fn deref(&self) -> &Self::Target

Dereferences the value.
source§

impl<T> DerefMut for PgVarlena<T>where T: Copy + Sized,

source§

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.
source§

impl<T> Drop for PgVarlena<T>where T: Copy + Sized,

pg_sys::pfree a PgVarlena if we allocated it, instead of Postgres

source§

fn drop(&mut self)

Executes the destructor for this type. Read more
source§

impl<T> From<PgVarlena<T>> for Option<Datum>where T: Copy + Sized,

source§

fn from(val: PgVarlena<T>) -> Self

Converts to this type from the input type.
source§

impl<T> FromDatum for PgVarlena<T>where T: Copy + Sized,

source§

unsafe fn from_polymorphic_datum( datum: Datum, is_null: bool, _typoid: Oid ) -> Option<Self>

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>

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>where Self: Sized,

Safety Read more
source§

unsafe fn try_from_datum( datum: Datum, is_null: bool, type_oid: Oid ) -> Result<Option<Self>, TryFromDatumError>where Self: Sized + 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: Sized + IntoDatum,

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

impl<T> IntoDatum for PgVarlena<T>where T: Copy + Sized,

source§

fn into_datum(self) -> Option<Datum>

source§

fn type_oid() -> Oid

source§

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

source§

fn array_type_oid() -> Oid

source§

fn is_compatible_with(other: Oid) -> bool

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

impl<T> SqlTranslatable for PgVarlena<T>where T: SqlTranslatable + Copy,

Auto Trait Implementations§

§

impl<T> RefUnwindSafe for PgVarlena<T>where T: RefUnwindSafe,

§

impl<T> !Send for PgVarlena<T>

§

impl<T> !Sync for PgVarlena<T>

§

impl<T> Unpin for PgVarlena<T>where T: Unpin,

§

impl<T> UnwindSafe for PgVarlena<T>where T: UnwindSafe,

Blanket Implementations§

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<A, T> AsBits<T> for Awhere A: AsRef<[T]>, T: BitStore,

source§

fn as_bits<O>(&self) -> &BitSlice<T, O> where O: BitOrder,

Views self as an immutable bit-slice region with the O ordering.
source§

fn try_as_bits<O>(&self) -> Result<&BitSlice<T, O>, BitSpanError<T>>where O: BitOrder,

Attempts to view self as an immutable bit-slice region with the O ordering. Read more
source§

impl<A, T> AsMutBits<T> for Awhere A: AsMut<[T]>, T: BitStore,

source§

fn as_mut_bits<O>(&mut self) -> &mut BitSlice<T, O> where O: BitOrder,

Views self as a mutable bit-slice region with the O ordering.
source§

fn try_as_mut_bits<O>(&mut self) -> Result<&mut BitSlice<T, O>, BitSpanError<T>>where O: BitOrder,

Attempts to view self as a mutable bit-slice region with the O ordering. Read more
source§

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

const: unstable · source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

const: unstable · source§

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

Mutably borrows from an owned value. Read more
§

impl<T> Conv for T

§

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

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

impl<T> FmtForward for T

§

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

const: unstable · source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

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

const: unstable · 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.

§

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

§

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

impl<T> Tap for T

§

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

Immutable access to a value. Read more
§

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

Mutable access to a value. Read more
§

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

impl<T> TryConv for T

§

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 Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
const: unstable · source§

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

Performs the conversion.
source§

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

§

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

The type returned in the event of a conversion error.
const: unstable · source§

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

Performs the conversion.
source§

impl<T> WithTypeIds for Twhere T: 'static + ?Sized,

source§

const ITEM_ID: Lazy<TypeId, fn() -> TypeId> =

source§

const OPTION_ID: Lazy<Option<TypeId>, fn() -> Option<TypeId>> =

source§

const VEC_ID: Lazy<Option<TypeId>, fn() -> Option<TypeId>> =

source§

const VEC_OPTION_ID: Lazy<Option<TypeId>, fn() -> Option<TypeId>> =

source§

const OPTION_VEC_ID: Lazy<Option<TypeId>, fn() -> Option<TypeId>> =

source§

const OPTION_VEC_OPTION_ID: Lazy<Option<TypeId>, fn() -> Option<TypeId>> =

source§

const ARRAY_ID: Lazy<Option<TypeId>, fn() -> Option<TypeId>> =

source§

const OPTION_ARRAY_ID: Lazy<Option<TypeId>, fn() -> Option<TypeId>> =

source§

const VARIADICARRAY_ID: Lazy<Option<TypeId>, fn() -> Option<TypeId>> =

source§

const OPTION_VARIADICARRAY_ID: Lazy<Option<TypeId>, fn() -> Option<TypeId>> =

source§

const VARLENA_ID: Lazy<Option<TypeId>, fn() -> Option<TypeId>> =

source§

const OPTION_VARLENA_ID: Lazy<Option<TypeId>, fn() -> Option<TypeId>> =

source§

fn register_with_refs(map: &mut HashSet<RustSqlMapping>, single_sql: String)where Self: 'static,

source§

fn register_sized_with_refs( _map: &mut HashSet<RustSqlMapping>, _single_sql: String )where Self: 'static,

source§

fn register_sized(_map: &mut HashSet<RustSqlMapping>, _single_sql: String)where Self: 'static,

source§

fn register_varlena_with_refs( _map: &mut HashSet<RustSqlMapping>, _single_sql: String )where Self: 'static,

source§

fn register_varlena(_map: &mut HashSet<RustSqlMapping>, _single_sql: String)where Self: 'static,

source§

fn register_array_with_refs( _map: &mut HashSet<RustSqlMapping>, _single_sql: String )where Self: 'static,

source§

fn register_array(_map: &mut HashSet<RustSqlMapping>, _single_sql: String)where Self: 'static,

source§

fn register(set: &mut HashSet<RustSqlMapping>, single_sql: String)where Self: 'static,