Statements { public String getInsertTaskStatement() { return QueryBuilder.insertInto(keyspace, TABLE_WORKFLOWS) .value(WORKFLOW_ID_KEY, bindMarker()) .value(SHARD_ID_KEY, bindMarker()) .value(TASK_ID_KEY, bindMarker()) .value(ENTITY_KEY, ENTITY_TYPE_TASK) .value(PAYLOAD_KEY, bindMarker()) .getQueryString(); } @Inject  Statements(CassandraConfiguration config); String getInsertWorkflowDefStatement(); String getInsertWorkflowDefVersionIndexStatement(); String getInsertTaskDefStatement(); String getSelectWorkflowDefStatement(); String getSelectAllWorkflowDefVersionsByNameStatement(); String getSelectAllWorkflowDefsStatement(); String getSelectTaskDefStatement(); String getSelectAllTaskDefsStatement(); String getUpdateWorkflowDefStatement(); String getDeleteWorkflowDefStatement(); String getDeleteWorkflowDefIndexStatement(); String getDeleteTaskDefStatement(); String getInsertWorkflowStatement(); String getInsertTaskStatement(); String getInsertEventExecutionStatement(); String getSelectTotalStatement(); String getSelectTaskStatement(); String getSelectWorkflowStatement(); String getSelectWorkflowWithTasksStatement(); String getSelectTaskFromLookupTableStatement(); String getSelectTasksFromTaskDefLimitStatement(); String getSelectAllEventExecutionsForMessageFromEventExecutionsStatement(); String getUpdateWorkflowStatement(); String getUpdateTotalTasksStatement(); String getUpdateTotalPartitionsStatement(); String getUpdateTaskLookupStatement(); String getUpdateTaskDefLimitStatement(); String getUpdateEventExecutionStatement(); String getDeleteWorkflowStatement(); String getDeleteTaskLookupStatement(); String getDeleteTaskStatement(); String getDeleteTaskDefLimitStatement(); String getDeleteEventExecutionsStatement(); String getInsertEventHandlerStatement(); String getSelectAllEventHandlersStatement(); String getDeleteEventHandlerStatement();  }
@Test public void testGetInsertTaskStatement() { String statement = "INSERT INTO junit.workflows (workflow_id,shard_id,task_id,entity,payload) VALUES (?,?,?,'task',?);"; assertEquals(statement, statements.getInsertTaskStatement()); }