Struct PgRelation

Source
pub struct PgRelation { /* private fields */ }

Implementations§

Source§

impl PgRelation

Source

pub unsafe fn from_pg(ptr: Relation) -> Self

Wrap a Postgres-provided pg_sys::Relation.

It is assumed that Postgres will later RelationClose() the provided relation pointer. As such, it is not closed when this instance is dropped

§Safety

This method is unsafe as we cannot ensure that this relation will later be closed by Postgres

Source

pub unsafe fn from_pg_owned(ptr: Relation) -> Self

Wrap a Postgres-provided pg_sys::Relation.

The provided Relation will be closed via pg_sys::RelationClose when this instance is dropped

Source

pub unsafe fn open(oid: Oid) -> Self

Given a relation oid, use pg_sys::RelationIdGetRelation() to open the relation

If the specified relation oid was recently deleted, this function will panic.

Additionally, the relation is closed via pg_sys::RelationClose() when this instance is dropped.

§Safety

The caller should already have at least AccessShareLock on the relation ID, else there are nasty race conditions.

As such, this function is unsafe as we cannot guarantee that this requirement is true.

Source

pub unsafe fn with_lock(oid: Oid, lockmode: LOCKMODE) -> Self

relation_open - open any relation by relation OID

If lockmode is not “NoLock”, the specified kind of lock is obtained on the relation.

An error is raised if the relation does not exist.

§Safety

Using an inappropriate lockmode, such as using NoLock on a relation that has not been previously locked, may result in undefined behavior.

NB: a “relation” is anything with a pg_class entry. The caller is expected to check whether the relkind is something it can handle.

The opened relation is automatically closed via pg_sys::relation_close() when this instance is dropped

Source

pub unsafe fn open_with_name(relname: &str) -> Result<Self, &'static str>

Given a relation name, use pg_sys::to_regclass to look up its oid, and then pg_sys::RelationIdGetRelation() to open the relation.

If the specified relation name is not found, we return an Err(&str).

If the specified relation was recently deleted, this function will panic.

Additionally, the relation is closed via pg_sys::RelationClose() when this instance is dropped.

§Safety

The caller should already have at least AccessShareLock on the relation ID, else there are nasty race conditions.

As such, this function is unsafe as we cannot guarantee that this requirement is true.

Source

pub fn open_with_name_and_share_lock( relname: &str, ) -> Result<Self, &'static str>

Given a relation name, use pg_sys::to_regclass to look up its oid, and then open it with an AccessShareLock

If the specified relation name is not found, we return an Err(&str).

If the specified relation was recently deleted, this function will panic.

Additionally, the relation is closed via pg_sys::RelationClose() when this instance is dropped.

Source

pub fn name(&self) -> &str

RelationGetRelationName Returns the rel’s name.

Note that the name is only unique within the containing namespace.

Source

pub fn oid(&self) -> Oid

RelationGetRelid Returns the OID of the relation

Source

pub fn namespace_oid(&self) -> Oid

RelationGetNamespace Returns the rel’s namespace OID.

Source

pub fn namespace(&self) -> &str

What is the name of the namespace in which this relation is located?

Source

pub fn heap_relation(&self) -> Option<PgRelation>

If this PgRelation represents an index, return the PgRelation for the heap relation to which it is attached

Source

pub fn indices(&self, lockmode: LOCKMODE) -> impl Iterator<Item = PgRelation>

Return an iterator of indices, as PgRelations, attached to this relation

Source

pub fn tuple_desc(&self) -> PgTupleDesc<'_>

Returned a wrapped PgTupleDesc

The returned PgTupleDesc is tied to the lifetime of this PgRelation instance.

use pgx::{PgRelation, pg_sys};
let oid = example_pg_class_oid(42); // a valid pg_class "oid" value
let relation = unsafe { PgRelation::from_pg(pg_sys::RelationIdGetRelation(oid) ) };
let tupdesc = relation.tuple_desc();

// assert that the tuple descriptor has 12 attributes
assert_eq!(tupdesc.len(), 12);
Source

pub fn reltuples(&self) -> Option<f32>

Number of tuples in this relation (not always up-to-date)

Source

pub fn is_table(&self) -> bool

Source

pub fn is_matview(&self) -> bool

Source

pub fn is_index(&self) -> bool

Source

pub fn is_view(&self) -> bool

Source

pub fn is_sequence(&self) -> bool

Source

pub fn is_composite_type(&self) -> bool

Source

pub fn is_foreign_table(&self) -> bool

Source

pub fn is_partitioned_table(&self) -> bool

Source

pub fn is_toast_value(&self) -> bool

Source

pub fn to_owned(self) -> Self

ensures that the returned PgRelation is closed by Rust when it is dropped

Methods from Deref<Target = PgBox<RelationData>>§

Source

pub fn is_null(&self) -> bool

Are we boxing a NULL?

Source

pub fn as_ptr(&self) -> *mut T

Return the boxed pointer, so that it can be passed back into a Postgres function

Trait Implementations§

Source§

impl Clone for PgRelation

Source§

fn clone(&self) -> Self

Same as calling PgRelation::with_lock(AccessShareLock) on the underlying relation id

1.0.0 · Source§

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Deref for PgRelation

Source§

type Target = PgBox<RelationData>

The resulting type after dereferencing.
Source§

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

Dereferences the value.
Source§

impl Drop for PgRelation

Source§

fn drop(&mut self)

Executes the destructor for this type. Read more
Source§

impl FromDatum for PgRelation

Source§

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

Like from_datum for instantiating polymorphic types which require preserving the dynamic type metadata. 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 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§

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 IntoDatum for PgRelation

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 SqlTranslatable for PgRelation

Auto Trait Implementations§

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> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. 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<P, T> Receiver for P
where P: Deref<Target = T> + ?Sized, T: ?Sized,

Source§

type Target = T

🔬This is a nightly-only experimental API. (arbitrary_self_types)
The target type on which the method may be called.
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> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
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: 'static + ?Sized,

Source§

const ITEM_ID: Lazy<TypeId> = const ITEM_ID: Lazy<TypeId> = Lazy::new(|| TypeId::of::<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)
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,