|
|
|
@ -69,8 +69,8 @@ import static org.junit.Assert.assertTrue;
|
|
|
|
|
* we added fallback in {@link MySqlSchema} when parsing ddl failed and provided these cases to
|
|
|
|
|
* test.
|
|
|
|
|
*/
|
|
|
|
|
public class PolardbxSourceTCase extends AbstractTestBase {
|
|
|
|
|
private static final Logger LOG = LoggerFactory.getLogger(PolardbxSourceTCase.class);
|
|
|
|
|
public class PolardbxSourceITCase extends AbstractTestBase {
|
|
|
|
|
private static final Logger LOG = LoggerFactory.getLogger(PolardbxSourceITCase.class);
|
|
|
|
|
private static final Pattern COMMENT_PATTERN = Pattern.compile("^(.*)--.*$");
|
|
|
|
|
private static final Integer PORT = 8527;
|
|
|
|
|
private static final String HOST_NAME = "127.0.0.1";
|
|
|
|
@ -131,7 +131,7 @@ public class PolardbxSourceTCase extends AbstractTestBase {
|
|
|
|
|
protected static void initializePolardbxTables(String databaseName)
|
|
|
|
|
throws InterruptedException {
|
|
|
|
|
final String ddlFile = String.format("ddl/%s.sql", databaseName);
|
|
|
|
|
final URL ddlTestFile = PolardbxSourceTCase.class.getClassLoader().getResource(ddlFile);
|
|
|
|
|
final URL ddlTestFile = PolardbxSourceITCase.class.getClassLoader().getResource(ddlFile);
|
|
|
|
|
assertNotNull("Cannot locate " + ddlFile, ddlTestFile);
|
|
|
|
|
// need to sleep 1s, make sure the jdbc connection can be created
|
|
|
|
|
Thread.sleep(1000);
|