源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：com.gs.fw.common.mithra.test.MithraTestResource

示例1
protected void setUp() throws Exception
{
    super.setUp();

    String xmlFile = System.getProperty("mithra.xml.config");

    mithraTestResource = new MithraTestResource(xmlFile);

    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("M");
    connectionManager.setDatabaseTimeZone(TimeZone.getDefault());
    connectionManager.setDatabaseType(mithraTestResource.getDatabaseType());

    mithraTestResource.createSingleDatabase(connectionManager, "M", "testdata/mithraMatcherThreadTestSource.txt");
    mithraTestResource.setTestConnectionsOnTearDown(true);
    mithraTestResource.setUp();
}
示例2
public void testSingleDatabase() throws Exception
{
    String configFile= "mithraTestResource/MtrTestBaseRuntimeConfig.xml";
    MithraTestResource mtr1 = new MithraTestResource(configFile);

    ConnectionManagerForTests connectionManager = ConnectionManagerForBaseConfigTests.getInstance();
    connectionManager.setDefaultSource("base_config_db");
    mtr1.createSingleDatabase(connectionManager, "base_config_db", "testdata/mithraTestResource/mtrTestDataForSingleDb.txt");
    mtr1.setUp();

    Operation op = SaleFinder.all();
    SaleList list = new SaleList(op);
    int size = list.size();
    assertEquals(5, size);

    mtr1.tearDown();
}
示例3
public void testDatabaseForStringSourceaAttribute() throws Exception
{
    String configFile= "mithraTestResource/MtrTestDeskRuntimeConfig.xml";
    MithraTestResource mtr1 = new MithraTestResource(configFile);

    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    mtr1.createDatabaseForStringSourceAttribute(connectionManager,"A", "desk_db", "testdata/mithraTestResource/mtrTestDataForStringSource.txt");
    mtr1.setUp();

    Operation op = TinyBalanceFinder.businessDate().eq(new Timestamp(System.currentTimeMillis()));
    op = op.and(TinyBalanceFinder.balanceId().eq(10));
    op = op.and(TinyBalanceFinder.acmapCode().eq("A"));
    TinyBalance balance = TinyBalanceFinder.findOne(op);
    assertEquals(200, balance.getQuantity(), 0);
    mtr1.tearDown();
}
示例4
public void testDatabaseForIntSourceaAttribute() throws Exception
{
    String configFile= "mithraTestResource/MtrTestDeskRuntimeConfig.xml";
    MithraTestResource mtr1 = new MithraTestResource(configFile);

    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    mtr1.createDatabaseForIntSourceAttribute(connectionManager,1, "desk_db", "testdata/mithraTestResource/mtrTestDataForIntSource.txt");
    mtr1.setUp();

    Operation op = LocationFinder.all();
    op = op.and(LocationFinder.sourceId().eq(1));

    LocationList list = new LocationList(op);
    assertEquals(7, list.size());
    mtr1.tearDown();
}
示例5
public void testTest() throws Exception
{
    BaseDomainTestResource testResource = new BaseDomainTestResource();
    testResource.setUp();

    MithraTestResource mtr2 = new MithraTestResource("mithraTestResource/MtrTestRuntimeConfig.xml");

    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("test_db1");
    mtr2.createSingleDatabase(connectionManager, "test_db1", "testdata/mithraTestResource/mtrTestDataForMultiSingleDb.txt");
    mtr2.setUp();

    Operation orderOp = OrderFinder.all();
    OrderList orderList = new OrderList(orderOp);
    assertEquals(4, orderList.size());

    Operation sellerOp = SellerFinder.all();
    SellerList sellerList = new SellerList(sellerOp);
    assertEquals(4, sellerList.size());

    testResource.tearDown();
    mtr2.tearDown();
}
示例6
public void testTest2() throws Exception
{
    BaseDomainTestResource testResource = new BaseDomainTestResource();
    testResource.setUp();

    MithraTestResource mtr2 = new MithraTestResource("mithraTestResource/MtrTestRuntimeConfig.xml");

    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("test_db1");
    mtr2.createSingleDatabase(connectionManager, "test_db1", "testdata/mithraTestResource/mtrTestDataForMultiSingleDb.txt");
    mtr2.setUp();

    Operation orderOp = OrderFinder.all();
    OrderList orderList = new OrderList(orderOp);
    assertEquals(4, orderList.size());

    Operation prodOp = ProductSpecificationFinder.all();
    ProductSpecificationList prodList = new ProductSpecificationList(prodOp);
    assertEquals(1, prodList.size());

    testResource.tearDown();
    mtr2.tearDown();

}
示例7
public void testNestedMithraTestResource()
{
    MithraTestResource mtr1 = new MithraTestResource("mithraTestResource/MtrTestRuntimeConfigWithResourceName.xml");
    ConnectionManagerForTests cmForConfig = ConnectionManagerForTests.getInstance("mithra_qa");
    mtr1.createSingleDatabase(cmForConfig,"testdata/mithraTestResource/mtrTestDataForSingleDb.txt");
    mtr1.setUp();

    testDatabaseForStringSourceAttribute();
    testDatabaseForStringSourceAttribute();

    Operation op = SaleFinder.all();
    SaleList list = new SaleList(op);
    int size = list.size();
    assertEquals(5, size);
    mtr1.tearDown();
}
示例8
public void testAddingRuntimeConfigFile()
{
    MithraTestResource mtr1 = new MithraTestResource("mithraTestResource/MtrTestRuntimeConfigWithResourceName.xml");
    mtr1.loadMithraConfiguration("mithraTestResource/MtrAdditionalTestRuntimeConfig.xml");
    ConnectionManagerForTests cmForConfig = ConnectionManagerForTests.getInstance("mithra_qa");
    mtr1.createSingleDatabase(cmForConfig,"testdata/mithraTestResource/mtrAdditionalTestDataForSingleDb.txt");

    mtr1.setUp();

    Operation op = OrderFinder.all();
    OrderList list = new OrderList(op);
    int size = list.size();
    assertEquals(4, size);
    mtr1.tearDown();

}
示例9
public void testAddingRuntimeConfigAfterCreatingDb()
{
    MithraTestResource mtr1 = new MithraTestResource("mithraTestResource/MtrTestRuntimeConfigWithResourceName.xml");

    ConnectionManagerForTests cmForConfig = ConnectionManagerForTests.getInstance("mithra_qa");
    mtr1.createSingleDatabase(cmForConfig,"testdata/mithraTestResource/mtrAdditionalTestDataForSingleDb.txt");
    mtr1.loadMithraConfiguration("mithraTestResource/MtrAdditionalTestRuntimeConfig.xml");
    mtr1.setUp();

    Operation op = OrderFinder.all();
    OrderList list = new OrderList(op);
    int size = list.size();
    assertEquals(4, size);
    mtr1.tearDown();

}
示例10
public void testAddingRuntimeConfigAfterSetup()
{
    MithraTestResource mtr1 = new MithraTestResource("mithraTestResource/MtrTestRuntimeConfigWithResourceName.xml");

    ConnectionManagerForTests cmForConfig = ConnectionManagerForTests.getInstance("mithra_qa");
    mtr1.createSingleDatabase(cmForConfig,"testdata/mithraTestResource/mtrTestDataForSingleDb.txt");

    mtr1.setUp();
    //todo:check this with Moh
    mtr1.loadMithraConfiguration("mithraTestResource/MtrAdditionalTestRuntimeConfig.xml");
    mtr1.addTestDataToDatabase("testdata/mithraTestResource/mtrAdditionalTestDataForSingleDb.txt",cmForConfig);

    Operation op = OrderFinder.all();
    OrderList list = new OrderList(op);
    int size = list.size();
    assertEquals(4, size);
    mtr1.tearDown();

}
示例11
public void testTwoResources() throws Exception
{
    String configFile= "mithraTestResource/MohMithraRuntimeConfig.xml";
    MithraTestResource mtr1 = new MithraTestResource(configFile);
    MithraTestResource mtr2 = new MithraTestResource(configFile);
    mtr1.setDeleteOnCreate(false);
    mtr2.setDeleteOnCreate(false);
    mtr1.createSingleDatabase(ConnectionManagerForTests.getInstance("mithra_qa"), "testdata/mithraTestResource/testFileOne.txt");
    mtr2.createSingleDatabase(ConnectionManagerForTests.getInstance("mithra_qa"), "testdata/mithraTestResource/testFileTwo.txt");
    mtr1.setUp();
    mtr2.setUp();

   // assert that data from both test files is now loaded
    Operation op = SaleFinder.all();
    SaleList list = new SaleList(op);
    int size = list.size();
    assertEquals(10, size);

    mtr1.tearDown();
    mtr2.tearDown();
}
示例12
protected InputStream getConfigXml(String fileName) throws FileNotFoundException
{
    String xmlRoot = System.getProperty(MithraTestResource.ROOT_KEY);
    if (xmlRoot == null)
    {
        InputStream result = this.getClass().getClassLoader().getResourceAsStream(fileName);
        if (result == null)
        {
            throw new RuntimeException("could not find " + fileName + " in classpath. Additionally, " + MithraTestResource.ROOT_KEY + " was not specified");
        }
        return result;
    }
    else
    {
        String fullPath = xmlRoot;
        if (!xmlRoot.endsWith(File.separator))
        {
            fullPath += File.separator;
        }
        return new FileInputStream(fullPath + fileName);
    }
}
示例13
protected void setUp() throws Exception
{
    super.setUp();
    String xmlFile = System.getProperty("mithra.xml.config");

    mithraTestResource = new MithraTestResource(xmlFile);

    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("A");
    connectionManager.setDatabaseTimeZone(TimeZone.getDefault());
    connectionManager.setDatabaseType(mithraTestResource.getDatabaseType());

    mithraTestResource.createSingleDatabase(connectionManager, "A", "testdata/DbExtractorTest_source.txt");
    mithraTestResource.setTestConnectionsOnTearDown(true);
    mithraTestResource.setUp();
}
示例14
protected void setUp() throws Exception
{
    super.setUp();

    mithraTestResource = new MithraTestResource(System.getProperty("mithra.xml.config"));

    ConnectionManagerForTests lewConnectionManager = ConnectionManagerForTests.getInstance("lew");
    ConnectionManagerForTests paraConnectionManager  = ConnectionManagerForTests.getInstance("para");
    mithraTestResource.createSingleDatabase(lewConnectionManager, "testdata/lewDataSource.txt");
    mithraTestResource.createSingleDatabase(paraConnectionManager, "testdata/paraDataSource.txt");

    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("extract");
    connectionManager.setDatabaseTimeZone(TimeZone.getDefault());
    connectionManager.setDatabaseType(mithraTestResource.getDatabaseType());

    mithraTestResource.createSingleDatabase(connectionManager, "extract", "testdata/objectgraph/MithraObjectGraphExtractorTest_data.txt");
    mithraTestResource.createDatabaseForStringSourceAttribute(connectionManager, "extract", "extract", "testdata/objectgraph/MithraObjectGraphExtractorTest_dataStringSourceA.txt");
    mithraTestResource.setTestConnectionsOnTearDown(true);
    mithraTestResource.setUp();
}
示例15
protected void setupMithra()
{
    final MithraManager mithraManager = MithraManagerProvider.getMithraManager();
    final String mithraRuntimeConfig = "ReladomoJmsTestConfig.xml";
    System.setProperty("h2.additionalArguments", ";MVCC=TRUE");
    mithraTestResource = new MithraTestResource(mithraRuntimeConfig);
    ConnectionManagerForTests connectionManagerForTestTradeDb = ConnectionManagerForTests.getInstance("test_trade_db");
    mithraTestResource.createSingleDatabase(connectionManagerForTestTradeDb);

    this.mithraTestResource.setUp();

    multiThreadedTm = new MultiThreadedTm();
    mithraManager.setJtaTransactionManagerProvider(new JtaProvider()
    {
        @Override
        public TransactionManager getJtaTransactionManager()
        {
            return multiThreadedTm;
        }
    });
    mithraManager.setTransactionTimeout(180); // short timeout for testing topic processor
}
示例16
@Before
public void setUp() throws NamingException, JMSException, XAException
{
    final MithraManager mithraManager = MithraManagerProvider.getMithraManager();
    final String mithraRuntimeConfig = "ReladomoJmsTestConfig.xml";
    System.setProperty("h2.additionalArguments", ";MVCC=TRUE");
    mithraTestResource = new MithraTestResource(mithraRuntimeConfig);
    ConnectionManagerForTests connectionManagerForTestTradeDb = ConnectionManagerForTests.getInstance("test_trade_db");
    mithraTestResource.createSingleDatabase(connectionManagerForTestTradeDb);

    this.mithraTestResource.setUp();

    multiThreadedTm = new MultiThreadedTm();
    mithraManager.setJtaTransactionManagerProvider(new JtaProvider()
    {
        @Override
        public TransactionManager getJtaTransactionManager()
        {
            return multiThreadedTm;
        }
    });
    mithraManager.setTransactionTimeout(180); // short timeout for testing topic processor
}
示例17
protected void setUp()
throws Exception
{
    mithraTestResource = new MithraTestResource("MithraConfigGsIntegrator.xml");

    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("A");
    connectionManager.setDatabaseTimeZone(TimeZone.getDefault());
    connectionManager.setDatabaseType(mithraTestResource.getDatabaseType());

    mithraTestResource.createSingleDatabase(connectionManager, "A", "hsqldb/mithraGsIntegratorTestData.txt");

     mithraTestResource.setUp();
}
示例18
@Override
protected void setUp() throws Exception
{
    super.setUp();
    this.mithraTestResource = new MithraTestResource("MithraCacheTestConfig.xml");
    this.mithraTestResource.setUp();
}
示例19
@Override
protected void setUp() throws Exception
{
    super.setUp();
    this.mithraTestResource = new MithraTestResource("MithraCacheTestConfig.xml");
    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("nystlew");
    this.mithraTestResource.createSingleDatabase(connectionManager, "nystlew", "testdata/cacheloader/CacheLoaderTest_STLEW.txt");

    this.mithraTestResource.createDatabaseForStringSourceAttribute(connectionManager, NYK_REGION, "testdata/cacheloader/CacheLoaderTest_NYLEW.txt");
    this.mithraTestResource.setUp();
}
示例20
@Override
protected void setUp() throws Exception
{
    super.setUp();
    assertTrue("The refresh tests mean to run in EST. They will fail in different timezone. Set timezone on the EST on the workstation.", NYK_TIME_ZONES.contains(java.util.TimeZone.getDefault().getID()));

    this.mithraTestResource = new MithraTestResource("MithraCacheTestProcessingOnlyConfig.xml");
    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("main");
    this.mithraTestResource.createSingleDatabase(connectionManager, "main", "testdata/cacheloader/CacheLoaderTest_ProcessingOnly.txt");
    this.mithraTestResource.setUp();
}
示例21
@Override
protected void setUp() throws Exception
{
    super.setUp();
    assertTrue("The refresh tests mean to run in EST. They will fail in different timezone. Set timezone on the EST on the workstation.", nykTimeZones.contains(java.util.TimeZone.getDefault().getID()));
    this.mithraTestResource = new MithraTestResource("MithraCacheTestConfig.xml");
    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("nystlew");
    this.mithraTestResource.createSingleDatabase(connectionManager, "nystlew", "testdata/cacheloader/CacheLoaderTest_STLEW.txt");

    this.mithraTestResource.createDatabaseForStringSourceAttribute(connectionManager, NYK_REGION, "testdata/cacheloader/CacheLoaderTest_NYLEW.txt");
    this.mithraTestResource.createDatabaseForStringSourceAttribute(connectionManager, LN1_REGION, "testdata/cacheloader/CacheLoaderTest_LN1LEW.txt");
    this.mithraTestResource.createDatabaseForStringSourceAttribute(connectionManager, LN2_REGION, "testdata/cacheloader/CacheLoaderTest_LN2LEW.txt");
    this.mithraTestResource.setUp();
}
示例22
@Override
protected void setUp() throws Exception
{
    super.setUp();
    this.mithraTestResource = new MithraTestResource("MithraCacheTestConfig.xml");
    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("nystlew");
    this.mithraTestResource.createSingleDatabase(connectionManager, "nystlew", "testdata/cacheloader/CacheLoaderTest_STLEW.txt");

    this.mithraTestResource.createDatabaseForStringSourceAttribute(connectionManager, NYK_REGION, "testdata/cacheloader/CacheLoaderTest_NYLEW.txt");
    this.mithraTestResource.setUp();
}
示例23
@Override
protected void setUp() throws Exception
{
    super.setUp();
    this.mithraTestResource = new MithraTestResource("MithraCacheTestConfig.xml");
    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("nystlew");
    this.mithraTestResource.createSingleDatabase(connectionManager, "nystlew", "testdata/cacheloader/CacheLoaderTest_STLEW.txt");

    this.mithraTestResource.createDatabaseForStringSourceAttribute(connectionManager, NYK_REGION, "testdata/cacheloader/CacheLoaderTest_NYLEW.txt");
    this.mithraTestResource.setUp();
}
示例24
@Override
protected void setUp() throws Exception
{
    super.setUp();
    this.mithraTestResource = new MithraTestResource("MithraCacheTestConfig.xml");
    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("nystlew");
    this.mithraTestResource.createSingleDatabase(connectionManager, "nystlew", "testdata/cacheloader/CacheLoaderTest_STLEW.txt");

    this.mithraTestResource.createDatabaseForStringSourceAttribute(connectionManager, NYK_REGION, "testdata/cacheloader/CacheLoaderTest_NYLEW.txt");
    this.mithraTestResource.setUp();
}
示例25
@Override
protected void setUp() throws Exception
{
    super.setUp();
    this.mithraTestResource = new MithraTestResource("MithraCacheTestConfig.xml");
    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("nystlew");
    this.mithraTestResource.createSingleDatabase(connectionManager, "nystlew", "testdata/cacheloader/CacheLoaderTest_STLEW.txt");

    this.mithraTestResource.createDatabaseForStringSourceAttribute(connectionManager, NYK_REGION, "testdata/cacheloader/CacheLoaderTest_NYLEW.txt");
    this.mithraTestResource.setUp();
}
示例26
@Override
protected void setUp() throws Exception
{
    MithraRuntimeType mithraRuntimeType = new MithraRuntimeType();
    ConnectionManagerType connectionManagerType = new ConnectionManagerType();
    connectionManagerType.setClassName(ConnectionManagerForTests.class.getName());
    connectionManagerType.setMithraObjectConfigurations(FastList.newListWith(
            getMithraObjectConfigurationType(TestOverlapFullyMilestoned.class),
            getMithraObjectConfigurationType(TestOverlapBusinessDateMilestoned.class),
            getMithraObjectConfigurationType(TestOverlapProcessingDateMilestoned.class)));
    mithraRuntimeType.setConnectionManagers(FastList.newListWith(connectionManagerType));

    this.mithraTestResource = new MithraTestResource(mithraRuntimeType);

    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance();
    connectionManager.setDefaultSource("A");
    connectionManager.setDatabaseTimeZone(TimeZone.getDefault());
    connectionManager.setDatabaseType(this.mithraTestResource.getDatabaseType());

    this.mithraTestResource.createSingleDatabase(connectionManager, "A", "testdata/overlapTestDataBroken.txt");
    this.mithraTestResource.setTestConnectionsOnTearDown(true);

    executeSql("DROP INDEX IF EXISTS I_TEST_OVERLAP_FULLY_MILESTONED_F");
    executeSql("DROP INDEX IF EXISTS I_TEST_OVERLAP_FULLY_MILESTONED_T");
    executeSql("DROP INDEX IF EXISTS I_TEST_OVERLAP_BUSINESS_DATE_MILESTONED_F");
    executeSql("DROP INDEX IF EXISTS I_TEST_OVERLAP_BUSINESS_DATE_MILESTONED_T");
    executeSql("DROP INDEX IF EXISTS I_TEST_OVERLAP_PROCESSING_DATE_MILESTONED_F");
    executeSql("DROP INDEX IF EXISTS I_TEST_OVERLAP_PROCESSING_DATE_MILESTONED_T");

    this.mithraTestResource.setUp();

}
示例27
private void setUpMithraTestResource()
        throws Exception
{
    String configFile= "mithraTestResource/MtrTestBaseRuntimeConfig.xml";
    mtr1 = new MithraTestResource(configFile);
    mtr1.setDeleteOnCreate(false);
    ConnectionManagerForTests baseConnectionManager = ConnectionManagerForBaseConfigTests.getInstance();
    baseConnectionManager.setDefaultSource("base_config_db");
    mtr1.createSingleDatabase(baseConnectionManager, "base_config_db", null);
    mtr1.setUp();
}
示例28
private void setUpMithraTestResource()
        throws Exception
{
    String configFile= "mithraTestResource/MtrTestPricingRuntimeConfig.xml";
    String testDataFile = "mithraTestResource/mtrTestDataForPricingDb.txt";
    mtr1 = new MithraTestResource(configFile);
    ConnectionManagerForTests baseConnectionManager = ConnectionManagerForPricingTests.getInstance();
    baseConnectionManager.setDefaultSource("PRICING");
    mtr1.createSingleDatabase(baseConnectionManager, "PRICING", testDataFile);
    mtr1.setUp();
}
示例29
public void testCreateSingleDatabase()
{
    MithraTestResource mtr1 = new MithraTestResource("mithraTestResource/MtrTestRuntimeConfigWithResourceName.xml");
    ConnectionManagerForTests cmForConfig = ConnectionManagerForTests.getInstance("mithra_qa");
    mtr1.createSingleDatabase(cmForConfig,"testdata/mithraTestResource/mtrTestDataForSingleDb.txt");
    mtr1.setUp();

    Operation op = SaleFinder.all();
    SaleList list = new SaleList(op);
    int size = list.size();
    assertEquals(5, size);
    mtr1.tearDown();
}
示例30
public void testDatabaseForStringSourceAttribute()
{
    String configFile= "mithraTestResource/MtrTestDeskRuntimeConfigWithResourceName.xml";
    MithraTestResource mtr1 = new MithraTestResource(configFile);

    ConnectionManagerForTests connectionManager = ConnectionManagerForTests.getInstance("deskDb");
    mtr1.createDatabaseForStringSourceAttribute(connectionManager,"A", "testdata/mithraTestResource/mtrTestDataForStringSource.txt");
    mtr1.setUp();

    assertTestDatabaseForStringSourceAttribute();
    mtr1.tearDown();
}