Skip to content

Commit 2feb56c

Browse files
committed
[ksqlDb.RestApi.Client]: added the IgnoreInDDL function to the Fluent API tests #93
1 parent 54109ae commit 2feb56c

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

Tests/ksqlDB.RestApi.Client.IntegrationTests/KSql/Linq/ModelBuilderTests.cs

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@
66
using ksqlDB.RestApi.Client.KSql.Linq;
77
using ksqlDB.RestApi.Client.KSql.RestApi;
88
using ksqlDB.RestApi.Client.KSql.RestApi.Enums;
9-
using ksqlDB.RestApi.Client.KSql.RestApi.Extensions;
109
using ksqlDB.RestApi.Client.KSql.RestApi.Http;
1110
using ksqlDB.RestApi.Client.KSql.RestApi.Statements;
1211
using ksqlDB.RestApi.Client.KSql.RestApi.Statements.Properties;
@@ -105,7 +104,7 @@ public static async Task ClassCleanup()
105104
UseIfExistsClause = true,
106105
DeleteTopic = true,
107106
};
108-
await kSqlDbRestApiClient.DropStreamAsync<Models.Tweet>(dropFromItemProperties);
107+
await kSqlDbRestApiClient.DropStreamAsync<Tweet>(dropFromItemProperties);
109108
}
110109

111110
[SetUp]
@@ -128,13 +127,16 @@ public async Task Select()
128127
var source = QuerySource
129128
.ToAsyncEnumerable();
130129

130+
var tweet1 = Tweet1 with { RowTime = 0 };
131+
var tweet2 = Tweet2 with { RowTime = 0 };
132+
131133
//Act
132134
var actualValues = await CollectActualValues(source, expectedItemsCount);
133135

134136
//Assert
135137
var expectedValues = new List<Tweet>
136138
{
137-
Tweet1, Tweet2
139+
tweet1, tweet2
138140
};
139141

140142
expectedItemsCount.Should().Be(actualValues.Count);

Tests/ksqlDB.RestApi.Client.Tests/KSql/RestApi/Statements/CreateEntityTests.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -784,7 +784,7 @@ public void Print_IgnoreInDDLAttribute()
784784
string statement = new CreateEntity(modelBuilder).Print<IgnoreInDDL>(statementContext, creationMetadata, null);
785785

786786
//Assert
787-
statement.Should().Be($@"CREATE OR REPLACE TABLE {nameof(IgnoreInDDL)}s (
787+
statement.Should().Be($@"CREATE OR REPLACE TABLE {nameof(IgnoreInDDL)}S (
788788
{nameof(IgnoreInDDL.Id)} INT PRIMARY KEY
789789
) WITH ( KAFKA_TOPIC='{nameof(IgnoreInDDL)}', VALUE_FORMAT='Json', PARTITIONS='1', REPLICAS='1' );".ReplaceLineEndings());
790790
}

0 commit comments

Comments
 (0)