ctripcorp/zeus
1
1
Fork 0
mirror of https://github.com/ctripcorp/zeus.git synced 2024-11-10 17:13:46 +08:00
Code Issues Projects Releases Packages Wiki Activity

add impl of entityFactory

Browse source
This commit is contained in:
Mengyi Zhou 2016-01-26 14:38:06 +08:00 committed by Mengyi Zhou
parent b2382a11f5
commit df34b200c9
5 changed files with 129 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/main/java/com/ctrip/zeus/service/model/EntityFactory.java
View file

@ -11,21 +11,19 @@ import java.util.Set;
*/
public interface EntityFactory {
ModelStatusMapping<Group> getByVsIds(Long[] vsIds) throws Exception;
ModelStatusMapping<Group> getGroupsByVsIds(Long[] vsIds) throws Exception;
ModelStatusMapping<VirtualServer> getBySlbIds(Long slbId) throws Exception;
ModelStatusMapping<VirtualServer> getVsesBySlbIds(Long slbId) throws Exception;
ModelStatusMapping<Slb> getSlbById(Long[] slbId) throws Exception;
ModelStatusMapping<Slb> getSlbsByIds(Long[] slbIds) throws Exception;
ModelStatusMapping<VirtualServer> getVsByVsIds(Long[] vsIds) throws Exception;
ModelStatusMapping<VirtualServer> getVsesByIds(Long[] vsIds) throws Exception;
ModelStatusMapping<Group> getGroupById(Long[] groupId) throws Exception;
ModelStatusMapping<Group> getGroupsByIds(Long[] groupIds) throws Exception;
Long[] getSlbIdsByIp(String ip, ModelMode mode) throws Exception;
Long[] getVsIdsBySlbId(Long slbId, ModelMode mode) throws Exception;
Long[] getGroupIdsByVsIds(Long[] vsIds, ModelMode mode) throws Exception;
}

88
src/main/java/com/ctrip/zeus/service/model/impl/EntityFactoryImpl.java
View file

