### Question:
JDBCSagaPersistence implements PersistentStore { public void createTableIfNotExists() { Collection<String> sqls = SQLFileReader.readSQLs(); if (0 == sqls.size()) { return; } try (Connection connection = dataSource.getConnection()) { for (String each : sqls) { JDBCUtil.executeUpdate(connection, each, Lists.newArrayList()); } } catch (SQLException ex) { throw new ShardingException("Create saga persistence table failed", ex); } } JDBCSagaPersistence(final DataSource dataSource); void createTableIfNotExists(); @Override Map<String, List<EventEnvelope>> findPendingSagaEvents(); @Override void offer(final SagaEvent sagaEvent);  }### Answer:
@Test @SneakyThrows public void assertCreateTableIfNotExists() { sagaPersistence.createTableIfNotExists(); verify(statement, times(4)).executeUpdate(); }