提交 a3aaf246 编写于 作者: F Frankie Wu

upgrade codegen plugin to 1.0.16

上级 60396544
......@@ -30,7 +30,7 @@
<plugin>
<groupId>com.site.maven.plugins</groupId>
<artifactId>maven-codegen-plugin</artifactId>
<version>1.0.15</version>
<version>1.0.16</version>
<executions>
<execution>
<id>generate heartbeat report model</id>
......
......@@ -18,7 +18,7 @@ import com.dianping.cat.consumer.event.model.entity.EventReport;
import com.dianping.cat.consumer.event.model.entity.EventType;
import com.dianping.cat.consumer.event.model.entity.Range;
import com.dianping.cat.consumer.event.model.transform.DefaultXmlBuilder;
import com.dianping.cat.consumer.event.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.event.model.transform.DefaultDomParser;
import com.dianping.cat.hadoop.dal.Report;
import com.dianping.cat.hadoop.dal.ReportDao;
import com.dianping.cat.message.Event;
......@@ -83,7 +83,7 @@ public class EventAnalyzer extends AbstractMessageAnalyzer<EventReport> implemen
}
private void loadReports() {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
Bucket<String> reportBucket = null;
try {
......
......@@ -17,7 +17,7 @@ import com.dianping.cat.consumer.heartbeat.model.entity.Disk;
import com.dianping.cat.consumer.heartbeat.model.entity.HeartbeatReport;
import com.dianping.cat.consumer.heartbeat.model.entity.Period;
import com.dianping.cat.consumer.heartbeat.model.transform.DefaultXmlBuilder;
import com.dianping.cat.consumer.heartbeat.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.heartbeat.model.transform.DefaultDomParser;
import com.dianping.cat.hadoop.dal.Report;
import com.dianping.cat.hadoop.dal.ReportDao;
import com.dianping.cat.message.Heartbeat;
......@@ -92,7 +92,7 @@ public class HeartbeatAnalyzer extends AbstractMessageAnalyzer<HeartbeatReport>
StatusInfo info = null;
try {
info = new com.dianping.cat.status.model.transform.DefaultXmlParser().parse(xml);
info = new com.dianping.cat.status.model.transform.DefaultDomParser().parse(xml);
} catch (Exception e) {
e.printStackTrace();
return null;
......@@ -172,7 +172,7 @@ public class HeartbeatAnalyzer extends AbstractMessageAnalyzer<HeartbeatReport>
}
private void loadReports() {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
Bucket<String> reportBucket = null;
try {
......
......@@ -17,7 +17,7 @@ import com.dianping.cat.consumer.ip.model.entity.Ip;
import com.dianping.cat.consumer.ip.model.entity.IpReport;
import com.dianping.cat.consumer.ip.model.entity.Period;
import com.dianping.cat.consumer.ip.model.transform.DefaultXmlBuilder;
import com.dianping.cat.consumer.ip.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.ip.model.transform.DefaultDomParser;
import com.dianping.cat.hadoop.dal.Report;
import com.dianping.cat.hadoop.dal.ReportDao;
import com.dianping.cat.message.Event;
......@@ -87,7 +87,7 @@ public class TopIpAnalyzer extends AbstractMessageAnalyzer<IpReport> implements
}
private void loadReports() {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
Bucket<String> reportBucket = null;
try {
......
......@@ -18,7 +18,7 @@ import com.dianping.cat.consumer.problem.model.entity.Machine;
import com.dianping.cat.consumer.problem.model.entity.ProblemReport;
import com.dianping.cat.consumer.problem.model.entity.Segment;
import com.dianping.cat.consumer.problem.model.transform.DefaultXmlBuilder;
import com.dianping.cat.consumer.problem.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.problem.model.transform.DefaultDomParser;
import com.dianping.cat.hadoop.dal.Report;
import com.dianping.cat.hadoop.dal.ReportDao;
import com.dianping.cat.message.Message;
......@@ -117,7 +117,7 @@ public class ProblemAnalyzer extends AbstractMessageAnalyzer<ProblemReport> impl
}
private void loadReports() {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
Bucket<String> bucket = null;
try {
......
......@@ -19,7 +19,7 @@ import com.dianping.cat.consumer.transaction.model.entity.TransactionName;
import com.dianping.cat.consumer.transaction.model.entity.TransactionReport;
import com.dianping.cat.consumer.transaction.model.entity.TransactionType;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlBuilder;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.transaction.model.transform.DefaultDomParser;
import com.dianping.cat.hadoop.dal.Report;
import com.dianping.cat.hadoop.dal.ReportDao;
import com.dianping.cat.message.Message;
......@@ -86,7 +86,7 @@ public class TransactionAnalyzer extends AbstractMessageAnalyzer<TransactionRepo
}
private void loadReports() {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
Bucket<String> bucket = null;
try {
......
......@@ -6,13 +6,13 @@ import org.junit.Test;
import com.dianping.cat.consumer.ip.model.entity.IpReport;
import com.dianping.cat.consumer.ip.model.transform.DefaultJsonBuilder;
import com.dianping.cat.consumer.ip.model.transform.DefaultXmlBuilder;
import com.dianping.cat.consumer.ip.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.ip.model.transform.DefaultDomParser;
import com.site.helper.Files;
public class IpReportTest {
@Test
public void testXml() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("IpReport.xml"), "utf-8");
IpReport report = parser.parse(source);
String xml = new DefaultXmlBuilder().buildXml(report);
......@@ -23,7 +23,7 @@ public class IpReportTest {
@Test
public void testJson() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("IpReport.xml"), "utf-8");
IpReport report = parser.parse(source);
String json = new DefaultJsonBuilder().buildJson(report);
......
......@@ -6,13 +6,13 @@ import org.junit.Test;
import com.dianping.cat.consumer.problem.model.entity.ProblemReport;
import com.dianping.cat.consumer.problem.model.transform.DefaultJsonBuilder;
import com.dianping.cat.consumer.problem.model.transform.DefaultXmlBuilder;
import com.dianping.cat.consumer.problem.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.problem.model.transform.DefaultDomParser;
import com.site.helper.Files;
public class ProblemReportTest {
@Test
public void testXml() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("problem-report.xml"), "utf-8");
ProblemReport root = parser.parse(source);
String xml = new DefaultXmlBuilder().buildXml(root);
......@@ -23,7 +23,7 @@ public class ProblemReportTest {
@Test
public void testJson() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("problem-report.xml"), "utf-8");
ProblemReport root = parser.parse(source);
String json = new DefaultJsonBuilder().buildJson(root);
......
......@@ -6,13 +6,13 @@ import org.junit.Test;
import com.dianping.cat.consumer.transaction.model.entity.TransactionReport;
import com.dianping.cat.consumer.transaction.model.transform.DefaultJsonBuilder;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlBuilder;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.transaction.model.transform.DefaultDomParser;
import com.site.helper.Files;
public class TransactionReportTest {
@Test
public void testXml() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("TransactionReport.xml"), "utf-8");
TransactionReport report = parser.parse(source);
String xml = new DefaultXmlBuilder().buildXml(report);
......@@ -23,7 +23,7 @@ public class TransactionReportTest {
@Test
public void testJson() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("TransactionReport.xml"), "utf-8");
TransactionReport report = parser.parse(source);
String json = new DefaultJsonBuilder().buildJson(report);
......
......@@ -39,7 +39,7 @@
<plugin>
<groupId>com.site.maven.plugins</groupId>
<artifactId>maven-codegen-plugin</artifactId>
<version>1.0.15</version>
<version>1.0.16</version>
<executions>
<execution>
<id>generate configuration model</id>
......
......@@ -14,7 +14,7 @@ import org.codehaus.plexus.logging.Logger;
import com.dianping.cat.configuration.ClientConfigMerger;
import com.dianping.cat.configuration.ClientConfigValidator;
import com.dianping.cat.configuration.client.entity.ClientConfig;
import com.dianping.cat.configuration.client.transform.DefaultXmlParser;
import com.dianping.cat.configuration.client.transform.DefaultDomParser;
import com.dianping.cat.message.MessageProducer;
import com.dianping.cat.message.spi.MessageManager;
import com.site.helper.Files;
......@@ -123,7 +123,7 @@ public class Cat {
if (configFile.exists()) {
String xml = Files.forIO().readFrom(configFile.getCanonicalFile(), "utf-8");
globalConfig = new DefaultXmlParser().parse(xml);
globalConfig = new DefaultDomParser().parse(xml);
} else {
s_instance.m_logger.warn(String.format("Global config file(%s) not found, IGNORED.", configFile));
}
......@@ -140,7 +140,7 @@ public class Cat {
if (in != null) {
String xml = Files.forIO().readFrom(in, "utf-8");
clientConfig = new DefaultXmlParser().parse(xml);
clientConfig = new DefaultDomParser().parse(xml);
}
}
} catch (Exception e) {
......
......@@ -17,7 +17,7 @@ import com.dianping.cat.configuration.server.entity.LongUrl;
import com.dianping.cat.configuration.server.entity.Property;
import com.dianping.cat.configuration.server.entity.ServerConfig;
import com.dianping.cat.configuration.server.entity.StorageConfig;
import com.dianping.cat.configuration.server.transform.DefaultXmlParser;
import com.dianping.cat.configuration.server.transform.DefaultDomParser;
import com.site.helper.Files;
import com.site.helper.Threads;
import com.site.helper.Threads.Task;
......@@ -167,7 +167,7 @@ public class ServerConfigManager implements LogEnabled {
m_logger.info(String.format("Loading configuration file(%s) ...", configFile.getCanonicalPath()));
String xml = Files.forIO().readFrom(configFile, "utf-8");
ServerConfig config = new DefaultXmlParser().parse(xml);
ServerConfig config = new DefaultDomParser().parse(xml);
// do validation
config.accept(new ServerConfigValidator());
......
......@@ -21,7 +21,7 @@ import com.dianping.cat.configuration.client.IEntity;
import com.dianping.cat.configuration.client.entity.ClientConfig;
import com.dianping.cat.configuration.client.entity.Server;
import com.dianping.cat.configuration.client.transform.DefaultXmlBuilder;
import com.dianping.cat.configuration.client.transform.DefaultXmlParser;
import com.dianping.cat.configuration.client.transform.DefaultDomParser;
import com.site.helper.Files;
public class ClientConfigTest {
......@@ -51,14 +51,14 @@ public class ClientConfigTest {
private ClientConfig loadConfig(String configXml) throws IOException, SAXException {
InputStream in = getClass().getResourceAsStream(configXml);
String xml = Files.forIO().readFrom(in, "utf-8");
ClientConfig clientConfig = new DefaultXmlParser().parse(xml);
ClientConfig clientConfig = new DefaultDomParser().parse(xml);
return clientConfig;
}
@Test
public void testConfig() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("config.xml"), "utf-8");
ClientConfig root = parser.parse(source);
String xml = new DefaultXmlBuilder().buildXml(root);
......@@ -91,7 +91,7 @@ public class ClientConfigTest {
public void testServer() throws Exception {
InputStream in = getClass().getResourceAsStream("server.xml");
String xml = Files.forIO().readFrom(in, "utf-8");
ClientConfig config = new DefaultXmlParser().parse(xml);
ClientConfig config = new DefaultDomParser().parse(xml);
Assert.assertEquals("server", config.getMode());
Assert.assertEquals("192.168.8.21", config.getBind().getIp());
......
......@@ -5,13 +5,13 @@ import org.junit.Test;
import com.dianping.cat.status.model.entity.StatusInfo;
import com.dianping.cat.status.model.transform.DefaultXmlBuilder;
import com.dianping.cat.status.model.transform.DefaultXmlParser;
import com.dianping.cat.status.model.transform.DefaultDomParser;
import com.site.helper.Files;
public class StatusInfoTest {
@Test
public void testXml() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("status.xml"), "utf-8");
StatusInfo root = parser.parse(source);
String xml = new DefaultXmlBuilder().buildXml(root);
......
......@@ -4,7 +4,7 @@ import java.util.Date;
import java.util.List;
import com.dianping.cat.consumer.event.model.entity.EventReport;
import com.dianping.cat.consumer.event.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.event.model.transform.DefaultDomParser;
import com.dianping.cat.hadoop.dal.Report;
import com.dianping.cat.hadoop.dal.ReportDao;
import com.dianping.cat.hadoop.dal.ReportEntity;
......@@ -43,7 +43,7 @@ public class HistoricalEventService extends BaseHistoricalModelService<EventRepo
private EventReport getReportFromDatabase(long timestamp, String domain) throws Exception {
List<Report> reports = m_reportDao.findAllByPeriodDomainTypeName(new Date(timestamp), domain, 1, getName(),
ReportEntity.READSET_FULL);
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
EventReportMerger merger = null;
for (Report report : reports) {
......@@ -64,6 +64,6 @@ public class HistoricalEventService extends BaseHistoricalModelService<EventRepo
Bucket<String> bucket = m_bucketManager.getReportBucket(timestamp, "event");
String xml = bucket.findById(domain);
return xml == null ? null : new DefaultXmlParser().parse(xml);
return xml == null ? null : new DefaultDomParser().parse(xml);
}
}
package com.dianping.cat.report.page.model.event;
import com.dianping.cat.consumer.event.model.entity.EventReport;
import com.dianping.cat.consumer.event.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.event.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.spi.ModelPeriod;
import com.dianping.cat.report.page.model.spi.ModelRequest;
import com.dianping.cat.report.page.model.spi.internal.BaseLocalModelService;
......@@ -35,6 +35,6 @@ public class LocalEventService extends BaseLocalModelService<EventReport> {
Bucket<String> bucket = m_bucketManager.getReportBucket(timestamp, "event");
String xml = bucket.findById(domain);
return xml == null ? null : new DefaultXmlParser().parse(xml);
return xml == null ? null : new DefaultDomParser().parse(xml);
}
}
......@@ -5,7 +5,7 @@ import java.io.IOException;
import org.xml.sax.SAXException;
import com.dianping.cat.consumer.event.model.entity.EventReport;
import com.dianping.cat.consumer.event.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.event.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.spi.internal.BaseRemoteModelService;
public class RemoteEventService extends BaseRemoteModelService<EventReport> {
......@@ -15,6 +15,6 @@ public class RemoteEventService extends BaseRemoteModelService<EventReport> {
@Override
protected EventReport buildModel(String xml) throws SAXException, IOException {
return new DefaultXmlParser().parse(xml);
return new DefaultDomParser().parse(xml);
}
}
......@@ -5,7 +5,7 @@ import java.util.List;
import com.dianping.cat.consumer.heartbeat.model.entity.HeartbeatReport;
import com.dianping.cat.consumer.heartbeat.model.transform.DefaultMerger;
import com.dianping.cat.consumer.heartbeat.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.heartbeat.model.transform.DefaultDomParser;
import com.dianping.cat.hadoop.dal.Report;
import com.dianping.cat.hadoop.dal.ReportDao;
import com.dianping.cat.hadoop.dal.ReportEntity;
......@@ -44,7 +44,7 @@ public class HistoricalHeartbeatService extends BaseHistoricalModelService<Heart
private HeartbeatReport getReportFromDatabase(long timestamp, String domain) throws Exception {
List<Report> reports = m_reportDao.findAllByPeriodDomainTypeName(new Date(timestamp), domain, 1, getName(),
ReportEntity.READSET_FULL);
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
DefaultMerger merger = null;
for (Report report : reports) {
......@@ -65,6 +65,6 @@ public class HistoricalHeartbeatService extends BaseHistoricalModelService<Heart
Bucket<String> bucket = m_bucketManager.getReportBucket(timestamp, "heartbeat");
String xml = bucket.findById(domain);
return xml == null ? null : new DefaultXmlParser().parse(xml);
return xml == null ? null : new DefaultDomParser().parse(xml);
}
}
package com.dianping.cat.report.page.model.heartbeat;
import com.dianping.cat.consumer.heartbeat.model.entity.HeartbeatReport;
import com.dianping.cat.consumer.heartbeat.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.heartbeat.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.spi.ModelPeriod;
import com.dianping.cat.report.page.model.spi.ModelRequest;
import com.dianping.cat.report.page.model.spi.internal.BaseLocalModelService;
......@@ -35,6 +35,6 @@ public class LocalHeartbeatService extends BaseLocalModelService<HeartbeatReport
Bucket<String> bucket = m_bucketManager.getReportBucket(timestamp, "heartbeat");
String xml = bucket.findById(domain);
return xml == null ? null : new DefaultXmlParser().parse(xml);
return xml == null ? null : new DefaultDomParser().parse(xml);
}
}
......@@ -5,7 +5,7 @@ import java.io.IOException;
import org.xml.sax.SAXException;
import com.dianping.cat.consumer.heartbeat.model.entity.HeartbeatReport;
import com.dianping.cat.consumer.heartbeat.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.heartbeat.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.spi.internal.BaseRemoteModelService;
public class RemoteHeartbeatService extends BaseRemoteModelService<HeartbeatReport> {
......@@ -15,6 +15,6 @@ public class RemoteHeartbeatService extends BaseRemoteModelService<HeartbeatRepo
@Override
protected HeartbeatReport buildModel(String xml) throws SAXException, IOException {
return new DefaultXmlParser().parse(xml);
return new DefaultDomParser().parse(xml);
}
}
......@@ -4,7 +4,7 @@ import java.util.Date;
import java.util.List;
import com.dianping.cat.consumer.ip.model.entity.IpReport;
import com.dianping.cat.consumer.ip.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.ip.model.transform.DefaultDomParser;
import com.dianping.cat.hadoop.dal.Report;
import com.dianping.cat.hadoop.dal.ReportDao;
import com.dianping.cat.hadoop.dal.ReportEntity;
......@@ -43,7 +43,7 @@ public class HistoricalIpService extends BaseHistoricalModelService<IpReport> {
private IpReport getReportFromDatabase(long timestamp, String domain) throws Exception {
List<Report> reports = m_reportDao.findAllByPeriodDomainTypeName(new Date(timestamp), domain, 1, getName(),
ReportEntity.READSET_FULL);
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
IpReportMerger merger = null;
for (Report report : reports) {
......@@ -64,6 +64,6 @@ public class HistoricalIpService extends BaseHistoricalModelService<IpReport> {
Bucket<String> bucket = m_bucketManager.getReportBucket(timestamp, "ip");
String xml = bucket.findById(domain);
return xml == null ? null : new DefaultXmlParser().parse(xml);
return xml == null ? null : new DefaultDomParser().parse(xml);
}
}
package com.dianping.cat.report.page.model.ip;
import com.dianping.cat.consumer.ip.model.entity.IpReport;
import com.dianping.cat.consumer.ip.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.ip.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.spi.ModelPeriod;
import com.dianping.cat.report.page.model.spi.ModelRequest;
import com.dianping.cat.report.page.model.spi.internal.BaseLocalModelService;
......@@ -34,6 +34,6 @@ public class LocalIpService extends BaseLocalModelService<IpReport> {
Bucket<String> bucket = m_bucketManager.getReportBucket(timestamp, "ip");
String xml = bucket.findById(domain);
return xml == null ? null : new DefaultXmlParser().parse(xml);
return xml == null ? null : new DefaultDomParser().parse(xml);
}
}
......@@ -5,7 +5,7 @@ import java.io.IOException;
import org.xml.sax.SAXException;
import com.dianping.cat.consumer.ip.model.entity.IpReport;
import com.dianping.cat.consumer.ip.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.ip.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.spi.internal.BaseRemoteModelService;
public class RemoteIpService extends BaseRemoteModelService<IpReport> {
......@@ -15,6 +15,6 @@ public class RemoteIpService extends BaseRemoteModelService<IpReport> {
@Override
protected IpReport buildModel(String xml) throws SAXException, IOException {
return new DefaultXmlParser().parse(xml);
return new DefaultDomParser().parse(xml);
}
}
......@@ -5,7 +5,7 @@ import java.util.List;
import com.dianping.cat.consumer.problem.model.entity.ProblemReport;
import com.dianping.cat.consumer.problem.model.transform.DefaultMerger;
import com.dianping.cat.consumer.problem.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.problem.model.transform.DefaultDomParser;
import com.dianping.cat.hadoop.dal.Report;
import com.dianping.cat.hadoop.dal.ReportDao;
import com.dianping.cat.hadoop.dal.ReportEntity;
......@@ -44,7 +44,7 @@ public class HistoricalProblemService extends BaseHistoricalModelService<Problem
private ProblemReport getReportFromDatabase(long timestamp, String domain) throws Exception {
List<Report> reports = m_reportDao.findAllByPeriodDomainTypeName(new Date(timestamp), domain, 1, getName(),
ReportEntity.READSET_FULL);
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
DefaultMerger merger = null;
for (Report report : reports) {
......@@ -65,6 +65,6 @@ public class HistoricalProblemService extends BaseHistoricalModelService<Problem
Bucket<String> bucket = m_bucketManager.getReportBucket(timestamp, "problem");
String xml = bucket.findById(domain);
return xml == null ? null : new DefaultXmlParser().parse(xml);
return xml == null ? null : new DefaultDomParser().parse(xml);
}
}
package com.dianping.cat.report.page.model.problem;
import com.dianping.cat.consumer.problem.model.entity.ProblemReport;
import com.dianping.cat.consumer.problem.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.problem.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.spi.ModelPeriod;
import com.dianping.cat.report.page.model.spi.ModelRequest;
import com.dianping.cat.report.page.model.spi.internal.BaseLocalModelService;
......@@ -35,6 +35,6 @@ public class LocalProblemService extends BaseLocalModelService<ProblemReport> {
Bucket<String> bucket = m_bucketManager.getReportBucket(timestamp, "problem");
String xml = bucket.findById(domain);
return xml == null ? null : new DefaultXmlParser().parse(xml);
return xml == null ? null : new DefaultDomParser().parse(xml);
}
}
......@@ -5,7 +5,7 @@ import java.io.IOException;
import org.xml.sax.SAXException;
import com.dianping.cat.consumer.problem.model.entity.ProblemReport;
import com.dianping.cat.consumer.problem.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.problem.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.spi.internal.BaseRemoteModelService;
public class RemoteProblemService extends BaseRemoteModelService<ProblemReport> {
......@@ -15,6 +15,6 @@ public class RemoteProblemService extends BaseRemoteModelService<ProblemReport>
@Override
protected ProblemReport buildModel(String xml) throws SAXException, IOException {
return new DefaultXmlParser().parse(xml);
return new DefaultDomParser().parse(xml);
}
}
......@@ -4,7 +4,7 @@ import java.util.Date;
import java.util.List;
import com.dianping.cat.consumer.transaction.model.entity.TransactionReport;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.transaction.model.transform.DefaultDomParser;
import com.dianping.cat.hadoop.dal.Report;
import com.dianping.cat.hadoop.dal.ReportDao;
import com.dianping.cat.hadoop.dal.ReportEntity;
......@@ -43,7 +43,7 @@ public class HistoricalTransactionService extends BaseHistoricalModelService<Tra
private TransactionReport getReportFromDatabase(long timestamp, String domain) throws Exception {
List<Report> reports = m_reportDao.findAllByPeriodDomainTypeName(new Date(timestamp), domain, 1, getName(),
ReportEntity.READSET_FULL);
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
TransactionReportMerger merger = null;
for (Report report : reports) {
......@@ -64,6 +64,6 @@ public class HistoricalTransactionService extends BaseHistoricalModelService<Tra
Bucket<String> bucket = m_bucketManager.getReportBucket(timestamp, "transaction");
String xml = bucket.findById(domain);
return xml == null ? null : new DefaultXmlParser().parse(xml);
return xml == null ? null : new DefaultDomParser().parse(xml);
}
}
package com.dianping.cat.report.page.model.transaction;
import com.dianping.cat.consumer.transaction.model.entity.TransactionReport;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.transaction.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.spi.ModelPeriod;
import com.dianping.cat.report.page.model.spi.ModelRequest;
import com.dianping.cat.report.page.model.spi.internal.BaseLocalModelService;
......@@ -35,6 +35,6 @@ public class LocalTransactionService extends BaseLocalModelService<TransactionRe
Bucket<String> bucket = m_bucketManager.getReportBucket(timestamp, "transaction");
String xml = bucket.findById(domain);
return xml == null ? null : new DefaultXmlParser().parse(xml);
return xml == null ? null : new DefaultDomParser().parse(xml);
}
}
......@@ -5,7 +5,7 @@ import java.io.IOException;
import org.xml.sax.SAXException;
import com.dianping.cat.consumer.transaction.model.entity.TransactionReport;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.transaction.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.spi.internal.BaseRemoteModelService;
public class RemoteTransactionService extends BaseRemoteModelService<TransactionReport> {
......@@ -15,6 +15,6 @@ public class RemoteTransactionService extends BaseRemoteModelService<Transaction
@Override
protected TransactionReport buildModel(String xml) throws SAXException, IOException {
return new DefaultXmlParser().parse(xml);
return new DefaultDomParser().parse(xml);
}
}
......@@ -14,7 +14,7 @@ import javax.servlet.http.HttpServletResponse;
import com.dianping.cat.Cat;
import com.dianping.cat.configuration.ServerConfigManager;
import com.dianping.cat.configuration.client.entity.ClientConfig;
import com.dianping.cat.configuration.client.transform.DefaultXmlParser;
import com.dianping.cat.configuration.client.transform.DefaultDomParser;
import com.dianping.cat.message.spi.MessageHandler;
import com.dianping.cat.message.spi.MessageManager;
import com.dianping.cat.message.spi.internal.DefaultMessageHandler;
......@@ -70,7 +70,7 @@ public class CatServlet extends AbstractContainerServlet {
if (configFile != null) {
String xml = Files.forIO().readFrom(new File(configFile).getCanonicalFile(), "utf-8");
config = new DefaultXmlParser().parse(xml);
config = new DefaultDomParser().parse(xml);
}
if (config == null) {
......@@ -83,7 +83,7 @@ public class CatServlet extends AbstractContainerServlet {
if (in != null) {
String xml = Files.forIO().readFrom(in, "utf-8");
config = new DefaultXmlParser().parse(xml);
config = new DefaultDomParser().parse(xml);
}
}
} catch (Exception e) {
......
......@@ -5,14 +5,14 @@ import junit.framework.Assert;
import org.junit.Test;
import com.dianping.cat.consumer.event.model.entity.EventReport;
import com.dianping.cat.consumer.event.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.event.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.Handler.EventReportFilter;
import com.site.helper.Files;
public class EventReportFilterTest {
@Test
public void test() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("event.xml"), "utf-8");
EventReport report = parser.parse(source);
......
......@@ -5,14 +5,14 @@ import junit.framework.Assert;
import org.junit.Test;
import com.dianping.cat.consumer.transaction.model.entity.TransactionReport;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.transaction.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.Handler.TransactionReportFilter;
import com.site.helper.Files;
public class TransactionReportFilterTest {
@Test
public void test() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("transaction.xml"), "utf-8");
TransactionReport report = parser.parse(source);
......
......@@ -5,13 +5,13 @@ import org.junit.Test;
import com.dianping.cat.consumer.event.model.entity.EventName;
import com.dianping.cat.consumer.event.model.entity.EventReport;
import com.dianping.cat.consumer.event.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.event.model.transform.DefaultDomParser;
import com.site.helper.Files;
public class EventNameAggregatorTest {
@Test
public void test() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("event.xml"), "utf-8");
EventReport report = parser.parse(source);
String expected = Files.forIO().readFrom(getClass().getResourceAsStream("event-names.xml"), "utf-8");
......
......@@ -5,13 +5,13 @@ import org.junit.Test;
import com.dianping.cat.consumer.transaction.model.entity.TransactionName;
import com.dianping.cat.consumer.transaction.model.entity.TransactionReport;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.transaction.model.transform.DefaultDomParser;
import com.site.helper.Files;
public class TransactionNameAggregatorTest {
@Test
public void test() throws Exception {
DefaultXmlParser parser = new DefaultXmlParser();
DefaultDomParser parser = new DefaultDomParser();
String source = Files.forIO().readFrom(getClass().getResourceAsStream("transaction.xml"), "utf-8");
TransactionReport report = parser.parse(source);
String expected = Files.forIO().readFrom(getClass().getResourceAsStream("transaction-names.xml"), "utf-8");
......
......@@ -6,7 +6,7 @@ import org.unidal.webres.helper.Files;
import com.dianping.cat.consumer.transaction.model.entity.TransactionReport;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlBuilder;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlParser;
import com.dianping.cat.consumer.transaction.model.transform.DefaultDomParser;
import com.dianping.cat.report.page.model.transaction.TransactionReportMerger;
public class TransactionReportMergerTest {
......@@ -14,8 +14,8 @@ public class TransactionReportMergerTest {
public void testTransactionReportMerge() throws Exception {
String oldXml = Files.forIO().readFrom(getClass().getResourceAsStream("TransactionReportOld.xml"), "utf-8");
String newXml = Files.forIO().readFrom(getClass().getResourceAsStream("TransactionReportNew.xml"), "utf-8");
TransactionReport reportOld = new DefaultXmlParser().parse(oldXml);
TransactionReport reportNew = new DefaultXmlParser().parse(newXml);
TransactionReport reportOld = new DefaultDomParser().parse(oldXml);
TransactionReport reportNew = new DefaultDomParser().parse(newXml);
String expected = Files.forIO().readFrom(getClass().getResourceAsStream("TransactionReportMergeResult.xml"),
"utf-8");
TransactionReportMerger merger = new TransactionReportMerger(reportOld);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册