@ -3,13 +3,11 @@ package com.ctrip.zeus.service.model.impl;
import com.ctrip.zeus.dal.core.*;
import com.ctrip.zeus.model.entity.Group;
import com.ctrip.zeus.model.entity.GroupVirtualServer;
import com.ctrip.zeus.model.entity.Slb;
import com.ctrip.zeus.model.entity.VirtualServer;
import com.ctrip.zeus.restful.filter.FilterSet;
import com.ctrip.zeus.restful.filter.QueryExecuter;
import com.ctrip.zeus.service.model.EntityFactory;
import com.ctrip.zeus.service.model.IdVersion;
import com.ctrip.zeus.service.model.ModelMode;
import com.ctrip.zeus.service.model.ModelStatusMapping;
import com.ctrip.zeus.service.model.*;
import com.ctrip.zeus.service.model.handler.impl.ContentReaders;
import com.ctrip.zeus.service.query.GroupCriteriaQuery;
import com.ctrip.zeus.service.query.SlbCriteriaQuery;
@ -17,10 +15,7 @@ import com.ctrip.zeus.service.query.VirtualServerCriteriaQuery;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Set;
import java.util.Map;
import java.util.*;
/**
* Created by zhoumy on 2016/1/19.
@ -32,9 +27,13 @@ public class EntityFactoryImpl implements EntityFactory {
@Resource
private ArchiveVsDao archiveVsDao;
@Resource
private ArchiveSlbDao archiveSlbDao;
@Resource
private RGroupStatusDao rGroupStatusDao;
@Resource
private RVsStatusDao rVsStatusDao;
@Resource
private RSlbStatusDao rSlbStatusDao;
@Resource
private GroupCriteriaQuery groupCriteriaQuery;
@ -44,7 +43,7 @@ public class EntityFactoryImpl implements EntityFactory {
private VirtualServerCriteriaQuery virtualServerCriteriaQuery;
@Override
public ModelStatusMapping<Group> getByVsIds(Long[] vsIds) throws Exception {
public ModelStatusMapping<Group> getGroupsByVsIds(Long[] vsIds) throws Exception {
ModelStatusMapping<Group> result = new ModelStatusMapping<>();
Set<Long> groupIds = new HashSet<>();
Map<String, Group> mapping = new HashMap<>();
@ -68,7 +67,7 @@ public class EntityFactoryImpl implements EntityFactory {
}
@Override
public ModelStatusMapping<VirtualServer> getBySlbIds(Long slbId) throws Exception {
public ModelStatusMapping<VirtualServer> getVsesBySlbIds(Long slbId) throws Exception {
ModelStatusMapping<VirtualServer> result = new ModelStatusMapping<>();
Set<Long> vsIds = new HashSet<>();
Map<String, VirtualServer> mapping = new HashMap<>();
@ -89,6 +88,75 @@ public class EntityFactoryImpl implements EntityFactory {
return result;
}
@Override
public ModelStatusMapping<Slb> getSlbsByIds(Long[] slbIds) throws Exception {
ModelStatusMapping<Slb> result = new ModelStatusMapping<>();
List<RelSlbStatusDo> ref = rSlbStatusDao.findBySlbs(slbIds, RSlbStatusEntity.READSET_FULL);
Map<String, Slb> mapping = new HashMap<>();
for (ArchiveSlbDo d : archiveSlbDao.findVersionizedByIds(slbIds, ArchiveSlbEntity.READSET_FULL)) {
Slb slb = ContentReaders.readSlbContent(d.getContent());
slb.getVirtualServers().clear();
mapping.put(slb.getId() + "," + slb.getVersion(), slb);
}
for (RelSlbStatusDo d : ref) {
if (d.getOnlineVersion() == 0 || d.getOnlineVersion() != d.getOfflineVersion()) {
result.addOffline(d.getSlbId(), mapping.get(d.getSlbId() + "," + d.getOfflineVersion()));
}
if (d.getOnlineVersion() != 0) {
result.addOnline(d.getSlbId(), mapping.get(d.getSlbId() + "," + d.getOnlineVersion()));
}
}
return result;
}
@Override
public ModelStatusMapping<VirtualServer> getVsesByIds(Long[] vsIds) throws Exception {
ModelStatusMapping<VirtualServer> result = new ModelStatusMapping<>();
List<RelVsStatusDo> ref = rVsStatusDao.findByVses(vsIds, RVsStatusEntity.READSET_FULL);
Map<String, VirtualServer> mapping = new HashMap<>();
for (MetaVsArchiveDo d : archiveVsDao.findVersionizedByIds(vsIds, ArchiveVsEntity.READSET_FULL)) {
VirtualServer vs = ContentReaders.readVirtualServerContent(d.getContent());
mapping.put(vs.getId() + "," + d.getVersion(), vs);
}
for (RelVsStatusDo d : ref) {
if (d.getOnlineVersion() == 0 || d.getOnlineVersion() != d.getOfflineVersion()) {
result.addOffline(d.getVsId(), mapping.get(d.getVsId() + "," + d.getOfflineVersion()));
}
if (d.getOnlineVersion() != 0) {
result.addOnline(d.getVsId(), mapping.get(d.getVsId() + "," + d.getOnlineVersion()));
}
}
return result;
}
@Override
public ModelStatusMapping<Group> getGroupsByIds(Long[] groupIds) throws Exception {
ModelStatusMapping<Group> result = new ModelStatusMapping<>();
List<RelGroupStatusDo> ref = rGroupStatusDao.findByGroups(groupIds, RGroupStatusEntity.READSET_FULL);
Map<String, Group> mapping = new HashMap<>();
for (ArchiveGroupDo d : archiveGroupDao.findVersionizedByIds(groupIds, ArchiveGroupEntity.READSET_FULL)) {
Group g = ContentReaders.readGroupContent(d.getContent());
for (GroupVirtualServer e : g.getGroupVirtualServers()) {
e.setVirtualServer(new VirtualServer().setId(e.getVirtualServer().getId()));
}
mapping.put(d.getGroupId() + "," + d.getVersion(), g);
}
for (RelGroupStatusDo d : ref) {
if (d.getOnlineVersion() == 0 || d.getOnlineVersion() != d.getOfflineVersion()) {
result.addOffline(d.getGroupId(), mapping.get(d.getGroupId() + "," + d.getOfflineVersion()));
}
if (d.getOnlineVersion() != 0) {
result.addOnline(d.getGroupId(), mapping.get(d.getGroupId() + "," + d.getOnlineVersion()));
}
}
return result;
}
@Override
public Long[] getSlbIdsByIp(String ip, ModelMode mode) throws Exception {
final Set<IdVersion> range = slbCriteriaQuery.queryBySlbServerIp(ip);

18
src/main/resources/META-INF/dal/jdbc/meta-group.xml
View file

@ -96,7 +96,7 @@
</readset>
</readsets>
<query-defs>
<!--This query is particularly designed for batch selection required task executors-->
<!--These queries are particularly designed for batch selection required task executors-->
<query name="find-all-by-vs-ids" type="SELECT" multiple="true">
<param name="ids"/>
<statement>
@ -106,13 +106,27 @@
INNER JOIN (SELECT rgv.group_id, rgv.group_version
FROM r_group_vs rgv
INNER JOIN r_group_status rgs
ON rgv.group_id = rgs.group_id
ON rgv.group_id = rgs.group_id
AND (rgv.group_version = rgs.online_version OR rgv.group_version = rgs.offline_version)
WHERE rgv.vs_id IN <IN>${ids}</IN>) AS tmp
ON ag.group_id = tmp.group_id AND ag.version = tmp.group_version
]]>
</statement>
</query>
<query name="find-versionized-by-ids" type="SELECT" multiple="true">
<param name="ids"/>
<statement>
<![CDATA[
SELECT <FIELDS/>
FROM <TABLE/>
INNER JOIN r_group_status rgs
ON ag.group_id = rgs.group_id
AND (ag.version = rgs.online_version OR ag.version = rgs.offline_version)
WHERE ag.group_id IN <IN>${ids}</IN>
]]>
</statement>
</query>
<!--end-->
<query name="find-all-by-ids" type="SELECT" multiple="true">
<param name="ids"/>
<statement>

15
src/main/resources/META-INF/dal/jdbc/meta-slb.xml
View file

@ -74,6 +74,21 @@
<var name="hashes" value-type="Integer[]"/>
<var name="id-version-array" value-type="String[]"/>
<query-defs>
<!--These queries are particularly designed for batch selection required task executors-->
<query name="find-versionized-by-ids" type="SELECT" multiple="true">
<param name="ids"/>
<statement>
<![CDATA[
SELECT <FIELDS/>
FROM <TABLE/>
INNER JOIN r_slb_status rss
ON as3.slb_id = rss.slb_id
AND (as3.version = rss.online_version OR as3.version = rss.offline_version)
WHERE as3.slb_id IN <IN>${ids}</IN>
]]>
</statement>
</query>
<!--end-->
<query name="delete-by-slb" type="DELETE">
<param name="slb-id"/>
<statement>

16
src/main/resources/META-INF/dal/jdbc/meta-vs.xml
View file

@ -11,7 +11,7 @@
</readset>
</readsets>
<query-defs>
<!--This query is particularly designed for batch selection required task executors-->
<!--These queries are particularly designed for batch selection required task executors-->
<query name="find-all-by-slb-id" type="SELECT" multiple="true">
<param name="rel-id"/>
<statement>
@ -28,6 +28,20 @@
]]>
</statement>
</query>
<query name="find-versionized-by-ids" type="SELECT" multiple="true">
<param name="ids"/>
<statement>
<![CDATA[
SELECT <FIELDS/>
FROM <TABLE/>
INNER JOIN r_vs_status rvs
ON av.vs_id = rvs.vs_id
AND (av.version = rvs.online_version OR av.version = rvs.offline_version)
WHERE av.vs_id IN <IN>${ids}</IN>
]]>
</statement>
</query>
<!--end-->
<query name="find-all-by-ids" type="SELECT" multiple="true">
<param name="ids"/>
<statement>