|
|
|
@ -16,17 +16,23 @@ |
|
|
|
package org.thingsboard.server.dao.sql.tenant; |
|
|
|
|
|
|
|
import com.datastax.oss.driver.api.core.uuid.Uuids; |
|
|
|
import com.github.springtestdbunit.annotation.DatabaseSetup; |
|
|
|
import org.junit.After; |
|
|
|
import org.junit.Before; |
|
|
|
import org.junit.Test; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.thingsboard.server.common.data.Tenant; |
|
|
|
import org.thingsboard.server.common.data.TenantProfile; |
|
|
|
import org.thingsboard.server.common.data.id.TenantId; |
|
|
|
import org.thingsboard.server.common.data.page.PageData; |
|
|
|
import org.thingsboard.server.common.data.page.PageLink; |
|
|
|
import org.thingsboard.server.dao.AbstractJpaDaoTest; |
|
|
|
import org.thingsboard.server.dao.service.AbstractServiceTest; |
|
|
|
import org.thingsboard.server.dao.service.BaseTenantProfileServiceTest; |
|
|
|
import org.thingsboard.server.dao.tenant.TenantDao; |
|
|
|
import org.thingsboard.server.dao.tenant.TenantProfileDao; |
|
|
|
|
|
|
|
import java.util.ArrayList; |
|
|
|
import java.util.List; |
|
|
|
import java.util.UUID; |
|
|
|
|
|
|
|
import static org.assertj.core.api.Assertions.assertThat; |
|
|
|
@ -40,8 +46,26 @@ public class JpaTenantDaoTest extends AbstractJpaDaoTest { |
|
|
|
@Autowired |
|
|
|
private TenantDao tenantDao; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private TenantProfileDao tenantProfileDao; |
|
|
|
|
|
|
|
List<Tenant> createdTenants = new ArrayList<>(); |
|
|
|
TenantProfile tenantProfile; |
|
|
|
|
|
|
|
@Before |
|
|
|
public void setUp() throws Exception { |
|
|
|
tenantProfile = tenantProfileDao.save(TenantId.SYS_TENANT_ID, BaseTenantProfileServiceTest.createTenantProfile("default tenant profile")); |
|
|
|
assertThat(tenantProfile).as("tenant profile").isNotNull(); |
|
|
|
} |
|
|
|
|
|
|
|
@After |
|
|
|
public void tearDown() throws Exception { |
|
|
|
createdTenants.forEach((tenant)-> tenantDao.removeById(TenantId.SYS_TENANT_ID, tenant.getUuidId())); |
|
|
|
tenantProfileDao.removeById(TenantId.SYS_TENANT_ID, tenantProfile.getUuidId()); |
|
|
|
} |
|
|
|
|
|
|
|
@Test |
|
|
|
@DatabaseSetup("classpath:dbunit/empty_dataset.xml") |
|
|
|
//@DatabaseSetup("classpath:dbunit/empty_dataset.xml")
|
|
|
|
public void testFindTenantsByRegion() { |
|
|
|
createTenants(); |
|
|
|
assertEquals(60, tenantDao.find(AbstractServiceTest.SYSTEM_TENANT_ID).size()); |
|
|
|
@ -51,12 +75,12 @@ public class JpaTenantDaoTest extends AbstractJpaDaoTest { |
|
|
|
assertEquals(20, tenants1.getData().size()); |
|
|
|
|
|
|
|
pageLink = pageLink.nextPageLink(); |
|
|
|
PageData<Tenant> tenants2 = tenantDao.findTenantsByRegion(AbstractServiceTest.SYSTEM_TENANT_ID,"REGION_1", |
|
|
|
PageData<Tenant> tenants2 = tenantDao.findTenantsByRegion(AbstractServiceTest.SYSTEM_TENANT_ID, "REGION_1", |
|
|
|
pageLink); |
|
|
|
assertEquals(10, tenants2.getData().size()); |
|
|
|
|
|
|
|
pageLink = pageLink.nextPageLink(); |
|
|
|
PageData<Tenant> tenants3 = tenantDao.findTenantsByRegion(AbstractServiceTest.SYSTEM_TENANT_ID,"REGION_1", |
|
|
|
PageData<Tenant> tenants3 = tenantDao.findTenantsByRegion(AbstractServiceTest.SYSTEM_TENANT_ID, "REGION_1", |
|
|
|
pageLink); |
|
|
|
assertEquals(0, tenants3.getData().size()); |
|
|
|
} |
|
|
|
@ -68,16 +92,17 @@ public class JpaTenantDaoTest extends AbstractJpaDaoTest { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
private void createTenant(String region, String title, int index) { |
|
|
|
void createTenant(String region, String title, int index) { |
|
|
|
Tenant tenant = new Tenant(); |
|
|
|
tenant.setId(new TenantId(Uuids.timeBased())); |
|
|
|
tenant.setRegion(region); |
|
|
|
tenant.setTitle(title + "_" + index); |
|
|
|
tenantDao.save(AbstractServiceTest.SYSTEM_TENANT_ID, tenant); |
|
|
|
tenant.setTenantProfileId(tenantProfile.getId()); |
|
|
|
createdTenants.add(tenantDao.save(TenantId.SYS_TENANT_ID, tenant)); |
|
|
|
} |
|
|
|
|
|
|
|
@Test |
|
|
|
@DatabaseSetup("classpath:dbunit/empty_dataset.xml") |
|
|
|
//@DatabaseSetup("classpath:dbunit/empty_dataset.xml")
|
|
|
|
public void testIsExistsTenantById() { |
|
|
|
final UUID uuid = Uuids.timeBased(); |
|
|
|
final TenantId tenantId = new TenantId(uuid); |
|
|
|
@ -86,9 +111,12 @@ public class JpaTenantDaoTest extends AbstractJpaDaoTest { |
|
|
|
final Tenant tenant = new Tenant(); |
|
|
|
tenant.setId(tenantId); |
|
|
|
tenant.setTitle("Tenant " + uuid); |
|
|
|
tenantDao.save(AbstractServiceTest.SYSTEM_TENANT_ID, tenant); |
|
|
|
tenant.setTenantProfileId(tenantProfile.getId()); |
|
|
|
|
|
|
|
createdTenants.add(tenantDao.save(TenantId.SYS_TENANT_ID, tenant)); |
|
|
|
|
|
|
|
assertThat(tenantDao.existsById(tenantId, uuid)).as("Is tenant exists after save").isTrue(); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|