class PostgresCreateTask implements IDatabaseTask {

    @Override
    public void prepare(final IObject query) throws TaskPrepareException {
        try {
            CreateCollectionMessage message = IOC.resolve(Keys.getOrAdd(CreateCollectionMessage.class.getCanonicalName()), query);
            collection = message.getCollectionName();
            options = message.getOptions();
            preparedQuery = new QueryStatement();
            PostgresSchema.create(preparedQuery, collection, options);
        } catch (Exception e) {
            throw new TaskPrepareException(e);
        }
    }

    public  PostgresCreateTask(final IStorageConnection connection);

}