@@ -137,7 +137,7 @@ public void test() throws InterruptedException {
137137 Collections .emptySet (), Collections .emptySet (), Collections .emptySet ());
138138
139139 DeltaSourceContext context = new MockContext (SQLServerDriver .class );
140- MockEventEmitter eventEmitter = new MockEventEmitter (4 );
140+ MockEventEmitter eventEmitter = new MockEventEmitter (5 );
141141 SqlServerConfig config = new SqlServerConfig ("localhost" , port , "sa" , password ,
142142 DB , null , "mssql" );
143143
@@ -148,7 +148,7 @@ public void test() throws InterruptedException {
148148
149149 eventEmitter .waitForExpectedEvents (30 , TimeUnit .SECONDS );
150150
151- Assert .assertEquals (2 , eventEmitter .getDdlEvents ().size ());
151+ Assert .assertEquals (3 , eventEmitter .getDdlEvents ().size ());
152152 Assert .assertEquals (2 , eventEmitter .getDmlEvents ().size ());
153153
154154 DDLEvent ddlEvent = eventEmitter .getDdlEvents ().get (0 );
@@ -157,6 +157,10 @@ public void test() throws InterruptedException {
157157 Assert .assertEquals (CUSTOMERS_TABLE , ddlEvent .getTable ());
158158
159159 ddlEvent = eventEmitter .getDdlEvents ().get (1 );
160+ Assert .assertEquals (DDLOperation .CREATE_DATABASE , ddlEvent .getOperation ());
161+ Assert .assertEquals (DB , ddlEvent .getDatabase ());
162+
163+ ddlEvent = eventEmitter .getDdlEvents ().get (2 );
160164 Assert .assertEquals (DDLOperation .CREATE_TABLE , ddlEvent .getOperation ());
161165 Assert .assertEquals (DB , ddlEvent .getDatabase ());
162166 Assert .assertEquals (CUSTOMERS_TABLE , ddlEvent .getTable ());
0 commit comments