dev 契约锁

P15GEN2\59518

2024-05-29 d4210c7c4b04abde20037ea8aa0f54ef8a2649aa

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
package foundation.data.loader;
 
import foundation.dao.Filter;
import foundation.data.entity.Entity;
import foundation.data.entity.EntitySet;
import foundation.data.getter.EntitySetGetter;
import foundation.data.meta.template.PropertyTemplateBucket;
import foundation.data.object.DataJoin;
import foundation.data.object.DataJoins;
import foundation.data.object.DataObject;
import foundation.data.object.DataObjectContainer;
import foundation.persist.NamedSQL;
import foundation.persist.SQLRunner;
import foundation.server.Initializer;
 
public class DataObjectLoader extends Initializer {
 
    @Override
    public void startUp() throws Exception {
//        SQLRunner.formatOracleTables();
        
        //1. load data object
        loadDataObject();
        
        //2. load data object joins
        loadDataObjectJoins();
        
        //3. build data object
        buildDataObjects();
        
        //4.load data property template
        loadDataPropertyTemplate();
    }
 
    private void loadDataPropertyTemplate() throws Exception {
        PropertyTemplateBucket templateBucket = PropertyTemplateBucket.getInstance();    
        templateBucket.loadTemplateAndIndex();
    }
 
    @Override
    public void shutDown() throws Exception {
        
    }
    
    private void loadDataObject() throws Exception {
        DataObjectContainer objectContainer = DataObjectContainer.getInstance();
 
        NamedSQL namedSQL = NamedSQL.getInstance("getDataObjectList");
        EntitySet objectSet = SQLRunner.getEntitySet(namedSQL, new EntitySetGetter(null, null));
 
        for (Entity entity: objectSet) {
            DataObject dataObject = new DataObject();
            dataObject.load(entity);
            
            objectContainer.add(dataObject.getDataName(), dataObject);
        }
    }
    
    private void loadDataObjectJoins() throws Exception {
        NamedSQL namedSQL = NamedSQL.getInstance("getDataObjectJoinList");
        EntitySet entitySet = namedSQL.getEntitySet();
 
        for (Entity entity: entitySet) {
            DataJoin dataJoin = new DataJoin();
            dataJoin.load(entity);
            
            if (!dataJoin.isActive()) {
                continue;
            }
            
            DataObject dataObject = DataObject.getInstance(dataJoin.getDataName());
            
            if (dataObject == null) {
                continue;
            }
            
            dataObject.loadOneDataJoin(dataJoin);
        }        
    }
    
    private void buildDataObjects() throws Exception {
        DataObjectContainer container = DataObjectContainer.getInstance();
        
        for (DataObject dataObject: container) {
            dataObject.build();
        }
    }
 
    public static DataObject loadOneDataObject(String name) throws Exception {
        DataObject dataObject = DataObject.getInstance("sys_data_object");
        Filter filter = new Filter("table_name", name);
        Entity entity = dataObject.getTableEntity(filter);
        
        if (entity == null) {
            return null;
        }
        
        dataObject = new DataObject();
        dataObject.load(entity);
            
        return dataObject;
    }
    
    public static DataJoins loadOneDataObjectDataJoins(String name) throws Exception {
        DataObject dataObject = DataObject.getInstance("sys_data_object_join");
        Filter filter = new Filter("dataname", name);
        EntitySet entitySet = dataObject.getTableEntitySet(filter);
        
        if (entitySet == null || entitySet.isEmpty()) {
            return null;
        }
        
        DataJoins dataJoins = new DataJoins();
        
        for (Entity entity: entitySet) {
            DataJoin dataJoin = new DataJoin();
            dataJoin.load(entity);
            
            dataJoins.loadOne(dataJoin);
        }
            
        return dataJoins;
    }
 
}