Skip to content

Commit

Permalink
Remove MetaDataRefreshEngine.DDL_STATEMENT_CLASSES
Browse files Browse the repository at this point in the history
  • Loading branch information
terrymanu committed Jan 23, 2025
1 parent 51efe0b commit 2cb1e2b
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,7 @@ private int doExecuteUpdate(final ShardingSphereDatabase database, final Executi
.newInstance(database, executionContext.getSqlStatementContext().getSqlStatement(), updateCallback);
List<Integer> updateCounts = jdbcExecutor.execute(executionGroupContext, callback);
MetaDataRefreshEngine metaDataRefreshEngine = new MetaDataRefreshEngine(connection.getContextManager().getPersistServiceFacade().getMetaDataManagerPersistService(), database, props);
if (metaDataRefreshEngine.isNeedRefreshMetaData(executionContext.getSqlStatementContext())) {
if (metaDataRefreshEngine.isNeedRefresh(executionContext.getSqlStatementContext())) {
if (isNeedImplicitCommit(executionContext.getSqlStatementContext())) {
connection.commit();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ public final class MetaDataRefreshEngine {
* @param sqlStatementContext SQL statement context
* @return is need refresh meta data or not
*/
public boolean isNeedRefreshMetaData(final SQLStatementContext sqlStatementContext) {
public boolean isNeedRefresh(final SQLStatementContext sqlStatementContext) {
Class<?> sqlStatementClass = sqlStatementContext.getSqlStatement().getClass().getSuperclass();
return TypedSPILoader.findService(MetaDataRefresher.class, sqlStatementClass).isPresent();
}
Expand Down

0 comments on commit 2cb1e2b

Please sign in to comment.