public DdlCommandResult execute(
      final String sql,
      final DdlCommand ddlCommand,
      final boolean withQuery,
      final Set<SourceName> withQuerySources
  ) {
    return execute(sql, ddlCommand, withQuery, withQuerySources, false);
  }
@Test
  public void shouldAddSourceTable() {
    // Given:
    final CreateTableCommand cmd = buildCreateTable(TABLE_NAME, false, true);

    // When:
    cmdExec.execute(SQL_TEXT, cmd, true, ImmutableSet.of(TABLE_NAME));

    // Then:
    final KsqlTable ksqlTable = (KsqlTable) metaStore.getSource(TABLE_NAME);
    assertThat(ksqlTable.isSource(), is(true));

    // Check query source was not added as constraints for source tables
    assertThat(metaStore.getSourceConstraints(TABLE_NAME), is(NO_QUERY_SOURCES));
  }