Skip to content

Commit f0880fd

Browse files
authored
Fixes exception thrown if renamed schema name missed on AlterSchemaPushDownMetaDataRefresher (#34465)
1 parent f141d77 commit f0880fd

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/metadata/pushdown/type/schema/AlterSchemaPushDownMetaDataRefresher.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717

1818
package org.apache.shardingsphere.mode.metadata.refresher.metadata.pushdown.type.schema;
1919

20-
import com.google.common.base.Preconditions;
2120
import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
2221
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
2322
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
@@ -39,9 +38,10 @@ public final class AlterSchemaPushDownMetaDataRefresher implements PushDownMetaD
3938
public void refresh(final MetaDataManagerPersistService metaDataManagerPersistService, final ShardingSphereDatabase database, final Collection<String> logicDataSourceNames,
4039
final String schemaName, final DatabaseType databaseType, final AlterSchemaStatement sqlStatement, final ConfigurationProperties props) throws SQLException {
4140
Optional<String> renameSchemaName = sqlStatement.getRenameSchema().map(optional -> optional.getValue().toLowerCase());
42-
Preconditions.checkArgument(renameSchemaName.isPresent(), "The renamed schema is not exist of schema '%s'.", schemaName);
43-
metaDataManagerPersistService.alterSchema(new AlterSchemaPOJO(database.getName(), sqlStatement.getSchemaName().getValue().toLowerCase(),
44-
renameSchemaName.get(), logicDataSourceNames));
41+
if (!renameSchemaName.isPresent()) {
42+
return;
43+
}
44+
metaDataManagerPersistService.alterSchema(new AlterSchemaPOJO(database.getName(), sqlStatement.getSchemaName().getValue().toLowerCase(), renameSchemaName.get(), logicDataSourceNames));
4545
}
4646

4747
@Override

0 commit comments

Comments
 (0)