-
Notifications
You must be signed in to change notification settings - Fork 3.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Jdbc merge support #23034
Jdbc merge support #23034
Conversation
09df173
to
dedee86
Compare
8b2f8c8
to
b6e0023
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Another round of review. Please have a lot of patience, I still try to get deeper and still I am not there. There could be a case where some my comments could be reverted in future. It is a creative process, so I hope in the end we will get into a good spot with this PR, but it may require trials and errors.
I mostly reviewed the first commit. I asked for some preparatory commits, potentially we could do them as separate PR and merge it faster. Then we could rebase this PR.
plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcClient.java
Outdated
Show resolved
Hide resolved
plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcClient.java
Outdated
Show resolved
Hide resolved
plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcClient.java
Outdated
Show resolved
Hide resolved
plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/BaseJdbcClient.java
Outdated
Show resolved
Hide resolved
plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/DefaultJdbcMetadata.java
Outdated
Show resolved
Hide resolved
plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcMergeSink.java
Outdated
Show resolved
Hide resolved
plugin/trino-ignite/src/main/java/io/trino/plugin/ignite/IgniteMergeTableHandle.java
Outdated
Show resolved
Hide resolved
plugin/trino-ignite/src/main/java/io/trino/plugin/ignite/IgniteMetadata.java
Outdated
Show resolved
Hide resolved
plugin/trino-ignite/src/main/java/io/trino/plugin/ignite/IgniteMetadata.java
Outdated
Show resolved
Hide resolved
plugin/trino-postgresql/src/main/java/io/trino/plugin/postgresql/PostgreSqlClient.java
Outdated
Show resolved
Hide resolved
159b755
to
fb71994
Compare
fb71994
to
df161e9
Compare
db01ce8
to
4a3fcb5
Compare
@kokosing Here's the updated version for review |
Add support for postgresql. |
This pull request has gone a while without any activity. Tagging the Trino developer relations team: @bitsondatadev @colebow @mosabua |
97870af
to
41f8870
Compare
@@ -115,6 +115,18 @@ catalog named `sales` using the configured connector. | |||
```{include} non-transactional-insert.fragment | |||
``` | |||
|
|||
### Non-transactional MERGE |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@mosabua Would you mind to have a look?
Added the |
|
Renamed to |
c5d7afd
to
6870972
Compare
Support MERGE in base jdbc module and refactor Phoenix implementation based on it
6870972
to
23a2c29
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
% comments
plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/DefaultJdbcMetadata.java
Outdated
Show resolved
Hide resolved
plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcWriteConfig.java
Show resolved
Hide resolved
plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcWriteSessionProperties.java
Show resolved
Hide resolved
plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcClient.java
Show resolved
Hide resolved
Co-Authored-By: Grzegorz Kokosiński <[email protected]>
23a2c29
to
fb63d83
Compare
Thank you! Merged. |
Woooohhoooo.. congratulations @chenjian2664 -- excellent work. Also thank you so much for your help and guidance @kokosing |
...n/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlConnectorTest.java
Show resolved
Hide resolved
...ostgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlJdbcConnectionAccesses.java
Show resolved
Hide resolved
...ostgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlJdbcConnectionCreation.java
Show resolved
Hide resolved
plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcWriteSessionProperties.java
Show resolved
Hide resolved
@chenjian2664 this PR covers support MERGE for oracle as well? |
@shohamyamin This pr not covers oracle, but I am working on it |
The oracle work is tracking in #23034 @shohamyamin FYI |
Description
Close #20532
Additional context and related issues
Release notes
(x) Release notes are required, with the following suggested text: