test_class.file: shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-core/src/test/java/org/apache/shardingsphere/proxy/frontend/executor/CommandExecutorSelectorTest.java
test_class.identifier: CommandExecutorSelectorTest
test_case.body: @Test
      public void assertGetExecutorServiceWithOccupyThreadForPerConnection() {
          ChannelId channelId = mock(ChannelId.class);
          ChannelThreadExecutorGroup.getInstance().register(channelId);
          assertThat(CommandExecutorSelector.getExecutorService(true, false, TransactionType.LOCAL, channelId), instanceOf(ExecutorService.class));
      }
test_case.class_method_signature: CommandExecutorSelectorTest.assertGetExecutorServiceWithOccupyThreadForPerConnection()
test_case.full_signature: @Test public void assertGetExecutorServiceWithOccupyThreadForPerConnection()
test_case.identifier: assertGetExecutorServiceWithOccupyThreadForPerConnection
test_case.invocations: mock register getInstance assertThat getExecutorService instanceOf
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void assertGetExecutorServiceWithOccupyThreadForPerConnection()
focal_class.file: shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-core/src/main/java/org/apache/shardingsphere/proxy/frontend/executor/CommandExecutorSelector.java
focal_class.identifier: CommandExecutorSelector
focal_class.class_method_signature: CommandExecutorSelector.getExecutorService(final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType, final ChannelId channelId)
focal_class.full_signature: public static ExecutorService getExecutorService(final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType, final ChannelId channelId)
focal_class.identifier: getExecutorService
focal_class.modifiers: public static
focal_class.parameters: (final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType, final ChannelId channelId)
focal_class.return: ExecutorService
focal_class.signature: ExecutorService getExecutorService(final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType, final ChannelId channelId)
focal_class.class_method_signature: CommandExecutorSelector.isOccupyThreadForPerConnection(final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType)
focal_class.full_signature: private static boolean isOccupyThreadForPerConnection(final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType)
focal_class.identifier: isOccupyThreadForPerConnection
focal_class.modifiers: private static
focal_class.parameters: (final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType)
focal_class.return: boolean
focal_class.signature: boolean isOccupyThreadForPerConnection(final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType)
focal_method.body: public static ExecutorService getExecutorService(final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType, final ChannelId channelId) {
          return isOccupyThreadForPerConnection(isOccupyThreadForPerConnection, supportHint, transactionType)
                  ? ChannelThreadExecutorGroup.getInstance().get(channelId) : UserExecutorGroup.getInstance().getExecutorService();
      }
focal_method.class_method_signature: CommandExecutorSelector.getExecutorService(final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType, final ChannelId channelId)
focal_method.full_signature: public static ExecutorService getExecutorService(final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType, final ChannelId channelId)
focal_method.identifier: getExecutorService
focal_method.invocations: isOccupyThreadForPerConnection get getInstance getExecutorService getInstance
focal_method.modifiers: public static
focal_method.parameters: (final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType, final ChannelId channelId)
focal_method.return: ExecutorService
focal_method.signature: ExecutorService getExecutorService(final boolean isOccupyThreadForPerConnection, final boolean supportHint, final TransactionType transactionType, final ChannelId channelId)