Package org.apache.tuscany.das.rdb

Examples of org.apache.tuscany.das.rdb.DAS.createCommand()

42
43
44
45
46
47
48
49
50
51
52
        super.tearDown();
    }

    public void testRead() throws Exception {
        DAS das = DAS.FACTORY.createDAS(getConnection());
        Command getOrderDetails = das.createCommand("Select * from ORDERDETAILS where ORDERID = ? AND PRODUCTID = ?");

        getOrderDetails.setParameter(1, Integer.valueOf(1));
        getOrderDetails.setParameter(2, Integer.valueOf(1));

        DataObject root = getOrderDetails.executeQuery();
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
    }

    public void testReadModifyWrite2() throws Exception {
        DAS das = DAS.FACTORY.createDAS(getConfig("OrdersOrderDetailsConfig.xml"), getConnection());
        Command getOrderDetails = das.createCommand("Select * from ORDERDETAILS where ORDERID = 1 AND PRODUCTID = 1");

        DataObject root = getOrderDetails.executeQuery();

        DataObject orderDetails = (DataObject) root.get("ORDERDETAILS[1]");
        assertEquals(1.1f, orderDetails.getFloat("PRICE"), 0.01);
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
    }

    public void testReadOrdersAndDetails2() throws Exception {
        DAS das = DAS.FACTORY.createDAS(getConfig("OrdersOrderDetailsConfig.xml"), getConnection());
        Command read = das.createCommand("SELECT * FROM ANORDER LEFT JOIN ORDERDETAILS "
                + "ON ANORDER.ID = ORDERDETAILS.ORDERID ORDER BY ANORDER.ID");

        DataObject root = read.executeQuery();

        DataObject firstOrder = root.getDataObject("ANORDER[1]");
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
     * Read various types.
     */
    public void testRead() throws Exception {
        DAS das = DAS.FACTORY.createDAS(getConnection());
        // Read customer 1
        Command select = das.createCommand("Select * from TYPETEST where ID = 1");
        DataObject root = select.executeQuery();

        DataObject types = (DataObject) root.get("TYPETEST[1]");

        java.sql.Timestamp ts = (java.sql.Timestamp) types.get("ATIMESTAMP");
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
        c.setAddress("400 Fourth Street");

        DAS das = DAS.FACTORY.createDAS(helper.getConfig(), getConnection());
        das.applyChanges(graph);

        Command cmd = das.createCommand("select * from CUSTOMER order by ID desc");
        graph = cmd.executeQuery();
        assertEquals(6, graph.getList("Customer").size());
        assertEquals("Smith", graph.getDataObject("Customer[1]").getString("lastName"));
        assertEquals("400 Fourth Street", graph.getDataObject("Customer[1]").getString("address"));

View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
    }

    public void testSingleTableMerge() throws Exception {
        DAS das = DAS.FACTORY.createDAS(getConnection());
        Command select = das.createCommand("Select ID, LASTNAME, ADDRESS from CUSTOMER where ID <= ?");
        select.setParameter(1, "3");
        DataObject graph1 = select.executeQuery();
        assertEquals(3, graph1.getList("CUSTOMER").size());

        select.setParameter(1, "5");
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
        assertEquals(5, mergedGraph.getList("CUSTOMER").size());
    }

    public void testSingleTableMergeThreeGraphs() throws Exception {
        DAS das = DAS.FACTORY.createDAS(getConnection());
        Command select = das.createCommand("Select ID, LASTNAME, ADDRESS from CUSTOMER where ID <= ?");
        select.setParameter(1, "3");
        DataObject graph1 = select.executeQuery();
        assertEquals(3, graph1.getList("CUSTOMER").size());

        select.setParameter(1, "4");
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
    }

    public void testMultiTableMerge2() throws Exception {
        DAS das = DAS.FACTORY.createDAS(getConfig("CustomersOrdersConfig.xml"), getConnection());
        // Read some customers and related orders
        Command select = das.createCommand("SELECT * FROM CUSTOMER LEFT JOIN ANORDER ON "
                + "CUSTOMER.ID = ANORDER.CUSTOMER_ID where CUSTOMER.ID = ?");

        select.setParameter(1, Integer.valueOf(1));
        DataObject graph1 = select.executeQuery();

View Full Code Here
161
162
163
164
165
166
167
168
169
170
171
    }

    public void testMultiTableAppendSingleTable2() throws Exception {
        DAS das = DAS.FACTORY.createDAS(getConfig("CustomersOrdersConfig.xml"), getConnection());
        // Read some customers and related orders
        Command select = das.createCommand("SELECT * FROM CUSTOMER LEFT JOIN ANORDER ON "
                + "CUSTOMER.ID = ANORDER.CUSTOMER_ID where CUSTOMER.ID = ?");

        select.setParameter(1, Integer.valueOf(1));
        DataObject graph1 = select.executeQuery();

View Full Code Here
171
172
173
174
175
176
177
178
179
180
181
        DataObject customer = (DataObject) graph1.getList("CUSTOMER").get(0);
        assertEquals(2, customer.getList("orders").size());

        DAS das2 = DAS.FACTORY.createDAS(getConnection());
        Command select2 = das2.createCommand("select * from ANORDER");
        DataObject graph2 = select2.executeQuery();
        assertEquals(4, graph2.getList("ANORDER").size());

        GraphMerger merger = new GraphMerger();
        merger.addPrimaryKey("CUSTOMER.ID");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.