Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package com.firstrain.webevents.processor;
- import java.io.StringReader;
- import java.util.ArrayList;
- import java.util.List;
- import java.util.Properties;
- import org.apache.commons.digester.Digester;
- import org.apache.log4j.Logger;
- import org.apache.log4j.PropertyConfigurator;
- import com.firstrain.common.db.config.DataSourceConfigRuleSet;
- import com.firstrain.common.db.query.mgr.QManager;
- import com.firstrain.content.pipeline.PipelineDocumentContext;
- import com.firstrain.mip.db.FR_IDBConstant;
- import com.firstrain.webevents.producer.WebEventsCatsProducer;
- import junit.framework.TestCase;
- import org.junit.Ignore;
- @Ignore
- public class CompleteEventsProcessorTest extends TestCase {
- private static final Logger LOG = Logger.getLogger(CompleteEventsProcessorTest.class);
- private Properties getBasicLog4jProperties() {
- Properties prop = new Properties();
- prop.put("log4j.rootCategory", "DEBUG, A2");
- prop.put("log4j.appender.A2", "org.apache.log4j.ConsoleAppender");
- prop.put("log4j.appender.A2.layout", "org.apache.log4j.PatternLayout");
- prop.put("log4j.appender.A2.layout.ConversionPattern", "[%-5p] [%-d] [%t] [%c{2}] - [%m]%n");
- return prop;
- }
- protected void setUp() throws Exception {
- PropertyConfigurator.configure(getBasicLog4jProperties());
- /* Log4j Properties */
- Digester digester = new Digester();
- digester.addRuleSet(new DataSourceConfigRuleSet());
- String DatabaseConfig = "<data-sources>" + "<data-source className=\"org.apache.commons.dbcp.BasicDataSource\" key=\"analyticsDB\">"
- + "<property property=\"driverClassName\" value=\"com.mysql.jdbc.Driver\"/>"
- + "<property property=\"url\" value=\"jdbc:mysql://pmysqlbe2m.firstrain.com:3307/analyticsDB\"/>"
- + "<property property=\"username\" value=\"read\"/>" + "<property property=\"password\" value=\"me!\"/>"
- + "<property property=\"maxActive\" value=\"5\"/>" + "<property property=\"maxWait\" value=\"5000\"/>"
- + "<property property=\"defaultAutoCommit\" value=\"false\"/>" + "<property property=\"defaultReadOnly\" value=\"false\"/>"
- + "<property property=\"poolPreparedStatement\" value=\"true\"/>"
- + "<property property=\"validationQuery\" value=\"select 1\"/>" + "</data-source> "
- + "<data-source className=\"org.apache.commons.dbcp.BasicDataSource\" key=\"signalsDB\">"
- + "<property property=\"driverClassName\" value=\"com.microsoft.sqlserver.jdbc.SQLServerDriver\"/>"
- + "<property property=\"url\" value=\"dbc:sqlserver://MIDB01-SITEB:1433;DatabaseName=SignalsDB;SelectMethod=direct;ApplicationName=WebVolumeEventsProcessor\"/>"
- + "<property property=\"username\" value=\"read\"/>" + "<property property=\"password\" value=\"me!\"/>"
- + "<property property=\"maxActive\" value=\"20\"/>" + "<property property=\"maxWait\" value=\"5000\"/>"
- + "<property property=\"defaultAutoCommit\" value=\"false\"/>" + "<property property=\"defaultReadOnly\" value=\"false\"/>"
- + "<property property=\"poolPreparedStatement\" value=\"true\"/>"
- + "<property property=\"validationQuery\" value=\"select 1\"/>" + "</data-source> "
- + "<data-source className=\"org.apache.commons.dbcp.BasicDataSource\" key=\"wordFreq\">"
- + "<property property=\"driverClassName\" value=\"com.mysql.jdbc.Driver\"/>"
- + "<property property=\"url\" value=\"jdbc:mysql://pmysqlbe2m.firstrain.com:3307/events\"/>"
- + "<property property=\"username\" value=\"read\"/>" + "<property property=\"password\" value=\"me!\"/>"
- + "<property property=\"maxActive\" value=\"5\"/>" + "<property property=\"maxWait\" value=\"5000\"/>"
- + "<property property=\"defaultAutoCommit\" value=\"false\"/>" + "<property property=\"defaultReadOnly\" value=\"false\"/>"
- + "<property property=\"poolPreparedStatement\" value=\"true\"/>"
- + "<property property=\"validationQuery\" value=\"select 1\"/>" + "</data-source> " + "</data-sources>";
- digester.parse(new StringReader(DatabaseConfig));
- QManager.addQueryXml(FR_IDBConstant.MIP_DB_QUERY_XML);
- }
- protected void tearDown() throws Exception {
- }
- public void testHistoricEventGeneration() throws Throwable {
- CompleteEventsProcessor cep = new CompleteEventsProcessor();
- cep.setDoCleanUp(true);
- cep.setDebugMode(true);
- cep.setDocQuality("Selective");
- cep.setEndDate("2013-07-31");
- cep.setEventsDatabase("signalsDB");
- cep.setIntraDayComputation(false);
- cep.setLiveMode(false);
- cep.setParameterId(1);
- cep.setRecompute(true);
- cep.setStatsDatabase("analyticsDB");
- cep.setStopWordsFile("C:\\FirstRain\\Java\\FREcosystemService\\conf\\stopwords.txt");
- cep.setStrtDate("2013-07-29");
- cep.setWordFreqDatabase("wordFreq");
- List<Integer> catIds = new ArrayList<Integer>();
- catIds.add(491625);
- catIds.add(135215);
- List<Integer> catStats = new ArrayList<Integer>();
- catStats.add(1);
- catStats.add(1);
- catStats.add(1);
- PipelineDocumentContext ctx = new PipelineDocumentContext();
- ctx.put(WebEventsCatsProducer.CONTEXT_DATA, catIds);
- ctx.put(WebEventsCatsProducer.CAT_DATA, catStats);
- cep.process(ctx);
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement