feat(common): support switching from pg jdbc to pg native sinks

[kwannoel]

I hereby agree to the terms of the RisingWave Labs, Inc. Contributor License Agreement.

What's changed and what's your intention?

We can switch from jdbc:postgres to native postgres sink by enabling a config under [streaming.developer].

See Release Notes below for more details.

Checklist

• I have written necessary rustdoc comments
• I have added necessary unit tests and integration tests
• I have added test labels as necessary. See details.
• I have added fuzzing tests or opened an issue to track them. (Optional, recommended for new SQL features Sqlsmith: Sql feature generation #7934).
• My PR contains breaking changes. (If it deprecates some features, please create a tracking issue to remove them in the future).
• All checks passed in ./risedev check (or alias, ./risedev c)
• My PR changes performance-critical code. (Please run macro/micro-benchmarks and show the results.)

• My PR contains critical fixes that are necessary to be merged into the latest release. (Please check out the details)

Documentation

• My PR needs documentation updates. (Please use the Release note section below to summarize the impact on users)

Release note

We support switching from connector='jdbc' for jdbc postgres sinks to connector='postgres'.

This can be done by enabling a streaming developer config:

[streaming.developer]
stream_switch_jdbc_pg_to_native = true

[kwannoel]

• perf(stream): optimize native pg sink #19688
• feat(common): support switching from pg jdbc to pg native sinks #19703 👈 (View in Graphite)
• main

This stack of pull requests is managed by Graphite. Learn more about stacking.

[chenzl25]

LGTM

[StrikeW]

LGTM!

[stdrc]

Suggested change

	if !url.contains("jdbc:postgres") {
	bail!("invalid jdbc url")
	}
	let url = url.replace("jdbc:", "");
	let url = Url::parse(&url).map_err(|e| anyhow!(e).context("failed to parse jdbc url"))?;
	if !url.starts_with("jdbc:") {
	bail!("invalid jdbc url")
	}
	let url = Url::parse(&url[5..]).map_err(|e| anyhow!(e).context("failed to parse jdbc url"))?;

[kwannoel]

Replace jdbc is a lot more explicit, than trimming the string after 5 chars.

[kwannoel]

Need review for Cargo.lock

[kwannoel]

Merge activity

• Dec 11, 8:30 PM EST: Graphite couldn't merge this PR because it failed for an unknown reason (This repository has GitHub's merge queue enabled, which is currently incompatible with Graphite).

[github-actions]

Hi, there.

📝 Telemetry Reminder:
If you're implementing this feature, please consider adding telemetry metrics to track its usage. This helps us understand how the feature is being used and improve it further.
You can find the function report_event of telemetry reporting in the following files. Feel free to ask questions if you need any guidance!

• src/frontend/src/telemetry.rs
• src/meta/src/telemetry.rs
• src/stream/src/telemetry.rs
• src/storage/compactor/src/telemetry.rs
  Or calling report_event_common (src/common/telemetry_event/src/lib.rs) as if finding it hard to implement.
  ✨ Thank you for your contribution to RisingWave! ✨

---

This is an automated comment created by the peaceiris/actions-label-commenter. Responding to the bot or mentioning it won't have any effect.