@Test(groups = SMALL)
public void testGenerateCreateTriggerCreatesTheCorrectQuery() {

    String query = PsqlQueryGenerator.generateCreateTriggerQuery("trigger_name", "table_name", "proc_name", "stream_name");
    String expected = String.format(
            "CREATE TRIGGER %s AFTER INSERT OR UPDATE OR DELETE ON %s FOR EACH ROW EXECUTE PROCEDURE %s('%s')",
            "trigger_name", "table_name", "proc_name", "stream_name");
    assertEquals(query, expected);
}