Struct PgVectorAdapter 

pub struct PgVectorAdapter { /* private fields */ }

Vector database backed by PostgreSQL + pgvector extension.

Requires a PostgreSQL instance with the vector extension installed (the adapter will attempt CREATE EXTENSION IF NOT EXISTS vector on startup).

Implementations

impl PgVectorAdapter

pub async fn new( database_url: &str, dimension: usize, ) -> Result<PgVectorAdapter, VectorDBError>

Connect to an existing PostgreSQL database and run pgvector migrations.

The database must already exist. Use Self::from_connection to share a connection that was established elsewhere (e.g. by the database crate).

Arguments

• database_url — Postgres connection string, e.g. postgres://user:pass@localhost:5432/mydb
• dimension — default vector dimension (e.g. 384 for BGE-Small)

pub async fn from_connection( db: DatabaseConnection, dimension: usize, ) -> Result<PgVectorAdapter, VectorDBError>

Wrap an existing SeaORM DatabaseConnection (must be Postgres).

The caller is responsible for ensuring the database already exists (the connection proves it does). Only the pgvector extension and bookkeeping table are created if missing.

pub fn dimension(&self) -> usize

Returns the default vector dimension this adapter was configured with.

Trait Implementations

impl VectorDB for PgVectorAdapter

fn create_collection<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, data_type: &'life1 str, field_name: &'life2 str, dimension: usize, ) -> Pin<Box<dyn Future<Output = Result<(), VectorDBError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, PgVectorAdapter: 'async_trait,

Create a collection for (data_type, field_name) pair

fn has_collection<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, data_type: &'life1 str, field_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool, VectorDBError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, PgVectorAdapter: 'async_trait,

Check if collection exists

fn index_points<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, data_type: &'life1 str, field_name: &'life2 str, points: &'life3 [VectorPoint], ) -> Pin<Box<dyn Future<Output = Result<(), VectorDBError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, PgVectorAdapter: 'async_trait,

Index data points (batch upsert with embeddings already generated)

fn search_similar<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, data_type: &'life1 str, field_name: &'life2 str, query_vector: &'life3 [f32], top_k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<SearchResult>, VectorDBError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, PgVectorAdapter: 'async_trait,

Search for similar vectors

fn delete_collection<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, data_type: &'life1 str, field_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), VectorDBError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, PgVectorAdapter: 'async_trait,

Delete collection

fn delete_points<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, data_type: &'life1 str, field_name: &'life2 str, point_ids: &'life3 [Uuid], ) -> Pin<Box<dyn Future<Output = Result<(), VectorDBError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, PgVectorAdapter: 'async_trait,

Delete points by IDs from an existing collection.

fn collection_size<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, data_type: &'life1 str, field_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<usize, VectorDBError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, PgVectorAdapter: 'async_trait,

Get collection statistics

fn list_collections<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, String)>, VectorDBError>> + Send + 'async_trait>>

where 'life0: 'async_trait, PgVectorAdapter: 'async_trait,

List all existing vector collections as (data_type, field_name) pairs.

fn prune<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), VectorDBError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Remove all vector collections.

fn batch_search_similar<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, data_type: &'life1 str, field_name: &'life2 str, query_vectors: &'life3 [Vec<f32>], top_k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<SearchResult>>, VectorDBError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, Self: 'async_trait,

Perform multiple vector similarity searches in sequence.