SqlResult execute(CreateMappingPlan plan, SqlSecurityContext ssc) {
        catalog.createMapping(plan.mapping(), plan.replace(), plan.ifNotExists(), ssc);
        return UpdateSqlResultImpl.createUpdateCountResult(0);
    }
@Test
    public void test_insertExecution() {
        // given
        QueryId queryId = QueryId.create(UuidUtil.newSecureUUID());
        DmlPlan plan = new DmlPlan(
                Operation.INSERT,
                planKey(),
                QueryParameterMetadata.EMPTY,
                emptySet(),
                dag,
                null,
                false,
                planExecutor,
                Collections.emptyList(),
                false,
                null
        );

        given(hazelcastInstance.getJet()).willReturn(jetInstance);
        given(jetInstance.newLightJob(eq(dag), isA(JobConfig.class), eq(null)))
                .willReturn(job);

        // when
        SqlResult result = planExecutor.execute(plan, queryId, emptyList(), 0L, INSTANCE);

        // then
        assertThat(result.updateCount()).isEqualTo(0);
        verify(job).join();
    }