Struct PostgresqlBackend 

pub struct PostgresqlBackend { /* private fields */ }

PostgreSQL storage backend

This backend uses OpenDAL’s Postgresql service to query database tables. Each row is treated as a “file” where:

• The key_field column becomes the file path
• The value_field column becomes the file content

Example

use sqlite_vtable_opendal::backends::postgresql::PostgresqlBackend;
use sqlite_vtable_opendal::types::QueryConfig;

let backend = PostgresqlBackend::new(
    "postgresql://user:pass@localhost/db",
    "my_table",
    "id",
    "data"
);
let config = QueryConfig::default();
let files = backend.list_files(&config).await?;

Implementations

impl PostgresqlBackend

pub fn new( connection_string: impl Into<String>, table: impl Into<String>, key_field: impl Into<String>, value_field: impl Into<String>, ) -> Self

Create a new PostgreSQL backend

Arguments

• connection_string - PostgreSQL connection string
• table - Table name to query
• key_field - Column name for keys (default: “key”)
• value_field - Column name for values (default: “value”)

Example

use sqlite_vtable_opendal::backends::postgresql::PostgresqlBackend;

let backend = PostgresqlBackend::new(
    "postgresql://localhost/mydb",
    "documents",
    "id",
    "content"
);

Trait Implementations

impl StorageBackend for PostgresqlBackend

fn list_files<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 QueryConfig, ) -> Pin<Box<dyn Future<Output = Result<Vec<FileMetadata>>> + Send + 'async_trait>>

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

List files from the storage backend according to the query configuration

fn backend_name(&self) -> &'static str

Get the name of this backend (for logging/debugging)