Module database 

PostgreSQL database source adapter (feature = “postgres”) Database source adapter — queries PostgreSQL as a pipeline data source.

Implements DataSourcePort and ScrapingService so database queries can participate in a DAG pipeline as a first-class node.

Requires the postgres feature flag (sqlx dependency).

Example

use stygian_graph::adapters::database::DatabaseSource;
use stygian_graph::ports::data_source::{DataSourcePort, QueryParams};
use serde_json::json;

let db = DatabaseSource::new("postgres://user:pass@localhost/mydb").await.unwrap();
let rows = db.query(QueryParams {
    query: "SELECT id, name FROM users LIMIT 10".into(),
    parameters: vec![],
    limit: Some(10),
}).await.unwrap();

Structs

DatabaseSource

Adapter: PostgreSQL database as a pipeline data source.