Introduce the awaitility framework to replace Thread.sleep in E2E (#37384)

* Add document and test cases on DistSQL of manage SQL_TRANSLATOR rule

* Add document and test cases on DistSQL of manage SQL_TRANSLATOR rule

* Add document and test cases on DistSQL of manage SQL_TRANSLATOR rule

* Add document and test cases on DistSQL of manage SQL_TRANSLATOR rule

* Introduce the awaitility framework to replace Thread.sleep in E2E

* Introduce the awaitility framework to replace Thread.sleep in E2E

* Introduce the awaitility framework to replace Thread.sleep in E2E

* Introduce the awaitility framework to replace Thread.sleep in E2E

Author: terrymanu

test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/storage/type/DockerStorageContainer.java

@@ -132,13 +132,12 @@ private String getURL() {
                 .orElseGet(() -> option.getConnectOption().getURL("localhost", getFirstMappedPort()));
     }
 
-    @SneakyThrows({SQLException.class, InterruptedException.class})
+    @SneakyThrows(SQLException.class)
     @Override
     protected void containerIsStarted(final InspectContainerResponse containerInfo) {
         if (option.getCreateOption().isSupportDockerEntrypoint()) {
             return;
         }
-        Thread.sleep(10000L);
         try (
                 Connection connection = DriverManager.getConnection(option.getConnectOption().getURL("localhost", getFirstMappedPort()),
                         option.getCreateOption().getDefaultUserWhenUnsupportedDockerEntrypoint().orElse(""),

test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/operation/pipeline/cases/migration/general/PostgreSQLToMySQLMigrationE2EIT.java

@@ -17,7 +17,6 @@
 
 package org.apache.shardingsphere.test.e2e.operation.pipeline.cases.migration.general;
 
-import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.RandomStringUtils;
 import org.apache.commons.lang3.RandomUtils;
@@ -35,6 +34,7 @@
 import org.apache.shardingsphere.test.e2e.operation.pipeline.framework.param.PipelineE2ETestCaseArgumentsProvider;
 import org.apache.shardingsphere.test.e2e.operation.pipeline.framework.param.PipelineTestParameter;
 import org.awaitility.Awaitility;
+import org.awaitility.core.ConditionTimeoutException;
 import org.junit.jupiter.api.condition.EnabledIf;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ArgumentsSource;
@@ -150,17 +150,13 @@ private void initTargetTable(final PipelineContainerComposer containerComposer)
         }
     }
 
-    @SneakyThrows
     private static boolean waitForTableExistence(final Connection connection, final String tableName) {
-        int elapsedTime = 0;
-        while (elapsedTime < 60) {
-            if (tableExists(connection, tableName)) {
-                return true;
-            }
-            Thread.sleep(3 * 1000L);
-            elapsedTime += 3;
+        try {
+            Awaitility.await().ignoreExceptions().atMost(60L, TimeUnit.SECONDS).pollInterval(3L, TimeUnit.SECONDS).until(() -> tableExists(connection, tableName));
+            return true;
+        } catch (final ConditionTimeoutException ex) {
+            return false;
         }
-        return false;
     }
 
     private static boolean tableExists(final Connection connection, final String tableName) throws SQLException {

test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/sql/it/sql/dal/DALE2EIT.java

@@ -74,10 +74,8 @@ private void assertExecute(final SQLE2EITContext context) throws SQLException {
         try (Connection connection = environmentEngine.getTargetDataSource().getConnection()) {
             try (Statement statement = connection.createStatement()) {
                 statement.execute(context.getSQL());
-                Thread.sleep(1000L);
+                Awaitility.await().pollDelay(1L, TimeUnit.SECONDS).until(() -> true);
                 assertExecuteResult(context, statement);
-            } catch (final InterruptedException ignore) {
-                Thread.currentThread().interrupt();
             }
         } finally {
             tearDown(context);