SeataATShardingTransactionManager implements ShardingTransactionManager { @Override public TransactionType getTransactionType() { return TransactionType.BASE; } SeataATShardingTransactionManager(); @Override void init(final DatabaseType databaseType, final Collection<ResourceDataSource> resourceDataSources); @Override TransactionType getTransactionType(); @Override boolean isInTransaction(); @Override Connection getConnection(final String dataSourceName); @Override @SneakyThrows(TransactionException.class) void begin(); @Override @SneakyThrows(TransactionException.class) void commit(); @Override @SneakyThrows(TransactionException.class) void rollback(); @Override void close();  }
@Test public void assertInit() { Map<String, DataSource> actual = getDataSourceMap(); assertThat(actual.size(), is(1)); assertThat(actual.get("demo_ds"), instanceOf(DataSourceProxy.class)); assertThat(seataATShardingTransactionManager.getTransactionType(), is(TransactionType.BASE)); }