Merge pull request #135 from data-integrations/bugfix/CDAP-17566-mssql-emit-metrics-schemaname

[CDAP-17566] Emit schemaName as part of the events in sqlserver

Author: elfenheart

sqlserver-delta-plugins/src/main/java/io/cdap/delta/sqlserver/SqlServerRecordConsumer.java

@@ -164,13 +164,17 @@ public void accept(SourceRecord sourceRecord) {
         // try to always drop the table before snapshot the schema.
         emitter.emit(builder.setOperation(DDLOperation.Type.DROP_TABLE)
                        .setTableName(tableName)
+                       .setSchemaName(schemaName)
                        .build());
 
         // try to emit create database event before create table event
-        emitter.emit(builder.setOperation(DDLOperation.Type.CREATE_DATABASE).build());
+        emitter.emit(builder.setOperation(DDLOperation.Type.CREATE_DATABASE)
+                       .setSchemaName(schemaName)
+                       .build());
 
         emitter.emit(builder.setOperation(DDLOperation.Type.CREATE_TABLE)
                        .setTableName(tableName)
+                       .setSchemaName(schemaName)
                        .setSchema(schema)
                        .setPrimaryKey(primaryFields)
                        .build());
@@ -191,6 +195,7 @@ public void accept(SourceRecord sourceRecord) {
       .setOffset(latestOffset)
       .setOperationType(op)
       .setDatabaseName(databaseName)
+      .setSchemaName(schemaName)
       .setTableName(tableName)
       .setRow(value)
       .setSnapshot(isSnapshot)