package jnpf.dmsMapper;
|
|
import jnpf.dmsDatabase.DmsJsonNodeTypeHandler;
|
import org.apache.ibatis.builder.xml.XMLMapperBuilder;
|
import org.apache.ibatis.session.Configuration;
|
import org.junit.jupiter.api.Test;
|
import java.util.Map;
|
import java.util.UUID;
|
import static org.junit.jupiter.api.Assertions.*;
|
|
class DmsVersionPropertiesMapperSqlTest {
|
@Test void versionPropertiesAreTenantScopedAndMappedAsJson() throws Exception {
|
Configuration config = new Configuration();
|
for (String name : new String[]{"DmsVersionPropertiesMapper", "DmsWenjianXinzengShenheMapper", "DmsWenjianXiudingShenheMapper"}) {
|
String path = "mapper/" + name + ".xml";
|
try (var in = getClass().getResourceAsStream("/" + path)) {
|
new XMLMapperBuilder(in, config, path, config.getSqlFragments()).parse();
|
}
|
}
|
var namespace = DmsVersionPropertiesMapper.class.getName();
|
var params = Map.of("tenantId", "tenant", "versionId", UUID.randomUUID(), "properties", "{}");
|
var find = config.getMappedStatement(namespace + ".find");
|
var mapping = find.getResultMaps().get(0).getResultMappings().stream()
|
.filter(m -> "extendedProperties".equals(m.getProperty())).findFirst().orElseThrow();
|
assertInstanceOf(DmsJsonNodeTypeHandler.class, mapping.getTypeHandler());
|
assertEquals("extended_properties", mapping.getColumn());
|
String findSql = find.getBoundSql(params).getSql();
|
assertTrue(findSql.contains("tenant_id = ?"));
|
assertTrue(findSql.contains("id = ?"));
|
var insert = config.getMappedStatement(namespace + ".insertVersion");
|
assertEquals(org.apache.ibatis.mapping.SqlCommandType.INSERT, insert.getSqlCommandType());
|
var version = new jnpf.dmsEntity.permission.entity.DmsFileVersionEntity();
|
String insertSql = insert.getBoundSql(Map.of("version", version, "properties", "{}")).getSql();
|
assertTrue(insertSql.contains("extended_properties"));
|
assertTrue(insertSql.contains("CAST(? AS jsonb)"));
|
assertFalse(config.hasStatement(namespace + ".initialize"));
|
for (String name : new String[]{"DmsWenjianXinzengShenheMapper", "DmsWenjianXiudingShenheMapper"}) {
|
var statement = config.getMappedStatement("jnpf.dmsMapper." + name + ".selectByFlowForUpdate");
|
assertTrue(statement.getResultMaps().get(0).getResultMappings().stream()
|
.anyMatch(m -> "shenhe_ren_id".equals(m.getColumn()) && "shenheRenId".equals(m.getProperty())));
|
}
|
}
|
}
|
