Skip to content

Commit b994fd6

Browse files
tomasfabiantomasfabian
committed
[ksqlDB.RestApi.Client]: SqlServer.Connector.Tests project file scoped namespaces
1 parent af5661a commit b994fd6

File tree

10 files changed

+696
-537
lines changed

10 files changed

+696
-537
lines changed

‎Tests/SqlServer.Connector.Tests/Cdc/CdcClientTests.cs

Lines changed: 95 additions & 96 deletions
Original file line numberDiff line numberDiff line change
@@ -9,139 +9,138 @@
99
using UnitTests;
1010
using ConfigurationProvider = SqlServer.Connector.Tests.Config.ConfigurationProvider;
1111

12-
namespace SqlServer.Connector.Tests.Cdc
12+
namespace SqlServer.Connector.Tests.Cdc;
13+
14+
[TestClass]
15+
[TestCategory("Integration")]
16+
public class CdcClientTests : TestBase<CdcClient>
1317
{
14-
[TestClass]
15-
[TestCategory("Integration")]
16-
public class CdcClientTests : TestBase<CdcClient>
18+
[ClassInitialize]
19+
public static async Task ClassInitialize(TestContext context)
1720
{
18-
[ClassInitialize]
19-
public static async Task ClassInitialize(TestContext context)
20-
{
21-
var dbContext = new ApplicationDbContext();
21+
var dbContext = new ApplicationDbContext();
2222

23-
await dbContext.Database.EnsureDeletedAsync();
23+
await dbContext.Database.EnsureDeletedAsync();
2424

25-
await dbContext.Database.MigrateAsync();
26-
}
25+
await dbContext.Database.MigrateAsync();
26+
}
2727

28-
private static readonly IConfiguration Configuration = ConfigurationProvider.CreateConfiguration();
28+
private static readonly IConfiguration Configuration = ConfigurationProvider.CreateConfiguration();
2929

30-
[ClassCleanup]
31-
public static async Task ClassCleanup()
32-
{
33-
var dbContext = new ApplicationDbContext();
30+
[ClassCleanup]
31+
public static async Task ClassCleanup()
32+
{
33+
var dbContext = new ApplicationDbContext();
3434

35-
await dbContext.Database.EnsureDeletedAsync();
36-
}
35+
await dbContext.Database.EnsureDeletedAsync();
36+
}
3737

38-
static string ConnectionString => Configuration.GetConnectionString("DefaultConnection");
38+
static string ConnectionString => Configuration.GetConnectionString("DefaultConnection");
3939

40-
readonly SqlConnectionStringBuilder connectionStringBuilder = new(ConnectionString);
40+
readonly SqlConnectionStringBuilder connectionStringBuilder = new(ConnectionString);
4141

42-
[TestInitialize]
43-
public override void TestInitialize()
44-
{
45-
base.TestInitialize();
42+
[TestInitialize]
43+
public override void TestInitialize()
44+
{
45+
base.TestInitialize();
4646

47-
ClassUnderTest = new CdcClient(ConnectionString);
48-
}
47+
ClassUnderTest = new CdcClient(ConnectionString);
48+
}
4949

50-
[TestMethod]
51-
public async Task CdcEnableDbAsync()
52-
{
53-
//Arrange
54-
string databaseName = connectionStringBuilder.InitialCatalog;
50+
[TestMethod]
51+
public async Task CdcEnableDbAsync()
52+
{
53+
//Arrange
54+
string databaseName = connectionStringBuilder.InitialCatalog;
5555

56-
//Act
57-
await ClassUnderTest.CdcEnableDbAsync();
56+
//Act
57+
await ClassUnderTest.CdcEnableDbAsync();
5858

59-
var isEnabled = await ClassUnderTest.IsCdcDbEnabledAsync(databaseName);
59+
var isEnabled = await ClassUnderTest.IsCdcDbEnabledAsync(databaseName);
6060

61-
//Assert
62-
isEnabled.Should().Be(true);
63-
}
61+
//Assert
62+
isEnabled.Should().Be(true);
63+
}
6464

65-
[TestMethod]
66-
public async Task CdcEnableTableAsync()
67-
{
68-
//Arrange
65+
[TestMethod]
66+
public async Task CdcEnableTableAsync()
67+
{
68+
//Arrange
6969

70-
//Act
71-
await ClassUnderTest.CdcEnableTableAsync(tableName);
70+
//Act
71+
await ClassUnderTest.CdcEnableTableAsync(tableName);
7272

73-
var isEnabled = await ClassUnderTest.IsCdcTableEnabledAsync(tableName);
73+
var isEnabled = await ClassUnderTest.IsCdcTableEnabledAsync(tableName);
7474

75-
//Assert
76-
isEnabled.Should().Be(true);
77-
}
75+
//Assert
76+
isEnabled.Should().Be(true);
77+
}
7878

79-
string tableName = "Sensors";
79+
string tableName = "Sensors";
8080

81-
[TestMethod]
82-
public async Task CdcEnableTableAsync_CdcEnableTableInput()
83-
{
84-
//Arrange
85-
string captureInstance = $"dbo_{tableName}_v2";
81+
[TestMethod]
82+
public async Task CdcEnableTableAsync_CdcEnableTableInput()
83+
{
84+
//Arrange
85+
string captureInstance = $"dbo_{tableName}_v2";
8686

87-
var cdcEnableTable = new CdcEnableTable(tableName)
88-
{
89-
CaptureInstance = captureInstance
90-
};
87+
var cdcEnableTable = new CdcEnableTable(tableName)
88+
{
89+
CaptureInstance = captureInstance
90+
};
9191

92-
//Act
93-
await ClassUnderTest.CdcEnableTableAsync(cdcEnableTable);
92+
//Act
93+
await ClassUnderTest.CdcEnableTableAsync(cdcEnableTable);
9494

95-
var isEnabled = await ClassUnderTest.IsCdcTableEnabledAsync(tableName, captureInstance: captureInstance);
95+
var isEnabled = await ClassUnderTest.IsCdcTableEnabledAsync(tableName, captureInstance: captureInstance);
9696

97-
//Assert
98-
isEnabled.Should().Be(true);
99-
}
97+
//Assert
98+
isEnabled.Should().Be(true);
99+
}
100100

101-
[TestMethod]
102-
public async Task CdcDisableTableAsync_CaptureInstance()
103-
{
104-
//Arrange
105-
string captureInstance = $"dbo_{tableName}_v2";
101+
[TestMethod]
102+
public async Task CdcDisableTableAsync_CaptureInstance()
103+
{
104+
//Arrange
105+
string captureInstance = $"dbo_{tableName}_v2";
106106

107-
//Act
108-
await ClassUnderTest.CdcDisableTableAsync(tableName, captureInstance: captureInstance);
107+
//Act
108+
await ClassUnderTest.CdcDisableTableAsync(tableName, captureInstance: captureInstance);
109109

110-
var isEnabled = await ClassUnderTest.IsCdcTableEnabledAsync(tableName, captureInstance: captureInstance);
110+
var isEnabled = await ClassUnderTest.IsCdcTableEnabledAsync(tableName, captureInstance: captureInstance);
111111

112-
//Assert
113-
isEnabled.Should().Be(false);
114-
}
112+
//Assert
113+
isEnabled.Should().Be(false);
114+
}
115115

116-
[TestMethod]
117-
public async Task CdcDisableTableAsync()
118-
{
119-
//Arrange
116+
[TestMethod]
117+
public async Task CdcDisableTableAsync()
118+
{
119+
//Arrange
120120

121-
//Act
122-
await ClassUnderTest.CdcDisableTableAsync(tableName);
121+
//Act
122+
await ClassUnderTest.CdcDisableTableAsync(tableName);
123123

124-
var isEnabled = await ClassUnderTest.IsCdcTableEnabledAsync(tableName);
124+
var isEnabled = await ClassUnderTest.IsCdcTableEnabledAsync(tableName);
125125

126-
//Assert
127-
isEnabled.Should().Be(false);
128-
}
126+
//Assert
127+
isEnabled.Should().Be(false);
128+
}
129129

130-
[TestMethod]
131-
public async Task CdcDisableDbAsync()
132-
{
133-
//Arrange
134-
string databaseName = connectionStringBuilder.InitialCatalog;
130+
[TestMethod]
131+
public async Task CdcDisableDbAsync()
132+
{
133+
//Arrange
134+
string databaseName = connectionStringBuilder.InitialCatalog;
135135

136-
//Act
137-
await ClassUnderTest.CdcDisableDbAsync();
136+
//Act
137+
await ClassUnderTest.CdcDisableDbAsync();
138138

139-
//Assert
139+
//Assert
140140

141-
var isEnabled = await ClassUnderTest.IsCdcDbEnabledAsync(databaseName);
141+
var isEnabled = await ClassUnderTest.IsCdcDbEnabledAsync(databaseName);
142142

143-
//Assert
144-
isEnabled.Should().Be(false);
145-
}
143+
//Assert
144+
isEnabled.Should().Be(false);
146145
}
147146
}

