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"));
    }
}