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"));