[Bug]: JDBC SQL lineage reports is missing schema support

[stankiewicz]

What happened?

when querying JDBCIO:

.withQuery("select id, first_name, last_name from public.users")

reported lineage is reporting table segment as public.users.

expected output should be two segments: public, users as per Dataplex FQN spec:
cloudsql_{scheme}:{projectId}.{location}.{instanceId}.{databaseId}.{schemaId}.{tableId}

if sql query/inputed table is missing schema then beam reports:
cloudsql_{scheme}:{projectId}.{location}.{instanceId}.{databaseId}.{tableId}

which dataplex interprets as
cloudsql_{scheme}:{projectId}.{location}.{instanceId}.{databaseId}.{schemaId}

Issue Priority

Priority: 3 (minor)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam YAML
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Infrastructure
• Component: Spark Runner
• Component: Flink Runner
• Component: Samza Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner

[stankiewicz]

@Abacn , fyi

[stankiewicz]

I'm also thinking if we are missing quoted identifiers e.g.

select * from `select`

https://dev.mysql.com/doc/refman/8.4/en/identifiers.html