-
Notifications
You must be signed in to change notification settings - Fork 350
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
[#575] feat(jdbc): Support for DataSource and schema operations in JDBC catalog. #703
Conversation
1bb7e1f
to
6923f5d
Compare
Code Coverage Report
Files
|
...talog-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
Outdated
Show resolved
Hide resolved
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/JdbcCatalogOperations.java
Show resolved
Hide resolved
6923f5d
to
9d034cd
Compare
...talog-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
Outdated
Show resolved
Hide resolved
...talog-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
Outdated
Show resolved
Hide resolved
.../src/test/java/com/datastrato/gravitino/catalog/jdbc/converter/SqliteExceptionConverter.java
Outdated
Show resolved
Hide resolved
...on/src/main/java/com/datastrato/gravitino/catalog/jdbc/operation/JdbcDatabaseOperations.java
Outdated
Show resolved
Hide resolved
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/utils/DataSourceUtils.java
Outdated
Show resolved
Hide resolved
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/utils/DataSourceUtils.java
Outdated
Show resolved
Hide resolved
...on/src/main/java/com/datastrato/gravitino/catalog/jdbc/operation/JdbcDatabaseOperations.java
Outdated
Show resolved
Hide resolved
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/JdbcCatalogOperations.java
Outdated
Show resolved
Hide resolved
...talog-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
Outdated
Show resolved
Hide resolved
Does the pr introduce some user-facing config options? If yes, we should add the document, too. |
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/utils/DataSourceUtils.java
Outdated
Show resolved
Hide resolved
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/utils/DataSourceUtils.java
Outdated
Show resolved
Hide resolved
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/JdbcCatalogOperations.java
Outdated
Show resolved
Hide resolved
...on/src/main/java/com/datastrato/gravitino/catalog/jdbc/converter/JdbcExceptionConverter.java
Show resolved
Hide resolved
...on/src/main/java/com/datastrato/gravitino/catalog/jdbc/operation/JdbcDatabaseOperations.java
Outdated
Show resolved
Hide resolved
...on/src/main/java/com/datastrato/gravitino/catalog/jdbc/operation/JdbcDatabaseOperations.java
Outdated
Show resolved
Hide resolved
...talog-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
Outdated
Show resolved
Hide resolved
...talog-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
Outdated
Show resolved
Hide resolved
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/JdbcCatalogOperations.java
Outdated
Show resolved
Hide resolved
...on/src/main/java/com/datastrato/gravitino/catalog/jdbc/operation/JdbcDatabaseOperations.java
Outdated
Show resolved
Hide resolved
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/utils/DataSourceUtils.java
Outdated
Show resolved
Hide resolved
...on/src/main/java/com/datastrato/gravitino/catalog/jdbc/operation/JdbcDatabaseOperations.java
Outdated
Show resolved
Hide resolved
89b4b22
to
766bcbf
Compare
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/utils/DataSourceUtils.java
Show resolved
Hide resolved
...talog-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
Outdated
Show resolved
Hide resolved
...talog-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
Outdated
Show resolved
Hide resolved
...-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/operation/DatabaseOperation.java
Outdated
Show resolved
Hide resolved
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/JdbcCatalogOperations.java
Show resolved
Hide resolved
...talog-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
Outdated
Show resolved
Hide resolved
...talog-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
Outdated
Show resolved
Hide resolved
...on/src/main/java/com/datastrato/gravitino/catalog/jdbc/operation/JdbcDatabaseOperations.java
Show resolved
Hide resolved
.../src/test/java/com/datastrato/gravitino/catalog/jdbc/operation/SqliteDatabaseOperations.java
Show resolved
Hide resolved
.../src/test/java/com/datastrato/gravitino/catalog/jdbc/operation/SqliteDatabaseOperations.java
Show resolved
Hide resolved
...-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/operation/DatabaseOperation.java
Outdated
Show resolved
Hide resolved
...-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/operation/DatabaseOperation.java
Show resolved
Hide resolved
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/utils/DataSourceUtils.java
Outdated
Show resolved
Hide resolved
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/utils/DataSourceUtils.java
Outdated
Show resolved
Hide resolved
...ommon/src/main/java/com/datastrato/gravitino/catalog/jdbc/JdbcCatalogPropertiesMetadata.java
Outdated
Show resolved
Hide resolved
...talog-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/config/JdbcConfig.java
Outdated
Show resolved
Hide resolved
@FANNG1 Can you help to review the Iceberg catalog part again? |
...g-jdbc-common/src/main/java/com/datastrato/gravitino/catalog/jdbc/JdbcCatalogOperations.java
Show resolved
Hide resolved
.createWithDefault(null); | ||
|
||
public static final ConfigEntry<Integer> POOL_MIN_IDLE = | ||
new ConfigBuilder("jdbc.connect-pool.min-idle") |
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.
I'm not sure whether to change this to min-size
, @jerryshao what's you advise?
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.
I mainly referred to 'org.apache.commons.dbcp2.BasicDataSourceFactory#PROP_MIN_IDLE'
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.
I would suggest to align with "max-size" to use "min-size".
Also, I would prefer to shorten the configuration name to "pool.min-size" and "pool.max-size", what do you think?
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.
ok
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.
done.
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.
Also, I would prefer to shorten the configuration name to "pool.min-size" and "pool.max-size", what do you think?
I think you neglect this comment.
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.
Okay, I'll change it to pool.min-size
Generally LGTM, except some minor comments |
8977c1a
to
409380a
Compare
LGTM. |
What changes were proposed in this pull request?
We need to add management functionalities for data sources and operations on schemas in jdbc-common.
Why are the changes needed?
Fix: #575
Does this PR introduce any user-facing change?
No
How was this patch tested?
UT