Examples of MockOutputPipe

eu.admire.registry.test.TestUtils.MockOutputPipe
A mock output object to assist with unit testing activities. @author The OGSA-DAI Project Team
uk.org.ogsadai.activity.MockOutputPipe
A mock output object to assist with unit testing activities. @author The OGSA-DAI Project Team

Examples of eu.admire.registry.test.TestUtils.MockOutputPipe

    {


        String sparqlQuery = "SELECT * WHERE {?s ?p ?o}";
        BlockReader input = new LiteralBlockReader(new SimpleLiteral(
                sparqlQuery));
        MockOutputPipe output = new MockOutputPipe(new Object[] {});


        mActivity.addInput("expression", input);
        mActivity.addOutput("rdfdata", output);


        mActivity.process();

View Full Code Here

Examples of eu.admire.registry.test.TestUtils.MockOutputPipe

                + "SELECT ?x ?y "
                + "WHERE {     ?x dmi:hasStructuralType ?y .  "
                + "}";
        BlockReader input = new LiteralBlockReader(new SimpleLiteral(
                sparqlQuery));
        MockOutputPipe output = new MockOutputPipe(new Object[] {});


        mActivity.addInput("expression", input);
        mActivity.addOutput("rdfdata", output);


        mActivity.process();

View Full Code Here

Examples of eu.admire.registry.test.TestUtils.MockOutputPipe

    String ouputPE = NAMESPACE + "SQLQueryStatement";
    String inputPE = NAMESPACE + "SQLStatement";


    BlockReader input1 = new LiteralBlockReader(new SimpleLiteral(ouputPE));
    BlockReader input2 = new LiteralBlockReader(new SimpleLiteral(inputPE));
    MockOutputPipe output = new MockOutputPipe(new Object[] {});


    mActivity.addInput("ontologyElement1", input1);
    mActivity.addInput("ontologyElement2", input2);
    mActivity.addOutput("inferenceResults", output);


    mActivity.process();
    System.out.println(output.getActualBlocks());
    if (output.getActualBlocks().size() > 0) {
      Assert.assertTrue(output.getActualBlocks().contains("subClassOf"));
    } else {
      Assert.assertFalse(true);
    }


  }

View Full Code Here

Examples of eu.admire.registry.test.TestUtils.MockOutputPipe

    String ouputPE = NAMESPACE + "SystemElement";
    String inputPE = NAMESPACE + "DbElement";


    BlockReader input1 = new LiteralBlockReader(new SimpleLiteral(ouputPE));
    BlockReader input2 = new LiteralBlockReader(new SimpleLiteral(inputPE));
    MockOutputPipe output = new MockOutputPipe(new Object[] {});


    mActivity.addInput("ontologyElement1", input1);
    mActivity.addInput("ontologyElement2", input2);
    mActivity.addOutput("inferenceResults", output);


    mActivity.process();
    System.out.println(output.getActualBlocks());
    if (output.getActualBlocks().size() > 0) {
      Assert.assertTrue(output.getActualBlocks().contains("equivalent"));
    } else {
      Assert.assertFalse(true);
    }


  }

View Full Code Here

Examples of eu.admire.registry.test.TestUtils.MockOutputPipe

    String ouputPE = NAMESPACE + "SQLStatement";
    String inputPE = NAMESPACE + "XQueryStatement";


    BlockReader input1 = new LiteralBlockReader(new SimpleLiteral(ouputPE));
    BlockReader input2 = new LiteralBlockReader(new SimpleLiteral(inputPE));
    MockOutputPipe output = new MockOutputPipe(new Object[] {});


    mActivity.addInput("ontologyElement1", input1);
    mActivity.addInput("ontologyElement2", input2);
    mActivity.addOutput("inferenceResults", output);


    mActivity.process();
    System.out.println(output.getActualBlocks());
    if (output.getActualBlocks().size() > 0) {
      Assert.assertTrue(output.getActualBlocks().contains("disjoint"));
    } else {
      Assert.assertFalse(true);
    }
  }

View Full Code Here

Examples of eu.admire.registry.test.TestUtils.MockOutputPipe

    String ouputPE = NAMESPACE + "FahrenheitDegrees";
    String inputPE = NAMESPACE + "CelsiusDegrees";


    BlockReader input1 = new LiteralBlockReader(new SimpleLiteral(ouputPE));
    BlockReader input2 = new LiteralBlockReader(new SimpleLiteral(inputPE));
    MockOutputPipe output = new MockOutputPipe(new Object[] {});


    mActivity.addInput("ontologyElement1", input1);
    mActivity.addInput("ontologyElement2", input2);
    mActivity.addOutput("inferenceResults", output);


    mActivity.process();
    System.out.println(output.getActualBlocks());
    if (output.getActualBlocks().size() > 0) {
      Assert.assertTrue(output.getActualBlocks().contains("convertible"));
    } else {
      Assert.assertFalse(true);
    }
  }

View Full Code Here

Examples of uk.org.ogsadai.activity.MockOutputPipe

                new Integer(0),
                ControlBlock.LIST_END
        });
        activity.addInput("columns", inputColumns);


        MockOutputPipe output = new MockOutputPipe(new Object[] {});
        activity.addOutput("data", output);
        
        activity.process();
        
        Iterator blocks = output.getActualBlocks().iterator();
        assertTrue(blocks.hasNext());
        assertEquals(ControlBlock.LIST_BEGIN, blocks.next());
        assertTrue(blocks.hasNext());
        Object block = blocks.next();
        assertTrue(block instanceof MetadataWrapper);

View Full Code Here

Examples of uk.org.ogsadai.activity.MockOutputPipe

                ControlBlock.LIST_BEGIN,
                ControlBlock.LIST_END
        });
        activity.addInput("columns", inputColumns);


        MockOutputPipe output = new MockOutputPipe(new Object[] {});
        activity.addOutput("data", output);
        
        activity.process();
        
        Iterator blocks = output.getActualBlocks().iterator();
        assertTrue(blocks.hasNext());
        assertEquals(ControlBlock.LIST_BEGIN, blocks.next());
        assertTrue(blocks.hasNext());
        Object block = blocks.next();
        assertTrue(block instanceof MetadataWrapper);

View Full Code Here

Examples of uk.org.ogsadai.activity.MockOutputPipe

                ControlBlock.LIST_BEGIN,
                ControlBlock.LIST_END
        });
        activity.addInput("columns", inputColumns);


        MockOutputPipe output = new MockOutputPipe(new Object[] {});
        activity.addOutput("data", output);
        
        try
        {
            activity.process();

View Full Code Here

Examples of uk.org.ogsadai.activity.MockOutputPipe

                ControlBlock.LIST_BEGIN,
                ControlBlock.LIST_END
        });
        activity.addInput("columns", inputColumns);


        MockOutputPipe output = new MockOutputPipe(new Object[] {});
        activity.addOutput("data", output);
        
        try
        {
            activity.process();

View Full Code Here

0 1 2 3 4

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.