CPD Results
The following document contains the results of PMD's CPD 7.17.0.
Duplications
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/alter/type/AlterShardingTableRuleStatementAssert.java | 65 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/create/type/CreateShardingTableRuleStatementAssert.java | 67 |
Collection<TableRuleSegment> actualTableRules = actual.getRules().stream().map(TableRuleSegment.class::cast).collect(Collectors.toList());
assertShardingTableRules(assertContext, actualTableRules, tableRuleStatementTestCase.getRules());
}
}
}
private static void assertShardingAutoTableRules(final SQLCaseAssertContext assertContext, final Collection<AutoTableRuleSegment> actual, final List<ExpectedAutoTableRule> expected) {
if (null == expected) {
assertNull(actual, assertContext.getText("Actual sharding auto table rule should not exist."));
} else {
assertNotNull(actual, assertContext.getText("Actual sharding auto table rule should exist."));
assertThat(assertContext.getText("Sharding auto table rule count assertion error: "), actual.size(), is(expected.size()));
int count = 0;
for (AutoTableRuleSegment each : actual) {
AutoTableRuleAssert.assertIs(assertContext, each, expected.get(count));
count++;
}
}
}
private static void assertShardingTableRules(final SQLCaseAssertContext assertContext, final Collection<TableRuleSegment> actual, final List<ExpectedTableRule> expected) {
if (null == expected) {
assertNull(actual, assertContext.getText("Actual sharding table rule should not exist."));
} else {
assertNotNull(actual, assertContext.getText("Actual sharding table rule should exist."));
assertThat(assertContext.getText("Sharding table rule count assertion error: "), actual.size(), is(expected.size()));
int count = 0;
for (TableRuleSegment each : actual) {
TableRuleAssert.assertIs(assertContext, each, expected.get(count));
count++;
}
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterSqlBlockRuleStatementAssert.java | 46 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateSqlBlockRuleStatementAssert.java | 46 |
public static void assertIs(final SQLCaseAssertContext assertContext, final DorisAlterSqlBlockRuleStatement actual, final DorisAlterSqlBlockRuleStatementTestCase expected) {
if (null != expected.getRuleName()) {
assertThat(assertContext.getText("Rule name does not match: "), actual.getRuleName(), is(expected.getRuleName()));
}
assertNotNull(actual.getProperties(), assertContext.getText("Properties should not be null"));
if (!expected.getProperties().isEmpty()) {
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetPartitionVersionStatementAssert.java | 48 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetTableStatusStatementAssert.java | 47 |
final DorisAdminSetPartitionVersionStatementTestCase expected) {
assertNotNull(actual.getTable(), assertContext.getText("Table should not be null"));
TableAssert.assertIs(assertContext, actual.getTable(), expected.getTable());
assertNotNull(actual.getProperties(), assertContext.getText("Properties should not be null"));
if (!expected.getProperties().isEmpty()) {
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateFileStatementAssert.java | 71 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/DropFileStatementAssert.java | 71 |
private static void assertProperties(final SQLCaseAssertContext assertContext, final CreateFileStatement actual, final CreateFileStatementTestCase expected) {
assertNotNull(expected.getProperties(), assertContext.getText("Expected properties should not be null"));
assertNotNull(actual.getProperties(), assertContext.getText("Actual properties should not be null"));
SQLSegmentAssert.assertIs(assertContext, actual.getProperties(), expected.getProperties());
assertThat(assertContext.getText("Properties size assertion error: "),
actual.getProperties().getProperties().size(), is(expected.getProperties().getProperties().size()));
for (int i = 0; i < expected.getProperties().getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().getProperties().get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final ExpectedProperty expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 81 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 172 |
if (actual.getDataSourceProperties().isPresent() && !expected.getDataSourceProperties().isEmpty()) {
assertNotNull(actual.getDataSourceProperties().get(), assertContext.getText("Data source properties should not be null"));
assertThat(assertContext.getText("Data source properties size does not match: "), actual.getDataSourceProperties().get().getProperties().size(),
is(expected.getDataSourceProperties().size()));
for (int i = 0; i < expected.getDataSourceProperties().size(); i++) {
assertProperty(assertContext, actual.getDataSourceProperties().get().getProperties().get(i), expected.getDataSourceProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterSqlBlockRuleStatementAssert.java | 48 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateWorkloadGroupStatementAssert.java | 48 |
assertThat(assertContext.getText("Rule name does not match: "), actual.getRuleName(), is(expected.getRuleName()));
}
assertNotNull(actual.getProperties(), assertContext.getText("Properties should not be null"));
if (!expected.getProperties().isEmpty()) {
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateSqlBlockRuleStatementAssert.java | 48 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateWorkloadGroupStatementAssert.java | 48 |
assertThat(assertContext.getText("Rule name does not match: "), actual.getRuleName(), is(expected.getRuleName()));
}
assertNotNull(actual.getProperties(), assertContext.getText("Properties should not be null"));
if (!expected.getProperties().isEmpty()) {
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaStatusStatementAssert.java | 46 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaVersionStatementAssert.java | 46 |
public static void assertIs(final SQLCaseAssertContext assertContext, final DorisAdminSetReplicaStatusStatement actual, final DorisAdminSetReplicaStatusStatementTestCase expected) {
assertNotNull(actual.getProperties(), assertContext.getText("Properties should not be null"));
if (!expected.getProperties().isEmpty()) {
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 75 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 50 |
private static void assertProperties(final SQLCaseAssertContext assertContext, final AlterDatabaseStatement actual, final AlterDatabaseStatementTestCase expected) {
if (expected.getProperties().isEmpty()) {
return;
}
assertNotNull(actual.getProperties(), assertContext.getText("Properties should not be null"));
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetPartitionVersionStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaStatusStatementAssert.java | 47 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaVersionStatementAssert.java | 47 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetTableStatusStatementAssert.java | 50 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterSqlBlockRuleStatementAssert.java | 50 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateSqlBlockRuleStatementAssert.java | 50 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateWorkloadGroupStatementAssert.java | 50 |
assertNotNull(actual.getProperties(), assertContext.getText("Properties should not be null"));
if (!expected.getProperties().isEmpty()) {
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterViewStatementAssert.java | 95 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateViewStatementAssert.java | 63 |
private static void assertColumns(final SQLCaseAssertContext assertContext, final AlterViewStatement actual, final AlterViewStatementTestCase expected) {
assertThat(assertContext.getText("View columns size assertion error: "), actual.getColumns().size(), is(expected.getColumns().size()));
int count = 0;
for (ViewColumnSegment each : actual.getColumns()) {
ExpectedViewColumn expectedColumn = expected.getColumns().get(count);
IdentifierValueAssert.assertIs(assertContext, each.getColumn().getIdentifier(), expectedColumn, "View column");
SQLSegmentAssert.assertIs(assertContext, each, expectedColumn);
if (null != expectedColumn.getComment()) {
assertTrue(each.getComment().isPresent(), assertContext.getText(String.format("View column `%s` should have comment", expectedColumn.getName())));
assertThat(assertContext.getText(String.format("View column `%s` comment assertion error: ", expectedColumn.getName())),
each.getComment().get(), is(expectedColumn.getComment()));
} else {
assertFalse(each.getComment().isPresent(), assertContext.getText(String.format("View column `%s` should not have comment", expectedColumn.getName())));
}
count++;
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/segment/policy/PolicyAssert.java | 59 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/type/DorisAlterColocateGroupStatementAssert.java | 71 |
public static void assertProperties(final SQLCaseAssertContext assertContext, final PropertiesSegment actual, final ExpectedCatalogProperties expected) {
SQLSegmentAssert.assertIs(assertContext, actual, expected);
assertThat(assertContext.getText("Properties size assertion error: "), actual.getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().get(i), expected.getProperties().get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final ExpectedCatalogProperty expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCopyTabletStatementAssert.java | 46 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetPartitionVersionStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaStatusStatementAssert.java | 47 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaVersionStatementAssert.java | 47 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetTableStatusStatementAssert.java | 50 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterSqlBlockRuleStatementAssert.java | 50 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateRepositoryStatementAssert.java | 80 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateSqlBlockRuleStatementAssert.java | 50 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateWorkloadGroupStatementAssert.java | 50 |
assertThat(assertContext.getText("Tablet ID does not match: "), actual.getTabletId(), is(expected.getTabletId()));
if (!expected.getProperties().isEmpty()) {
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCheckTabletStatementAssert.java | 50 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCopyTabletStatementAssert.java | 47 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetPartitionVersionStatementAssert.java | 52 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaStatusStatementAssert.java | 48 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaVersionStatementAssert.java | 48 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetTableStatusStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterSqlBlockRuleStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateRepositoryStatementAssert.java | 81 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateSqlBlockRuleStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateWorkloadGroupStatementAssert.java | 51 |
if (!expected.getProperties().isEmpty()) {
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/alter/type/AlterDefaultShardingStrategyStatementAssert.java | 45 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/create/type/CreateDefaultShardingStrategyStatementAssert.java | 46 |
assertThat(assertContext.getText(String.format("`%s`'s default sharding strategy segment assertion error: ", actual.getClass().getSimpleName())),
actual.getDefaultType(), is(expected.getStrategy().getDefaultType()));
assertThat(assertContext.getText(String.format("`%s`'s default sharding strategy segment assertion error: ", actual.getClass().getSimpleName())),
actual.getShardingColumn(), is(expected.getStrategy().getShardingColumn()));
assertThat(assertContext.getText(String.format("`%s`'s default sharding strategy segment assertion error: ", actual.getClass().getSimpleName())),
actual.getStrategyType(), is(expected.getStrategy().getStrategyType()));
if (!"none".equalsIgnoreCase(actual.getStrategyType())) {
assertThat(assertContext.getText(String.format("`%s`'s default sharding strategy segment assertion error: ", actual.getClass().getSimpleName())),
actual.getAlgorithmSegment().getName(), is(expected.getStrategy().getAlgorithmSegment().getName()));
}
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCheckTabletStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 104 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateRepositoryStatementAssert.java | 82 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateSqlBlockRuleStatementAssert.java | 52 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateWorkloadGroupStatementAssert.java | 52 |
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCopyTabletStatementAssert.java | 48 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 104 |
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetPartitionVersionStatementAssert.java | 53 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 104 |
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaStatusStatementAssert.java | 49 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 104 |
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaVersionStatementAssert.java | 49 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 104 |
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetTableStatusStatementAssert.java | 52 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 104 |
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterSqlBlockRuleStatementAssert.java | 52 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 104 |
assertThat(assertContext.getText("Properties size does not match: "), actual.getProperties().getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterResourceStatementAssert.java | 43 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateResourceStatementAssert.java | 43 |
public static void assertIs(final SQLCaseAssertContext assertContext, final DorisAlterResourceStatement actual, final DorisAlterResourceStatementTestCase expected) {
if (null != expected.getResourceName()) {
assertThat(assertContext.getText("resource name does not match: "), actual.getResourceName(), is(expected.getResourceName()));
}
assertNotNull(actual.getProperties(), assertContext.getText("properties should not be null"));
if (!expected.getProperties().isEmpty()) {
assertThat(assertContext.getText("properties size does not match: "), actual.getProperties().size(), is(expected.getProperties().size()));
expected.getProperties().forEach(property -> {
String actualValue = actual.getProperties().getProperty(property.getKey());
assertNotNull(actualValue, assertContext.getText("property key '" + property.getKey() + "' should exist"));
assertThat(assertContext.getText("property value for key '" + property.getKey() + "' does not match: "), actualValue, is(property.getValue()));
});
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCancelLoadStatementAssert.java | 44 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisShowLoadWarningsStatementAssert.java | 44 |
public static void assertIs(final SQLCaseAssertContext assertContext, final DorisCancelLoadStatement actual, final DorisCancelLoadStatementTestCase expected) {
if (null != expected.getDatabase()) {
assertNotNull(actual.getDatabase().orElse(null), assertContext.getText("Actual database should exist."));
DatabaseAssert.assertIs(assertContext, actual.getDatabase().get(), expected.getDatabase());
}
if (null != expected.getConditionType()) {
assertNotNull(actual.getConditionType(), assertContext.getText("Actual condition type should exist."));
assertThat(assertContext.getText("Condition type does not match: "), actual.getConditionType().get(), is(expected.getConditionType()));
}
if (null != expected.getConditionValue()) {
assertNotNull(actual.getConditionValue(), assertContext.getText("Actual condition value should exist."));
assertThat(assertContext.getText("Condition value does not match: "), actual.getConditionValue().get(), is(expected.getConditionValue()));
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/cases/parser/jaxb/statement/ddl/dialect/oracle/statistics/OracleAssociateStatisticsStatementTestCase.java | 40 |
| org/apache/shardingsphere/test/it/sql/parser/internal/cases/parser/jaxb/statement/ddl/dialect/oracle/statistics/OracleDisassociateStatisticsStatementTestCase.java | 40 |
public final class OracleAssociateStatisticsStatementTestCase extends SQLParserTestCase {
@XmlElement(name = "index")
private final List<ExpectedIndex> indexes = new LinkedList<>();
@XmlElement(name = "table")
private final List<ExpectedSimpleTable> tables = new LinkedList<>();
@XmlElement(name = "column")
private final List<ExpectedColumn> columns = new LinkedList<>();
@XmlElement(name = "function")
private final List<ExpectedFunction> functions = new LinkedList<>();
@XmlElement(name = "package")
private final List<ExpectedPackage> packages = new LinkedList<>();
@XmlElement(name = "type")
private final List<ExpectedType> types = new LinkedList<>();
@XmlElement(name = "index-type")
private final List<ExpectedIndexType> indexTypes = new LinkedList<>();
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/alter/AlterStorageUnitStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/create/RegisterStorageUnitStatementAssert.java | 55 |
assertNotNull(actual, assertContext.getText("Actual statement should exist."));
assertDataSources(assertContext, actual.getStorageUnits(), expected.getDataSources());
}
}
private static void assertDataSources(final SQLCaseAssertContext assertContext, final Collection<DataSourceSegment> actual, final List<ExpectedDataSource> expected) {
if (null == expected) {
assertNull(actual, assertContext.getText("Actual storage unit should not exist."));
} else {
assertNotNull(actual, assertContext.getText("Actual storage unit should exist."));
assertThat(assertContext.getText(String.format("Actual storage unit size should be %s , but it was %s", expected.size(), actual.size())), actual.size(), is(expected.size()));
int count = 0;
for (DataSourceSegment each : actual) {
DataSourceAssert.assertIs(assertContext, each, expected.get(count));
count++;
}
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/alter/type/AlterReadwriteSplittingRuleStatementAssert.java | 53 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/create/type/CreateReadwriteSplittingRuleStatementAssert.java | 54 |
assertReadwriteSplittingRule(assertContext, actual.getRules(), expected.getRules());
}
}
private static void assertReadwriteSplittingRule(final SQLCaseAssertContext assertContext, final Collection<ReadwriteSplittingRuleSegment> actual,
final List<ExceptedReadwriteSplittingRule> expected) {
if (null == expected) {
assertNull(actual, assertContext.getText("Actual readwrite-splitting rule should not exist."));
} else {
assertNotNull(actual, assertContext.getText("Actual readwrite-splitting rule should exist."));
assertThat(assertContext.getText(String.format("Actual readwrite-splitting rule size should be %s , but it was %s", expected.size(), actual.size())), actual.size(), is(expected.size()));
int count = 0;
for (ReadwriteSplittingRuleSegment each : actual) {
ReadwriteSplittingRuleAssert.assertIs(assertContext, each, expected.get(count));
count++;
}
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/alter/type/AlterShardingTableReferenceRulesStatementAssert.java | 53 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/create/type/CreateShardingTableReferenceRuleStatementAssert.java | 54 |
assertShardingBindingTableRules(assertContext, actual.getRules(), expected.getRules());
}
}
private static void assertShardingBindingTableRules(final SQLCaseAssertContext assertContext, final Collection<TableReferenceRuleSegment> actual,
final List<ExpectedShardingTableReferenceRule> expected) {
if (null == expected) {
assertNull(actual, assertContext.getText("Actual sharding table reference rule should not exist."));
} else {
assertNotNull(actual, assertContext.getText("Actual sharding table reference rule should exist."));
assertThat(assertContext.getText(String.format("Actual sharding table reference rule size should be %s , but it was %s", expected.size(), actual.size())),
actual.size(), is(expected.size()));
int count = 0;
for (TableReferenceRuleSegment each : actual) {
ShardingTableReferenceRuleAssert.assertIs(assertContext, each, expected.get(count));
count++;
}
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 64 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 155 |
if (actual.getJobProperties().isPresent() && !expected.getJobProperties().isEmpty()) {
assertNotNull(actual.getJobProperties().get(), assertContext.getText("Job properties should not be null"));
assertThat(assertContext.getText("Job properties size does not match: "), actual.getJobProperties().get().getProperties().size(),
is(expected.getJobProperties().size()));
for (int i = 0; i < expected.getJobProperties().size(); i++) {
assertProperty(assertContext, actual.getJobProperties().get().getProperties().get(i), expected.getJobProperties().get(i));
}
}
}
private static void assertDataSource(final SQLCaseAssertContext assertContext, final DorisAlterRoutineLoadStatement actual, final DorisAlterRoutineLoadStatementTestCase expected) { | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/alter/type/AlterEncryptRuleStatementAssert.java | 53 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/create/type/CreateEncryptRuleStatementAssert.java | 54 |
assertEncryptRules(assertContext, actual.getRules(), expected.getRules());
}
}
private static void assertEncryptRules(final SQLCaseAssertContext assertContext, final Collection<EncryptRuleSegment> actual, final List<ExpectedEncryptRule> expected) {
if (null == expected) {
assertNull(actual, assertContext.getText("Actual encrypt rule should not exist."));
} else {
assertNotNull(actual, assertContext.getText("Actual encrypt rule should exist."));
assertThat(assertContext.getText(String.format("Actual encrypt rule size should be %s , but it was %s", expected.size(), actual.size())), actual.size(), is(expected.size()));
int count = 0;
for (EncryptRuleSegment each : actual) {
ExpectedEncryptRule expectedEncryptRule = expected.get(count);
assertThat(assertContext.getText("encrypt rule table name assertion error: "), each.getTableName(), is(expectedEncryptRule.getName())); | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rql/type/ShowStorageUnitsStatementAssert.java | 53 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rql/type/ShowTablesStatementAssert.java | 53 |
private static void assertIs(final SQLCaseAssertContext assertContext, final ShowStorageUnitsStatement actual, final ShowStorageUnitsStatementTestCase expected) {
if (null == expected.getDatabase()) {
assertNull(actual.getFromDatabase(), assertContext.getText("Actual database should not exist."));
} else {
DatabaseAssert.assertIs(assertContext, actual.getFromDatabase().getDatabase(), expected.getDatabase());
}
if (null == expected.getLikePattern()) {
assertFalse(actual.getLikePattern().isPresent(), assertContext.getText("Actual like pattern should not exist."));
} else {
assertTrue(actual.getLikePattern().isPresent(), assertContext.getText("Actual like pattern should exist."));
assertThat(assertContext.getText("Like pattern assertion error"), actual.getLikePattern().get(), is(expected.getLikePattern()));
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisShowLoadStatementAssert.java | 80 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisShowStreamLoadStatementAssert.java | 80 |
private static void assertLimit(final SQLCaseAssertContext assertContext, final DorisShowLoadStatement actual, final DorisShowLoadStatementTestCase expected) {
if (null != expected.getLimit()) {
assertNotNull(actual.getLimit().orElse(null), assertContext.getText("Actual limit segment should exist."));
LimitClauseAssert.assertRowCount(assertContext, actual.getLimit().get().getRowCount().orElse(null), expected.getLimit().getRowCount());
LimitClauseAssert.assertOffset(assertContext, actual.getLimit().get().getOffset().orElse(null), expected.getLimit().getOffset());
} else {
assertNull(actual.getLimit().orElse(null), assertContext.getText("Actual limit segment should not exist."));
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisPauseRoutineLoadStatementAssert.java | 43 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisResumeRoutineLoadStatementAssert.java | 43 |
public static void assertIs(final SQLCaseAssertContext assertContext, final DorisPauseRoutineLoadStatement actual, final DorisPauseRoutineLoadStatementTestCase expected) {
assertThat(assertContext.getText("All flag does not match: "), actual.isAll(), is(expected.isAll()));
if (!expected.isAll() && actual.getJobName().isPresent()) {
assertThat(assertContext.getText("Job name does not match: "), actual.getJobName().get().getIdentifier().getValue(), is(expected.getJobName()));
if (null != expected.getOwner()) {
OwnerAssert.assertIs(assertContext, actual.getJobName().get().getOwner().orElse(null), expected.getOwner());
}
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCheckTabletStatementAssert.java | 53 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCopyTabletStatementAssert.java | 50 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetPartitionVersionStatementAssert.java | 55 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaStatusStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaVersionStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetTableStatusStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterSqlBlockRuleStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 106 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateRepositoryStatementAssert.java | 84 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateSqlBlockRuleStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateWorkloadGroupStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateFunctionStatementAssert.java | 90 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisDropFunctionStatementAssert.java | 68 |
final CreateFunctionStatementTestCase expected) {
if (!expected.getParameterDataTypes().isEmpty()) {
List<DataTypeSegment> actualParams = actual.getParameterDataTypes();
List<ExpectedDataTypeSegment> expectedParams = expected.getParameterDataTypes();
assertThat(assertContext.getText("Parameter count assertion error: "),
actualParams.size(), is(expectedParams.size()));
for (int i = 0; i < actualParams.size(); i++) {
assertThat(assertContext.getText(String.format("Parameter %d type assertion error: ", i)),
actualParams.get(i).getDataTypeName(), is(expectedParams.get(i).getName()));
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateIndexStatementAssert.java | 117 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/DropIndexStatementAssert.java | 76 |
private static void assertLockTable(final SQLCaseAssertContext assertContext, final CreateIndexStatement actual, final CreateIndexStatementTestCase expected) {
if (null == expected.getLockOption()) {
assertFalse(actual.getLockTable().isPresent(), assertContext.getText("Actual lock table segments should not exist."));
} else {
assertTrue(actual.getLockTable().isPresent(), assertContext.getText("Actual lock table segments should exist."));
assertThat(assertContext.getText(String.format("`%s`'s lock table assertion error: ", actual.getClass().getSimpleName())),
actual.getLockTable().get().getLockTableOption().name(), is(expected.getLockOption().getType()));
}
}
private static void assertAlgorithm(final SQLCaseAssertContext assertContext, final CreateIndexStatement actual, final CreateIndexStatementTestCase expected) { | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateFileStatementAssert.java | 73 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateIndexStatementAssert.java | 80 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/DropFileStatementAssert.java | 73 |
assertNotNull(actual.getProperties(), assertContext.getText("Actual properties should not be null"));
SQLSegmentAssert.assertIs(assertContext, actual.getProperties(), expected.getProperties());
assertThat(assertContext.getText("Properties size assertion error: "),
actual.getProperties().getProperties().size(), is(expected.getProperties().getProperties().size()));
for (int i = 0; i < expected.getProperties().getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().getProperties().get(i));
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/mysql/type/MySQLInstallComponentStatementAssert.java | 45 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/mysql/type/MySQLUninstallComponentStatementAssert.java | 45 |
public static void assertIs(final SQLCaseAssertContext assertContext, final MySQLInstallComponentStatement actual, final MySQLInstallComponentStatementTestCase expected) {
assertThat(assertContext.getText("Actual components size assertion error: "), actual.getComponents().size(), is(expected.getComponents().size()));
assertComponents(assertContext, actual.getComponents(), expected.getComponents());
}
private static void assertComponents(final SQLCaseAssertContext assertContext, final List<String> actual, final List<ExpectedComponent> expected) {
int count = 0;
for (String each : actual) {
assertThat(assertContext.getText("Actual component value does not match: "), each, is(expected.get(count).getName()));
count++;
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().get().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
private static void assertInsertStatement(final SQLCaseAssertContext assertContext, final DorisAlterJobStatement actual, final DorisAlterJobStatementTestCase expected) { | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/segment/policy/PolicyAssert.java | 63 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/type/DorisAlterWorkloadGroupStatementAssert.java | 68 |
assertProperty(assertContext, actual.getProperties().get(i), expected.getProperties().get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final ExpectedCatalogProperty expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/type/DorisAlterColocateGroupStatementAssert.java | 75 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/type/DorisAlterWorkloadGroupStatementAssert.java | 68 |
assertProperty(assertContext, actual.getProperties().get(i), expected.getProperties().get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final ExpectedCatalogProperty expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateIndexStatementAssert.java | 127 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/DropIndexStatementAssert.java | 86 |
private static void assertAlgorithm(final SQLCaseAssertContext assertContext, final CreateIndexStatement actual, final CreateIndexStatementTestCase expected) {
if (null == expected.getAlgorithmOption()) {
assertFalse(actual.getAlgorithmType().isPresent(), assertContext.getText("Actual algorithm segments should not exist."));
} else {
assertTrue(actual.getAlgorithmType().isPresent(), assertContext.getText("Actual algorithm segments should exist."));
assertThat(assertContext.getText(String.format("`%s`'s algorithm assertion error: ", actual.getClass().getSimpleName())),
actual.getAlgorithmType().get().getAlgorithmOption().name(), is(expected.getAlgorithmOption().getType()));
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCheckTabletStatementAssert.java | 53 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCopyTabletStatementAssert.java | 50 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetPartitionVersionStatementAssert.java | 55 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaStatusStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaVersionStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetTableStatusStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterSqlBlockRuleStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 106 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateRepositoryStatementAssert.java | 84 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateSqlBlockRuleStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateWorkloadGroupStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterTableStatementAssert.java | 206 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateFileStatementAssert.java | 78 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/DropFileStatementAssert.java | 78 |
assertProperty(assertContext, actual.getProperties().get(i), expected.getProperties().get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final ExpectedProperty expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCheckTabletStatementAssert.java | 53 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCopyTabletStatementAssert.java | 50 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetPartitionVersionStatementAssert.java | 55 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaStatusStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaVersionStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetTableStatusStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterSqlBlockRuleStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 106 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateRepositoryStatementAssert.java | 84 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateSqlBlockRuleStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateWorkloadGroupStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 276 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 177 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 66 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 86 |
assertProperty(assertContext, actual.getProperties().get().getProperties().get(i), expected.getProperties().get(i));
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/standard/type/DeleteStatementAssert.java | 137 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/standard/type/UpdateStatementAssert.java | 114 |
private static void assertLimitClause(final SQLCaseAssertContext assertContext, final DeleteStatement actual, final DeleteStatementTestCase expected) {
Optional<LimitSegment> limitSegment = actual.getLimit();
if (null == expected.getLimitClause()) {
assertFalse(limitSegment.isPresent(), assertContext.getText("Actual limit segment should not exist."));
} else {
assertTrue(limitSegment.isPresent(), assertContext.getText("Actual limit segment should exist."));
LimitClauseAssert.assertRowCount(assertContext, limitSegment.get().getRowCount().orElse(null), expected.getLimitClause().getRowCount());
SQLSegmentAssert.assertIs(assertContext, limitSegment.get(), expected.getLimitClause());
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/segment/policy/PolicyAssert.java | 59 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterTableStatementAssert.java | 202 |
public static void assertProperties(final SQLCaseAssertContext assertContext, final PropertiesSegment actual, final ExpectedCatalogProperties expected) {
SQLSegmentAssert.assertIs(assertContext, actual, expected);
assertThat(assertContext.getText("Properties size assertion error: "), actual.getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().get(i), expected.getProperties().get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final ExpectedCatalogProperty expected) { | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 131 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 82 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 57 |
assertProperty(assertContext, actual.get(i), expected.get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/type/DorisAlterColocateGroupStatementAssert.java | 71 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterTableStatementAssert.java | 202 |
private static void assertProperties(final SQLCaseAssertContext assertContext, final PropertiesSegment actual, final ExpectedCatalogProperties expected) {
SQLSegmentAssert.assertIs(assertContext, actual, expected);
assertThat(assertContext.getText("Properties size assertion error: "), actual.getProperties().size(), is(expected.getProperties().size()));
for (int i = 0; i < expected.getProperties().size(); i++) {
assertProperty(assertContext, actual.getProperties().get(i), expected.getProperties().get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final ExpectedCatalogProperty expected) { | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/mysql/type/MySQLShowTableStatusStatementAssert.java | 42 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/mysql/type/MySQLShowTablesStatementAssert.java | 42 |
public static void assertIs(final SQLCaseAssertContext assertContext, final MySQLShowTableStatusStatement actual, final MySQLShowTableStatusStatementTestCase expected) {
if (actual.getFromDatabase().isPresent()) {
DatabaseAssert.assertIs(assertContext, actual.getFromDatabase().get().getDatabase(), expected.getFromDatabase().getDatabase());
SQLSegmentAssert.assertIs(assertContext, actual.getFromDatabase().get(), expected.getFromDatabase());
}
if (actual.getFilter().isPresent()) {
ShowFilterAssert.assertIs(assertContext, actual.getFilter().get(), expected.getFilter());
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateFunctionStatementAssert.java | 66 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisDropFunctionStatementAssert.java | 54 |
private static void assertFunctionName(final SQLCaseAssertContext assertContext, final DorisCreateFunctionStatement actual, final CreateFunctionStatementTestCase expected) {
if (null != expected.getFunctionName()) {
assertTrue(actual.getFunctionName().isPresent(), assertContext.getText("Function name should not be null"));
assertThat(assertContext.getText("Function name assertion error: "),
actual.getFunctionName().get().getIdentifier().getValue(), is(expected.getFunctionName().getName()));
SQLSegmentAssert.assertIs(assertContext, actual.getFunctionName().get(), expected.getFunctionName());
}
}
private static void assertGlobal(final SQLCaseAssertContext assertContext, final DorisCreateFunctionStatement actual, final CreateFunctionStatementTestCase expected) { | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/alter/type/AlterShadowRuleStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/rdl/create/type/CreateShadowRuleStatementAssert.java | 54 |
assertShadowRule(assertContext, actual.getRules(), expected.getRules());
}
}
private static void assertShadowRule(final SQLCaseAssertContext assertContext, final Collection<ShadowRuleSegment> actual, final List<ExpectedShadowRule> expected) {
if (null == expected) {
assertNull(actual, assertContext.getText("Actual shadow rule should not exist."));
} else {
assertNotNull(actual, assertContext.getText("Actual shadow rule should exist."));
int count = 0;
for (ShadowRuleSegment each : actual) {
ShadowRuleAssert.assertIs(assertContext, each, expected.get(count));
count++;
}
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dcl/dialect/sqlserver/type/SQLServerAlterLoginStatementAssert.java | 45 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dcl/dialect/sqlserver/type/SQLServerCreateLoginStatementAssert.java | 45 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dcl/dialect/sqlserver/type/SQLServerDropLoginStatementAssert.java | 45 |
public static void assertIs(final SQLCaseAssertContext assertContext, final SQLServerAlterLoginStatement actual, final SQLServerAlterLoginStatementTestCase expected) {
if (null == expected.getLogin()) {
assertNull(actual.getLoginSegment(), assertContext.getText("Actual login should not exist."));
} else {
assertNotNull(actual.getLoginSegment(), assertContext.getText("Actual login should exist."));
assertThat(assertContext.getText("Login name assertion error: "), actual.getLoginSegment().getLoginName().getValueWithQuoteCharacters(), is(expected.getLogin().getName()));
SQLSegmentAssert.assertIs(assertContext, actual.getLoginSegment(), expected.getLogin());
}
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 131 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 173 |
assertProperty(assertContext, actual.get(i), expected.get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 82 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 173 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterTableStatementAssert.java | 207 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateIndexStatementAssert.java | 87 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final ExpectedProperty expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
private static void assertSetSchemaDefinition(final SQLCaseAssertContext assertContext, final AlterTableStatement actual, final AlterTableStatementTestCase expected) { | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 57 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 173 |
assertProperty(assertContext, actual.getProperties().getProperties().get(i), expected.getProperties().get(i));
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCheckTabletStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 87 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCopyTabletStatementAssert.java | 51 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetPartitionVersionStatementAssert.java | 56 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaStatusStatementAssert.java | 52 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaVersionStatementAssert.java | 52 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetTableStatusStatementAssert.java | 55 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterSqlBlockRuleStatementAssert.java | 55 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 107 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateRepositoryStatementAssert.java | 85 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateSqlBlockRuleStatementAssert.java | 55 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateWorkloadGroupStatementAssert.java | 55 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCheckTabletStatementAssert.java | 55 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 97 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 88 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminCopyTabletStatementAssert.java | 52 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetPartitionVersionStatementAssert.java | 57 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaStatusStatementAssert.java | 53 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetReplicaVersionStatementAssert.java | 53 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAdminSetTableStatusStatementAssert.java | 56 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisAlterSqlBlockRuleStatementAssert.java | 56 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisBackupStatementAssert.java | 108 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateRepositoryStatementAssert.java | 86 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateSqlBlockRuleStatementAssert.java | 56 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dal/dialect/doris/type/DorisCreateWorkloadGroupStatementAssert.java | 56 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
}
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 67 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 96 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 277 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 178 |
}
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisAlterJobStatementAssert.java | 68 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/AlterDatabaseStatementAssert.java | 83 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateDatabaseStatementAssert.java | 58 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateStreamingJobStatementAssert.java | 132 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 278 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 179 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateFileStatementAssert.java | 79 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateIndexStatementAssert.java | 87 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final ExpectedProperty expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/CreateIndexStatementAssert.java | 87 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/standard/type/DropFileStatementAssert.java | 79 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final ExpectedProperty expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisBrokerLoadStatementAssert.java | 278 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/mysql/type/MySQLLoadDataStatementAssert.java | 174 |
}
}
private static void assertProperty(final SQLCaseAssertContext assertContext, final PropertySegment actual, final PropertyTestCase expected) {
assertThat(assertContext.getText(String.format("Property key '%s' assertion error: ", expected.getKey())), actual.getKey(), is(expected.getKey()));
assertThat(assertContext.getText(String.format("Property value for key '%s' assertion error: ", expected.getKey())), actual.getValue(), is(expected.getValue()));
SQLSegmentAssert.assertIs(assertContext, actual, expected);
} | |
| File | Line |
|---|---|
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/dialect/doris/DorisCreateSyncJobStatementAssert.java | 56 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisAlterRoutineLoadStatementAssert.java | 54 |
| org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/dml/dialect/doris/DorisCreateRoutineLoadStatementAssert.java | 73 |
private static void assertJobName(final SQLCaseAssertContext assertContext, final DorisCreateSyncJobStatement actual, final DorisCreateSyncJobStatementTestCase expected) {
if (actual.getJobName().isPresent()) {
assertThat(assertContext.getText("Job name does not match: "), actual.getJobName().get().getIdentifier().getValue(), is(expected.getJobName()));
if (null != expected.getOwner()) {
OwnerAssert.assertIs(assertContext, actual.getJobName().get().getOwner().orElse(null), expected.getOwner());
}
}
}
private static void assertChannelDescriptions(final SQLCaseAssertContext assertContext, final DorisCreateSyncJobStatement actual, final DorisCreateSyncJobStatementTestCase expected) { | |
