Skip to content

Commit fb31800

Browse files
committed
[ksqlDb.RestApi.Client]: added KSqlDBRestApiClientOptions ctor argument for KSqlDbRestApiClient adjusted unit tests
1 parent de77455 commit fb31800

File tree

2 files changed

+10
-9
lines changed

2 files changed

+10
-9
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ public void Init()
2525
{
2626
creationMetadata = new EntityCreationMetadata()
2727
{
28+
ShouldPluralizeEntityName = true,
2829
KafkaTopic = nameof(MyMovie),
2930
Partitions = 1,
3031
Replicas = 1

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

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -276,7 +276,7 @@ public void StringEnumerableMemberType()
276276
};
277277

278278
//Act
279-
string statement = new CreateInsert(modelBuilder).Generate(testEvent);
279+
string statement = new CreateInsert(modelBuilder).Generate(testEvent, new InsertProperties());
280280

281281
//Assert
282282
statement.Should().Be("INSERT INTO Events (Id, Places) VALUES (1, ARRAY['Place1', 'Place2', 'Place3']);");
@@ -513,7 +513,7 @@ public void FromEmptyList()
513513
var order = new Kafka_table_order2 { Id = 1, ItemsList = [] };
514514

515515
//Act
516-
string statement = new CreateInsert(modelBuilder).Generate(order);
516+
string statement = new CreateInsert(modelBuilder).Generate(order, new InsertProperties());
517517

518518
//Assert
519519
statement.Should().Be("INSERT INTO Kafka_table_order2s (Id, ItemsList) VALUES (1, ARRAY_REMOVE(ARRAY[0], 0));"); //ARRAY[] is not supported
@@ -526,7 +526,7 @@ public void FromNullList()
526526
var order = new Kafka_table_order2 { Id = 1, ItemsList = null };
527527

528528
//Act
529-
string statement = new CreateInsert(modelBuilder).Generate(order);
529+
string statement = new CreateInsert(modelBuilder).Generate(order, new InsertProperties());
530530

531531
//Assert
532532
statement.Should().Be("INSERT INTO Kafka_table_order2s (Id, ItemsList) VALUES (1, NULL);");
@@ -857,7 +857,7 @@ public void TimeTypes_DateAndTime()
857857
};
858858

859859
//Act
860-
string statement = new CreateInsert(modelBuilder).Generate(value);
860+
string statement = new CreateInsert(modelBuilder).Generate(value, new InsertProperties());
861861

862862
//Assert
863863
statement.Should().Be("INSERT INTO TimeTypes (Dt, Ts, DtOffset) VALUES ('2021-02-03', '02:03:04', '0001-01-01T00:00:00.000+00:00');");
@@ -878,7 +878,7 @@ public void TimeTypes_Timespan()
878878
};
879879

880880
//Act
881-
string statement = new CreateInsert(modelBuilder).Generate(value);
881+
string statement = new CreateInsert(modelBuilder).Generate(value, new InsertProperties());
882882

883883
//Assert
884884
statement.Should().Be("INSERT INTO TimeTypes (DtOffset) VALUES ('2021-07-04T13:29:45.447+04:00');");
@@ -917,7 +917,7 @@ public void Field()
917917
var value = new Update();
918918

919919
//Act
920-
string statement = new CreateInsert(modelBuilder).Generate(value);
920+
string statement = new CreateInsert(modelBuilder).Generate(value, new InsertProperties());
921921

922922
//Assert
923923
statement.Should().Be($"INSERT INTO Updates ({nameof(Update.ExtraField)}) VALUES ('{value.ExtraField}');");
@@ -994,7 +994,7 @@ public void Generate_FromInterface_WithNullInsertProperties_DoNotUseEntityType()
994994
};
995995

996996
//Act
997-
string statement = new CreateInsert(modelBuilder).Generate(value, insertProperties: null);
997+
string statement = new CreateInsert(modelBuilder).Generate(value, new InsertProperties());
998998

999999
//Assert
10001000
statement.Should().Be($"INSERT INTO {nameof(IMyUpdate)}s ({nameof(IMyUpdate.Field)}) VALUES ('{value.Field}');");
@@ -1011,7 +1011,7 @@ public void Generate_Enum()
10111011
};
10121012

10131013
//Act
1014-
string statement = new CreateInsert(modelBuilder).Generate(value, insertProperties: null);
1014+
string statement = new CreateInsert(modelBuilder).Generate(value, new InsertProperties());
10151015

10161016
//Assert
10171017
statement.Should().Be($"INSERT INTO {nameof(Port)}s ({nameof(Port.Id)}, {nameof(Port.PortType)}) VALUES (42, '{value.PortType}');");
@@ -1034,7 +1034,7 @@ public void Generate_Decimal_ShouldBePrinted()
10341034
};
10351035

10361036
//Act
1037-
string statement = new CreateInsert(modelBuilder).Generate(amount);
1037+
string statement = new CreateInsert(modelBuilder).Generate(amount, new InsertProperties());
10381038

10391039
//Assert
10401040
statement.Should().Be($"INSERT INTO {nameof(Amount)}s ({nameof(Amount.Volume).ToLower()}) VALUES ({amount.Volume});");

0 commit comments

Comments
 (0)