‎Tests/SqlServer.Connector.Tests/Cdc/Connectors/ConnectorExtensionsTests.cs

Lines changed: 44 additions & 45 deletions
Original file line numberDiff line numberDiff line change
@@ -3,64 +3,64 @@
33
using SqlServer.Connector.Cdc.Connectors;
44
using UnitTests;
55

6-
namespace SqlServer.Connector.Tests.Cdc.Connectors
6+
namespace SqlServer.Connector.Tests.Cdc.Connectors;
7+
8+
[TestClass]
9+
public class ConnectorExtensionsTests : TestBase
710
{
8-
[TestClass]
9-
public class ConnectorExtensionsTests : TestBase
11+
private SqlServerConnectorMetadata CreateConnector()
1012
{
11-
private SqlServerConnectorMetadata CreateConnector()
12-
{
13-
string connectionString =
14-
"Server=127.0.0.1,1433;User Id = SA;Password=<YourNewStrong@Passw0rd>;Initial Catalog = Sensors;MultipleActiveResultSets=true";
13+
string connectionString =
14+
"Server=127.0.0.1,1433;User Id = SA;Password=<YourNewStrong@Passw0rd>;Initial Catalog = Sensors;MultipleActiveResultSets=true";
1515

16-
return new SqlServerConnectorMetadata(connectionString);
17-
}
16+
return new SqlServerConnectorMetadata(connectionString);
17+
}
1818

19-
string connectorName = "myConnector";
19+
string connectorName = "myConnector";
2020

21-
[TestMethod]
22-
public void ToCreateSourceConnectorStatement()
23-
{
24-
//Arrange
25-
var connector = CreateConnector();
21+
[TestMethod]
22+
public void ToCreateSourceConnectorStatement()
23+
{
24+
//Arrange
25+
var connector = CreateConnector();
2626

27-
//Act
28-
var statement = connector.ToCreateConnectorStatement(connectorName);
27+
//Act
28+
var statement = connector.ToCreateConnectorStatement(connectorName);
2929

30-
//Assert
31-
statement.Should().Be(ExpectedStatement("CREATE SOURCE CONNECTOR"));
32-
}
30+
//Assert
31+
statement.Should().Be(ExpectedStatement("CREATE SOURCE CONNECTOR"));
32+
}
3333

34-
[TestMethod]
35-
public void ToCreateSourceConnectorStatement_IfNotExists()
36-
{
37-
//Arrange
38-
var connector = CreateConnector();
34+
[TestMethod]
35+
public void ToCreateSourceConnectorStatement_IfNotExists()
36+
{
37+
//Arrange
38+
var connector = CreateConnector();
3939

40-
//Act
41-
var statement = connector.ToCreateConnectorStatement(connectorName, ifNotExists: true);
40+
//Act
41+
var statement = connector.ToCreateConnectorStatement(connectorName, ifNotExists: true);
4242

43-
//Assert
44-
statement.Should().Be(ExpectedStatement("CREATE SOURCE CONNECTOR IF NOT EXISTS"));
45-
}
43+
//Assert
44+
statement.Should().Be(ExpectedStatement("CREATE SOURCE CONNECTOR IF NOT EXISTS"));
45+
}
4646

47-
[TestMethod]
48-
public void ToCreateSinkConnectorStatement()
49-
{
50-
//Arrange
51-
var connector = CreateConnector();
52-
connector.ConnectorType = ConnectorType.Sink;
47+
[TestMethod]
48+
public void ToCreateSinkConnectorStatement()
49+
{
50+
//Arrange
51+
var connector = CreateConnector();
52+
connector.ConnectorType = ConnectorType.Sink;
5353

54-
//Act
55-
var statement = connector.ToCreateConnectorStatement(connectorName);
54+
//Act
55+
var statement = connector.ToCreateConnectorStatement(connectorName);
5656

57-
//Assert
58-
statement.Should().Be(ExpectedStatement("CREATE SINK CONNECTOR"));
59-
}
57+
//Assert
58+
statement.Should().Be(ExpectedStatement("CREATE SINK CONNECTOR"));
59+
}
6060

61-
private string ExpectedStatement(string create)
62-
{
63-
return @$"{create} {connectorName} WITH (
61+
private string ExpectedStatement(string create)
62+
{
63+
return @$"{create} {connectorName} WITH (
6464
'connector.class'= 'io.debezium.connector.sqlserver.SqlServerConnector',
6565
'database.port'= '1433',
6666
'database.hostname'= '127.0.0.1',
@@ -69,6 +69,5 @@ private string ExpectedStatement(string create)
6969
'database.dbname'= 'Sensors'
7070
);
7171
";
72-
}
7372
}
7473
}

0 commit comments

Comments
 (0)