Skip to main content

build_create_subscription_sql

Function build_create_subscription_sql 

Source
pub fn build_create_subscription_sql(
    opts: &CreateSubscriptionOptions<'_>,
) -> Result<String>
Expand description

Build a CREATE SUBSCRIPTION statement.

ยงExample

use pg_walstream::sql_builder::{build_create_subscription_sql, CreateSubscriptionOptions};

let opts = CreateSubscriptionOptions {
    subscription_name: "my_sub",
    connection_string: "host=localhost dbname=source",
    publication: "my_pub",
    slot_name: "my_slot",
    ..Default::default()
};
let sql = build_create_subscription_sql(&opts).unwrap();
assert!(sql.starts_with("CREATE SUBSCRIPTION"));