@Test
public void shouldReturnErrorForFailedDatabaseCreationInInsert() throws Throwable {

  assertThat(databaseInsertFunction(FAILURE)
          .apply(sqlInsertRequest()
              .table(TABLE)
              .column("column", "value")
              .compile()).failed(),
      is(true));
}