### Question:
JDBCSink extends NamedSink { String generateInsertStatement(Row entries) { return "INSERT INTO " + this.targetTable + " (" + columnList(entries) + ") VALUES (" + valueList(entries) + ")"; } JDBCSink();   JDBCSink(UnmanagedConnectionProvider connection, String table); @Override void init(); @Override void processRow(Row columns); @Override void close(); @Override int hashCode(); @Override boolean equals(Object obj);  }### Answer:
@Test public void generateInsertStatement() { String expected = "INSERT INTO TARGET_TABLE (a,b) VALUES ('java','tengah')"; Row row = getEntries(); String actual = this.cut.generateInsertStatement(row); assertThat(actual, is(expected)); }