@Test
public void shouldReturnFailureForInvalidInsert() {

  assertThat(databaseInsertFunction(databaseSupplier)
          .apply(sqlInsertRequest()
              .table(INVALID_TABLE)
              .emptyColumn("column")
              .compile()).getFailure(),
      instanceOf(SQLException.class));
}