public void setCurrentSchema ( final String schemaName ) { if ( isSwitchFailed ( ) ) { throw new ShardingException ( "Failed to switch schema, please terminate current transaction." ) ; } this . schemaName = schemaName ; this . logicSchema = LogicSchemas . getInstance ( ) . getLogicSchema ( schemaName ) ; }
Change logic schema of current channel .