@Test
public void testCreate() {

    this.dsId = metadata.commit(() -> {
        DataSource ds = null;
        for (int i = 1; i <= COUNT + 1; i++) {
            ds = createDataSource(i);
        }
        return ds.getId();
    }, MetadataAccess.SERVICE);
    
    metadata.read(() -> {
        Optional<DataSource> ds = this.dsProvider.find(this.dsId);
        
        assertThat(ds).isNotNull().isPresent();
        assertThat(ds.get()).extracting("systemName", "title", "description").contains(dsTuple(COUNT + 1).toArray());
        assertThat(ds.get().getConnector()).isNotNull().extracting("id").contains(this.connId);
    }, MetadataAccess.SERVICE);
}