package jnpf.base.service;
|
|
import jnpf.base.mapper.UploadEditReadMapper;
|
import org.apache.ibatis.builder.xml.XMLMapperBuilder;
|
import org.apache.ibatis.datasource.unpooled.UnpooledDataSource;
|
import org.apache.ibatis.mapping.Environment;
|
import org.apache.ibatis.session.*;
|
import org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory;
|
import org.junit.*;
|
import java.util.*;
|
import static org.junit.Assert.*;
|
|
/** Executes the production XML on connection-local tables; no persistent business data is written. */
|
public class UploadEditReadMapperPostgresTest {
|
private SqlSession session;
|
private UploadEditReadMapper mapper;
|
@Before public void setup() throws Exception {
|
Assume.assumeTrue(System.getenv("DMS_READ_TEST_URL") != null);
|
var ds = new UnpooledDataSource("org.postgresql.Driver",System.getenv("DMS_READ_TEST_URL"),System.getenv("DMS_READ_TEST_USER"),System.getenv("DMS_READ_TEST_PASSWORD"));
|
var config = new Configuration(new Environment("read-test",new JdbcTransactionFactory(),ds));
|
String resource = "mapper/UploadEditReadMapper.xml";
|
try (var input = getClass().getClassLoader().getResourceAsStream(resource)) { new XMLMapperBuilder(input,config,resource,config.getSqlFragments()).parse(); }
|
session = new SqlSessionFactoryBuilder().build(config).openSession(false); mapper = session.getMapper(UploadEditReadMapper.class);
|
try (var s = session.getConnection().createStatement()) {
|
for(String table:List.of("dms_wenjian_xinzeng_shenhe","dms_wenjian_xiuding_shenhe")) {
|
s.execute("CREATE TEMP TABLE "+table+" ON COMMIT DROP AS SELECT f_id,f_tenant_id,f_delete_mark,f_flow_task_id,wenjian FROM public."+table+" WITH NO DATA");
|
s.execute("CREATE TEMP TABLE "+table+"_jilu_mingxi ON COMMIT DROP AS SELECT f_id,f_tenant_id,f_delete_mark,f_foreign_id,jilu_wenjian FROM public."+table+"_jilu_mingxi WITH NO DATA");
|
s.execute("INSERT INTO "+table+" VALUES ('record','tenant',NULL,'task','[{\"fileId\":\"main\"}]'),('other-record','tenant',NULL,'other-task','[]'),('deleted','tenant',1,'deleted-task','[]')");
|
s.execute("INSERT INTO "+table+"_jilu_mingxi VALUES ('row','tenant',NULL,'record','[{\"fileId\":\"child\"}]'),('foreign-row','tenant',NULL,'other-record','[]'),('deleted-row','tenant',1,'record','[]'),('foreign-tenant','other',NULL,'record','[]')");
|
}
|
for(String table:List.of("base_visual_release","base_visual_dev")) {
|
s.execute("CREATE TEMP TABLE "+table+" ON COMMIT DROP AS SELECT f_id,f_form_data,f_tables_data,f_column_data,f_db_link_id,f_delete_mark FROM public."+table+" WITH NO DATA");
|
s.execute("INSERT INTO "+table+" VALUES('model','{}','[]','{}','0',NULL),('deleted','{}','[]','{}','0',1)");
|
}
|
}
|
}
|
@After public void close() { if(session!=null) { try {session.rollback(true);} finally {session.close();} } }
|
@Test public void mainAndChildAliasRespectTenantDeletionAndParentRelationship() {
|
for(String table:List.of("dms_wenjian_xinzeng_shenhe","dms_wenjian_xiuding_shenhe")) {
|
assertEquals("record",mapper.dmsAttachment(table,"tenant","task",null).get("id"));
|
assertEquals("[{\"fileId\":\"main\"}]",mapper.dmsAttachment(table,"tenant","record",null).get("fileJson"));
|
assertEquals("[{\"fileId\":\"child\"}]",mapper.dmsAttachment(table,"tenant","task","row").get("fileJson"));
|
assertNull(mapper.dmsAttachment(table,"other","task",null));
|
assertNull(mapper.dmsAttachment(table,"tenant","deleted",null));
|
assertNull(mapper.dmsAttachment(table,"tenant","missing",null));
|
for(String row:List.of("foreign-row","deleted-row","foreign-tenant","missing"))
|
assertNull(mapper.dmsAttachment(table,"tenant","record",row).get("rowId"));
|
}
|
assertNull(mapper.dmsAttachment("workflow_task","tenant","record",null));
|
}
|
@Test public void definitionProjectionNeedsNoHistoryOrUnrelatedReleaseColumns() {
|
var model = mapper.releasedModel("model"); assertNotNull(model); assertEquals("model",model.getId());
|
assertEquals("{}",model.getFormData()); assertEquals("[]",model.getVisualTables()); assertEquals("0",model.getDbLinkId());
|
assertNull(mapper.releasedModel("deleted")); assertNull(mapper.designModel("deleted")); assertNotNull(mapper.designModel("model"));
|
}
|
}
|
