Package dev.henneberger.vertx.sqlserver.replication

Class SqlServerChangeEvent

java.lang.Object

dev.henneberger.vertx.sqlserver.replication.SqlServerChangeEvent

public final class SqlServerChangeEvent
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	SqlServerChangeEvent.Operation

Constructor Summary

Constructors

Constructor	Description
SqlServerChangeEvent(String captureInstance, SqlServerChangeEvent.Operation operation, Map<String,Object> before, Map<String,Object> after, String commitLsn, Instant commitTimestamp, Map<String,Object> metadata)

Method Summary

Modifier and Type	Method	Description
io.vertx.core.json.JsonObject	afterJson()
io.vertx.core.json.JsonObject	beforeJson()
BigDecimal	decimal(String field)
Double	doubleValue(String field)
Map<String,Object>	getAfter()
Map<String,Object>	getBefore()
String	getCaptureInstance()
String	getCommitLsn()
Instant	getCommitTimestamp()
Map<String,Object>	getMetadata()
SqlServerChangeEvent.Operation	getOperation()
Integer	integer(String field)
Long	longValue(String field)
Map<String,Object>	rowOrBefore()
String	string(String field)
String	stringFromAfter(String field)
String	stringFromBefore(String field)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SqlServerChangeEvent

public SqlServerChangeEvent(String captureInstance,
 SqlServerChangeEvent.Operation operation,
 Map<String,Object> before,
 Map<String,Object> after,
 String commitLsn,
 Instant commitTimestamp,
 Map<String,Object> metadata)

Method Details

getCaptureInstance

public String getCaptureInstance()

getOperation

public SqlServerChangeEvent.Operation getOperation()

getBefore

public Map<String,Object> getBefore()

getAfter

public Map<String,Object> getAfter()

getCommitLsn

public String getCommitLsn()

getCommitTimestamp

public Instant getCommitTimestamp()

getMetadata

public Map<String,Object> getMetadata()

afterJson

public io.vertx.core.json.JsonObject afterJson()

beforeJson

public io.vertx.core.json.JsonObject beforeJson()

rowOrBefore

public Map<String,Object> rowOrBefore()

string

public String string(String field)

integer

public Integer integer(String field)

longValue

public Long longValue(String field)

doubleValue

public Double doubleValue(String field)

decimal

public BigDecimal decimal(String field)

stringFromAfter

public String stringFromAfter(String field)

stringFromBefore

public String stringFromBefore(String field)