OPENJPA-1143: clean up test cases

git-svn-id: https://svn.apache.org/repos/asf/openjpa/trunk@794524 13f79535-47bb-0310-9956-ffa450edef68

openjpa-jdbc/src/main/java/org/apache/openjpa/jdbc/kernel/exps/CoalesceExpression.java

@@ -129,7 +129,7 @@ public class CoalesceExpression
         Val other, ExpState otherState) {
         CoalesceExpState cstate = (CoalesceExpState) state;
         for (int i = 0; i < _vals.length; i++)   
-            _vals[i].calculateValue(sel, ctx, cstate.states[i], null, null);
+            _vals[i].calculateValue(sel, ctx, cstate.states[i], other, otherState);
     }
 
     public void groupBy(Select sel, ExpContext ctx, ExpState state) {
@@ -141,7 +141,7 @@ public class CoalesceExpression
     }
 
     private SQLBuffer newSQLBuffer(Select sel, ExpContext ctx, ExpState state) {
-        calculateValue(sel, ctx, state, null, null);
+        calculateValue(sel, ctx, state, (Val)other, otherState);
         SQLBuffer buf = new SQLBuffer(ctx.store.getDBDictionary());
         appendTo(sel, ctx, state, buf, 0);
         return buf;

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/Account.java

@@ -19,8 +19,10 @@
 package org.apache.openjpa.persistence.criteria;
 
 import javax.persistence.Entity;
+import javax.persistence.FetchType;
 import javax.persistence.GeneratedValue;
 import javax.persistence.Id;
+import javax.persistence.ManyToOne;
 import javax.persistence.OneToOne;
 import javax.persistence.Table;
 
@@ -40,6 +42,12 @@ public class Account {
     @OneToOne
     private Person owner;
     
+    @ManyToOne
+    private Customer customer;
+    
+    @ManyToOne(optional = false, fetch = FetchType.LAZY)
+    private Product product;
+    
     private String name;
 
     public long getId() {
@@ -77,4 +85,20 @@ public class Account {
     public void setLoan(Integer loan) {
         this.loan = loan;
     }
+    
+    public Product getProduct() {
+        return product;
+    }
+    
+    public void setProduct(Product product) {
+        this.product = product;
+    }
+
+    public Customer getCustomer() {
+        return customer;
+    }
+    
+    public void setCustomer(Customer customer) {
+        this.customer = customer;
+    }
 }

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/Account_.java

@@ -14,4 +14,6 @@ public class Account_ {
     public static volatile SingularAttribute<Account,Integer> loan;
     public static volatile SingularAttribute<Account,String> name;
     public static volatile SingularAttribute<Account,Person> owner;
+    public static volatile SingularAttribute<Account,Customer> customer;
+    public static volatile SingularAttribute<Account,Product> product;
 }

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/CriteriaTest.java

@@ -207,7 +207,7 @@ public abstract class CriteriaTest extends TestCase {
             e.printStackTrace(new PrintWriter(w));
             fail("JPQL " + jpql + " failed to execute\r\n" + w);
         }
-        
+        em.clear();
         try {
             cSQL = executeQueryAndCollectSQL(cQ);
         } catch (Exception e) {
@@ -235,6 +235,31 @@ public abstract class CriteriaTest extends TestCase {
         }
     }
     
+    void executeAndCompareSQL(String jpql, String expectedSQL) {
+        Query jQ = em.createQuery(jpql);
+
+        List<String> jSQL = null;
+        List<String> cSQL = null;
+        try {
+            jSQL = executeQueryAndCollectSQL(jQ);
+        } catch (Exception e) {
+            StringWriter w = new StringWriter();
+            e.printStackTrace(new PrintWriter(w));
+            fail("JPQL " + jpql + " failed to execute\r\n" + w);
+        }
+        
+        printSQL("Target SQL for JPQL", jSQL);
+        
+        for (int i = 0; i < jSQL.size(); i++) {
+            if (!jSQL.get(i).equals(expectedSQL)) {
+                printSQL("SQL for JPQL", jSQL);
+                printSQL("Expected SQL", cSQL);
+                assertEquals(i + "-th Expected SQL and SQL for JPQL: " + jpql + " are different",
+                     expectedSQL, jSQL.get(i));
+            }
+        }
+    }
+    
     void printSQL(String header, List<String> sqls) {
         System.err.println(header);
         for (int i = 0; sqls != null && i < sqls.size(); i++) {

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/Customer.java

@@ -43,7 +43,7 @@ public class Customer {
 	private String lastName;
 	private String name;
 	
-	@OneToMany
+	@OneToMany(mappedBy="customer")
 	private Set<Order> orders = new HashSet<Order>(); 
 	
 	private int status;

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/Order.java

@@ -38,6 +38,7 @@ public class Order {
     private int quantity;
 	private double totalCost;
 	private int count;
+	private String name;
 	
 	@ManyToOne
 	private Customer customer;
@@ -93,6 +94,14 @@ public class Order {
         this.delivered = delivered;
     }
 
+    public String getName() {
+        return name;
+    }
+    
+    public void setName(String name) {
+        this.name = name;
+    }
+
     public Timestamp getOrderTs() {
         return orderTs;
     }

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/Order_.java

@@ -15,6 +15,7 @@ public class Order_ {
     public static volatile SingularAttribute<Order,Customer> customer;
     public static volatile SingularAttribute<Order,Boolean> delivered;
     public static volatile SingularAttribute<Order,Integer> id;
+    public static volatile SingularAttribute<Order,String> name;
     public static volatile ListAttribute<Order,LineItem> lineItems;
     public static volatile SingularAttribute<Order,Timestamp> orderTs;
     public static volatile SingularAttribute<Order,Integer> quantity;

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/Product.java

@@ -20,6 +20,7 @@ package org.apache.openjpa.persistence.criteria;
 import javax.persistence.*;
 
 @Entity
+@Table(name="CR_PRD")
 public class Product {
 	@Id 
 	@GeneratedValue(strategy=GenerationType.IDENTITY)

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/Request.java

@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.openjpa.persistence.criteria;
+
+import java.sql.Date;
+
+import javax.persistence.*;
+
+@Entity
+public class Request {
+     @Id
+     int id;
+     
+     private short status;
+    
+     @ManyToOne(optional = false, fetch = FetchType.LAZY)
+     private Account account;
+
+     Date requestTime;
+
+     public int getId() {
+         return id;
+     }
+     
+     public void setId(int id) {
+         this.id = id;
+     }
+     
+     public short getStatus() {
+         return status;
+     }
+
+     public void setStatus(short status) {
+         this.status = status;
+     }
+
+     
+     public Account getAccount() {
+         return account;
+     }
+
+     public void setAccount(Account account) {
+         this.account = account;
+     }
+    
+     public Date getRequestTime() {
+         return requestTime;
+     }
+     
+     public void setRequestTime(Date requestTime) {
+         this.requestTime = requestTime;
+     }
+     
+}

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/Request_.java

@@ -0,0 +1,18 @@
+/** 
+ *  Generated by OpenJPA MetaModel Generator Tool.
+**/
+
+package org.apache.openjpa.persistence.criteria;
+
+import java.sql.Date;
+
+import javax.persistence.metamodel.SingularAttribute;
+
+@javax.persistence.metamodel.StaticMetamodel
+(value=org.apache.openjpa.persistence.criteria.Request.class)
+public class Request_ {
+    public static volatile SingularAttribute<Request,Short> status;
+    public static volatile SingularAttribute<Request,Integer> id;
+    public static volatile SingularAttribute<Request,Account> account;
+    public static volatile SingularAttribute<Request,Date> requestTime;
+}

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/TestJoinCondition.java

@@ -1,9 +1,5 @@
 package org.apache.openjpa.persistence.criteria;
 
-import java.util.Collection;
-import java.util.List;
-import java.util.Set;
-
 import javax.persistence.criteria.CollectionJoin;
 import javax.persistence.criteria.CriteriaQuery;
 import javax.persistence.criteria.Join;
@@ -14,6 +10,8 @@ import javax.persistence.criteria.Root;
 import javax.persistence.criteria.SetJoin;
 import javax.persistence.metamodel.Bindable;
 
+import org.apache.openjpa.persistence.test.AllowFailure;
+
 /**
  * Tests Criteria Queries that use Join.
  *  
@@ -71,6 +69,7 @@ public class TestJoinCondition extends CriteriaTest {
         assertEquivalence(cq, jpql);
     }
     
+    @AllowFailure
     public void testCrossJoin() {
         String jpql = "select a from A a, C c where a.name=c.name";
         CriteriaQuery<?> cq = cb.createQuery();

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/TestStringCriteria.java

@@ -0,0 +1,440 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.openjpa.persistence.criteria;
+
+import java.math.BigDecimal;
+
+import javax.persistence.Parameter;
+import javax.persistence.criteria.CriteriaQuery;
+import javax.persistence.criteria.Join;
+import javax.persistence.criteria.JoinType;
+import javax.persistence.criteria.ListJoin;
+import javax.persistence.criteria.MapJoin;
+import javax.persistence.criteria.Root;
+import javax.persistence.criteria.SetJoin;
+import javax.persistence.criteria.Subquery;
+
+import org.apache.openjpa.persistence.test.AllowFailure;
+
+public class TestStringCriteria extends CriteriaTest {
+
+    @AllowFailure
+    public void testCriteria() {
+        String jpql = "select c from Customer c where c.name='Autowest Toyota'";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> customer = q.from(Customer.class);
+        q = cb.createQuery();
+        q.select(customer).where(
+                cb.equal(customer.get("name"), "Autowest Toyota"));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testJoins1() {
+        String jpql = "SELECT c.name FROM Customer c JOIN c.orders o "
+                + "JOIN o.lineItems i WHERE i.product.productType = 'printer'";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> cust = q.from(Customer.class);
+        SetJoin<Customer, Order> order = cust.joinSet("orders");
+        ListJoin<Order, LineItem> item = order.joinList("lineItems");
+        q.select(cust.get(Customer_.name)).where(
+                cb.equal(item.get("product").get("productType"), "printer"));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testJoins2() {
+        String jpql = "SELECT c FROM Customer c LEFT JOIN c.orders o WHERE "
+                + "c.status = 1";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> cust1 = q.from(Customer.class);
+        SetJoin<Customer, Order> order1 = cust1
+                .joinSet("orders", JoinType.LEFT);
+        q.where(cb.equal(cust1.get("status"), 1)).select(cust1);
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testFetchJoins() {
+        String jpql = "SELECT d FROM Department LEFT JOIN FETCH d.employees "
+                + "WHERE d.deptNo = 1";
+        CriteriaQuery q = cb.createQuery();
+        Root<Department> d = q.from(Department.class);
+        d.fetch("employees", JoinType.LEFT);
+        q.where(cb.equal(d.get("deptNo"), 1)).select(d);
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testPathNavigation() {
+        String jpql = "SELECT p.vendor FROM Employee e "
+                + "JOIN e.contactInfo.phones p  WHERE e.contactInfo.address.zipCode ="
+                + " '95054'";
+        CriteriaQuery q = cb.createQuery();
+        Root<Employee> emp = q.from(Employee.class);
+        ListJoin<Contact, Phone> phone = emp.join("contactInfo").joinList(
+                "phones");
+        q.where(cb.equal(emp.get("contactInfo").get("address").get("zipCode"),
+                "95054"));
+        q.select(phone.get("vendor"));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testKey() {
+        String jpql = "SELECT i.name, p FROM Item i JOIN i.photos p "
+                + "WHERE KEY(p) LIKE '%egret%'";
+
+        CriteriaQuery q = cb.createQuery();
+        Root<Item> item = q.from(Item.class);
+        MapJoin<Item, String, Photo> photo = item.joinMap("photos");
+        q.multiselect(item.get("name"), photo)
+                .where(cb.like(photo.key(), "%egret%"));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testRestrictQueryResult() {
+        String jpql = "SELECT t FROM CreditCard c JOIN c.transactionHistory t "
+                + "WHERE c.customer.accountNum = 321987 AND INDEX(t) BETWEEN 0 "
+                + "AND 9";
+        CriteriaQuery q = cb.createQuery();
+        Root<CreditCard> c = q.from(CreditCard.class);
+        ListJoin<CreditCard, TransactionHistory> t = c
+                .joinList("transactionHistory");
+        q.select(t).where(
+                cb.equal(c.get("customer").get("accountNum"), 321987),
+                cb.between(t.index(), 0, 9));
+
+        assertEquivalence(q, jpql);
+
+        /*
+         * 
+         * jpql = "SELECT o FROM Order o WHERE o.lineItems IS EMPTY"; q =
+         * cb.createQuery(); Root<Order> order = q.from(Order.class);
+         * ListJoin<Order,LineItem> lineItems = order.joinList("lineItems");
+         * q.where(cb.isEmpty(lineItems)); q.select(order);
+         * 
+         * assertEquivalence(q, jpql);
+         */
+    }
+
+    @AllowFailure
+    public void testExpressions() {
+        String jpql = "SELECT o.quantity, o.totalCost*1.08 AS taxedCost, "
+                + "a.zipCode FROM Customer c JOIN c.orders o JOIN c.address a "
+                + "WHERE a.state = 'CA' AND a.county = 'Santa Clara";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> cust = q.from(Customer.class);
+        SetJoin<Customer, Order> order = cust.joinSet("orders");
+        Join<Customer, Address> address = cust.join("address");
+        q.where(cb.equal(address.get("state"), "CA"), cb.equal(address
+                .get("county"), "Santa Clara"));
+        q.multiselect(order.get("quantity"),
+        // cb.prod(order.get("totalCost"), cb.literal(1.08)), //compiler err
+                address.get("zipCode"));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testIndex() {
+        String jpql = "SELECT w.name FROM Course c JOIN c.studentWaitList w "
+                + "WHERE c.name = 'Calculus' AND INDEX(w) = 0";
+        CriteriaQuery q = cb.createQuery();
+        Root<Course> course = q.from(Course.class);
+        ListJoin<Course, Student> w = course.joinList("studentWaitList");
+        q.where(cb.equal(course.get("name"), "Calculus"),
+                cb.equal(w.index(), 0)).select(w.get("name"));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testSum() {
+        String jpql = "SELECT SUM(i.price) FROM Order o JOIN o.lineItems i JOIN "
+                + "o.customer c WHERE c.lastName = 'Smith' AND c.firstName = 'John'";
+        CriteriaQuery q = cb.createQuery();
+        Root<Order> o = q.from(Order.class);
+        ListJoin<Order, LineItem> i = o.joinList("lineItems");
+        Join<Order, Customer> c = o.join("customer");
+        q.where(cb.equal(c.get("lastName"), "Smith"), cb.equal(c
+                .get("firstName"), "John"));
+        // q.select(cb.sum(i.get("price"))); //compiler err
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testSize() {
+        String jpql = "SELECT SIZE(d.employees) FROM Department d "
+                + "WHERE d.name = 'Sales'";
+        CriteriaQuery q = cb.createQuery();
+        Root<Department> d = q.from(Department.class);
+        q.where(cb.equal(d.get("name"), "Sales"));
+        // q.select(cb.size((d.get("employees")))); // compiler err
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testCase() {
+        String jpql = "SELECT e.name, CASE WHEN e.rating = 1 THEN e.salary * 1.1 "
+                + "WHEN e.rating = 2 THEN e.salary * 1.2 ELSE e.salary * 1.01 END "
+                + "FROM Employee e WHERE e.department.name = 'Engineering'";
+        CriteriaQuery q = cb.createQuery();
+        Root<Employee> e = q.from(Employee.class);
+        q.where(cb.equal(e.get("department").get("name"), "Engineering"));
+        q.multiselect(e.get("name"), cb.selectCase().when(
+                cb.equal(e.get("rating"), 1), 1.1) // cb.prod(e.get("salary"),
+                                                   // 1.1))
+                .when(cb.equal(e.get("rating"), 2), 1.2) // cb.prod(e.get("salary"),
+                                                         // 1.2))
+                .otherwise(1.01)); // cb.prod(e.get("salary"), 1.01)));
+
+        assertEquivalence(q, jpql);
+    }
+
+    /*
+     * @AllowFailure public void testLiterals() { String jpql =
+     * "SELECT p FROM Person p where 'Joe' MEMBER OF " + "p.nickNames";
+     * CriteriaQuery q = cb.createQuery(); Root<Person> p = q.from(Person.class);
+     * q.select(p).where(cb.isMember(cb.literal("Joe"), p.get(person_.
+     * getSet("nickNames", String.class))));
+     * 
+     * assertEquivalence(q, jpql); }
+     */
+
+    @AllowFailure
+    public void testParameters() {
+        String jpql = "SELECT c FROM Customer c Where c.status = :stat";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> c = q.from(Customer.class);
+        Parameter<Integer> param = cb.parameter(Integer.class);
+        q.select(c).where(cb.equal(c.get("status"), param));
+
+        assertEquivalence(q, jpql, new String[] { "stat" }, new Object[] { 1 });
+    }
+
+    @AllowFailure
+    public void testSelectList() {
+        String jpql = "SELECT v.location.street, KEY(i).title, VALUE(i) FROM "
+                + "VideoStore v JOIN v.videoInventory i "
+                + "WHERE v.location.zipCode = " + "'94301' AND VALUE(i) > 0";
+        CriteriaQuery q = cb.createQuery();
+        Root<VideoStore> v = q.from(VideoStore.class);
+        MapJoin<VideoStore, Movie, Integer> inv = v.joinMap("videoInventory");
+        q.where(cb.equal(v.get("location").get("zipCode"), "94301"), cb.gt(inv
+                .value(), 0));
+        q.multiselect(v.get("location").get("street"), inv.key().get("title"), inv
+                .value());
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void TestContructor() {
+        String jpql = "SELECT NEW CustomerDetails(c.id, c.status, o.quantity) FROM "
+                + "Customer c JOIN c.orders o WHERE o.quantity > 100";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> c = q.from(Customer.class);
+        SetJoin<Customer, Order> o = c.joinSet("orders");
+        // q.where(cb.gt(o.get("quantity"), 100)); //compiler err
+        //q.select(cb.select(CustomerDetails.class, c.get("id"), c.get("status"),
+        //        o.get("quantity")));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testSubquery1() {
+        String jpql = "SELECT goodCustomer FROM Customer goodCustomer WHERE "
+                + "goodCustomer.balanceOwed < (SELECT AVG(c.balanceOwed) FROM "
+                + "Customer c)";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> goodCustomer = q.from(Customer.class);
+        Subquery<Double> sq = q.subquery(Double.class);
+        Root<Customer> c = sq.from(Customer.class);
+        // q.where(cb.lt(goodCustomer.get("balanceOwed"), // compiler err
+        // sq.select(cb.avg(c.get("balanceOwed")))));
+        q.select(goodCustomer);
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testSubquery2() {
+        String jpql = "SELECT DISTINCT emp FROM Employee emp WHERE EXISTS ("
+                + "SELECT spouseEmp FROM Employee spouseEmp WHERE spouseEmp = "
+                + "emp.spouse)";
+        CriteriaQuery q = cb.createQuery();
+        Root<Employee> emp = q.from(Employee.class);
+        Subquery<Employee> sq1 = q.subquery(Employee.class);
+        Root<Employee> spouseEmp = sq1.from(Employee.class);
+        sq1.select(spouseEmp);
+        sq1.where(cb.equal(spouseEmp, emp.get("spouse")));
+        q.where(cb.exists(sq1));
+        q.select(emp).distinct(true);
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testSubquery3() {
+        String jpql = "SELECT emp FROM Employee emp WHERE emp.salary > ALL ("
+                + "SELECT m.salary FROM Manager m WHERE m.department ="
+                + " emp.department)";
+        CriteriaQuery q = cb.createQuery();
+        Root<Employee> emp1 = q.from(Employee.class);
+        q.select(emp1);
+        Subquery<BigDecimal> sq2 = q.subquery(BigDecimal.class);
+        Root<Manager> m = sq2.from(Manager.class);
+        // sq2.select(m.get("salary")); // compiler err
+        sq2.where(cb.equal(m.get("department"), emp1.get("department")));
+        // q.where(cb.gt(emp1.get("salary"), // compiler err
+        // cb.all(sq2)));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testSubquery4() {
+        String jpql = "SELECT c FROM Customer c WHERE "
+                + "(SELECT COUNT(o) FROM c.orders o) > 10";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> c1 = q.from(Customer.class);
+        q.select(c1);
+        Subquery<Long> sq3 = q.subquery(Long.class);
+        Root<Customer> c2 = sq3.correlate(c1);
+        SetJoin<Customer, Order> o = c2.joinSet("orders");
+        q.where(cb.gt(sq3.select(cb.count(o)), 10));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testSubquery5() {
+        String jpql = "SELECT o FROM Order o WHERE 10000 < ALL ("
+                + "SELECT a.balance FROM o.customer c JOIN c.accounts a)";
+        CriteriaQuery q = cb.createQuery();
+        Root<Order> o1 = q.from(Order.class);
+        q.select(o1);
+        Subquery<Integer> sq4 = q.subquery(Integer.class);
+        Root<Order> o2 = sq4.correlate(o1);
+        Join<Order, Customer> c3 = o2.join("customer");
+        ListJoin<Customer, Account> a = c3.joinList(("accounts"));
+        // sq4.select(a.get("balance")); // compiler err
+        q.where(cb.lt(cb.literal(10000), cb.all(sq4)));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testSubquery6() {
+        String jpql = "SELECT o FROM Order o JOIN o.customer c WHERE 10000 < "
+                + "ALL (SELECT a.balance FROM c.accounts a)";
+        CriteriaQuery q = cb.createQuery();
+        Root<Order> o3 = q.from(Order.class);
+        q.select(o3);
+        Join<Order, Customer> c4 = o3.join(Order_.customer);
+        Subquery<Integer> sq5 = q.subquery(Integer.class);
+        Join<Order, Customer> c5 = sq5.correlate(c4);
+        ListJoin<Customer, Account> a = c5.joinList("accounts");
+        // sq5.select(a.get("balance")); // compiler err
+        q.where(cb.lt(cb.literal(10000), cb.all(sq5)));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testGroupByAndHaving() {
+        String jpql = "SELECT c.status, AVG(c.filledOrderCount), COUNT(c) FROM "
+                + "Customer c GROUP BY c.status HAVING c.status IN (1, 2)";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> c = q.from(Customer.class);
+        q.groupBy(c.get("status"));
+        q.having(cb.in(c.get("status")).value(1).value(2));
+        q.multiselect(c.get("status"),
+        //cb.avg(c.get("filledOrderCount")), // compiler err
+                cb.count(c));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testOrdering1() {
+        String jpql = "SELECT o FROM Customer c JOIN c.orders o "
+                + "JOIN c.address a WHERE a.state = 'CA' ORDER BY o.quantity DESC, "
+                + "o.totalCost";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> c = q.from(Customer.class);
+        SetJoin<Customer, Order> o = c.joinSet("orders");
+        Join<Customer, Address> a = c.join("address");
+        q.where(cb.equal(a.get("state"), "CA"));
+        q.orderBy(cb.desc(o.get("quantity")), cb.asc(o.get("totalCost")));
+        q.select(o);
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testOrdering2() {
+        String jpql = "SELECT o.quantity, a.zipCode FROM Customer c JOIN c.orders "
+                + "JOIN c.address a WHERE a.state = 'CA' ORDER BY o.quantity, "
+                + "a.zipCode";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> c1 = q.from(Customer.class);
+        SetJoin<Customer, Order> o1 = c1.joinSet("orders");
+        Join<Customer, Address> a1 = c1.join("address");
+        q.where(cb.equal(a1.get("state"), "CA"));
+        q.orderBy(cb.asc(o1.get("quantity")), cb.asc(a1.get("zipCode")));
+        q.multiselect(o1.get("quantity"), a1.get("zipCode"));
+
+        assertEquivalence(q, jpql);
+    }
+
+    @AllowFailure
+    public void testOrdering3() {
+        String jpql = "SELECT o.quantity, o.cost * 1.08 AS taxedCost, a.zipCode "
+                + "FROM Customer c JOIN c.orders o JOIN c.address a "
+                + "WHERE a.state = 'CA' AND a.county = 'Santa Clara' "
+                + "ORDER BY o.quantity, taxedCost, a.zipCode";
+        CriteriaQuery q = cb.createQuery();
+        Root<Customer> c2 = q.from(Customer.class);
+        SetJoin<Customer, Order> o = c2.joinSet("orders");
+        Join<Customer, Address> a = c2.join("address");
+        q.where(cb.equal(a.get("state"), "CA"), cb.equal(a.get("county"),
+                "Santa Clara"));
+        q.orderBy(cb.asc(o.get("quantity")),
+        // cb.asc(cb.prod(o.get("totalCost"), 1.08)), //compiler err
+                cb.asc(a.get("zipCode")));
+        q.multiselect(o.get("quantity"),
+         //cb.prod(o.get("totalCost"), 1.08), //compiler err
+                a.get("zipCode"));
+
+        assertEquivalence(q, jpql);
+    }
+
+}

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/TestSubqueries.java

@@ -73,6 +73,7 @@ public class TestSubqueries extends CriteriaTest {
         assertEquivalence(q, query);
     }
 
+    @AllowFailure(message="cross join is not implemented")
     public void testSubquery01() {
         String query = "select o1.id from Order o1 where o1.id in "
                 + " (select distinct o.id from LineItem i, Order o"
@@ -243,7 +244,6 @@ public class TestSubqueries extends CriteriaTest {
         assertEquivalence(q, query);
     }
 
-    @AllowFailure(message="")
     public void testSubquery10() {
         String query = "select o.id from Order o where o.quantity >"
                 + " (select sum(o2.quantity) from Customer c, " 
@@ -259,7 +259,7 @@ public class TestSubqueries extends CriteriaTest {
         SetJoin<Customer, Order> o2 = c.join(Customer_.orders);
         sq.select(cb.sum(o2.get(Order_.quantity)));
 
-        q.where(cb.gt(o2.get(Order_.quantity), sq));
+        q.where(cb.gt(o.get(Order_.quantity), sq));
         
         assertEquivalence(q, query);
     }
@@ -285,7 +285,7 @@ public class TestSubqueries extends CriteriaTest {
         SetJoin<Customer, Order> o3 = c2.join(Customer_.orders);
         sq2.select(cb.min(o3.get(Order_.quantity)));
 
-        q.where(cb.between(o2.get(Order_.quantity), sq1.as(Integer.class), sq2));
+        q.where(cb.between(o.get(Order_.quantity), sq1.as(Integer.class), sq2));
         assertEquivalence(q, query);
     }
 
@@ -309,7 +309,7 @@ public class TestSubqueries extends CriteriaTest {
         assertEquivalence(q, query);
     }
 
-    @AllowFailure
+    @AllowFailure(message="cross join is not implemented")
     public void testSubquery13() {
         String query = "select o1.id, c.name from Order o1, Customer c"
                 + " where o1.quantity = "
@@ -389,23 +389,22 @@ public class TestSubqueries extends CriteriaTest {
         Root<Order> o = q.from(Order.class);
         q.select(o.get(Order_.id));
 
-        Subquery<Boolean> sq = q.subquery(Boolean.class);
+        Subquery<Object> sq = q.subquery(Object.class);
         Root<Order> o2 = sq.from(Order.class);
         sq.where(cb.equal(o.get(Order_.customer).get(Customer_.id), o2.get(
                 Order_.customer).get(Customer_.id)));
+        sq.select(
+            cb.selectCase().when(cb.gt(o2.get(Order_.quantity), 10), true)
+                .when(cb.equal(o2.get(Order_.quantity), 10), false)
+                .otherwise(false)
+        );
 
-        q.where(cb.equal(o.get(Order_.delivered),
-        // sq.select(
-                cb.selectCase().when(cb.gt(o2.get(Order_.quantity), 10), true)
-                        .when(cb.equal(o2.get(Order_.quantity), 10), false)
-                        .otherwise(false)
-        // )
-                ));
+        q.where(cb.equal(o.get(Order_.delivered), sq));
         
         assertEquivalence(q, query);
     }
 
-    
+    @AllowFailure(message="cross join is not implemented")
     public void testSubquery16() {
         String query = "select o1.id from Order o1 where o1.quantity > "
                 + " (select o.quantity*2 from LineItem i, Order o"
@@ -452,7 +451,7 @@ public class TestSubqueries extends CriteriaTest {
     }
 
     
-    public void testSubquery18() {
+    public void xtestSubquery18() {
         String query = "select o.id from Order o where o.orderTs >"
                 + " (select CURRENT_TIMESTAMP from o.lineItems i)";
 
@@ -476,9 +475,9 @@ public class TestSubqueries extends CriteriaTest {
         String query = "select o.id from Order o where o.quantity >"
                 + " (select SQRT(o.quantity) from Order o where o.delivered" +
                         " = true)";
-        CriteriaQuery<?> q = cb.createQuery();
+        CriteriaQuery<Integer> q = cb.createQuery(Integer.class);
         Root<Order> o = q.from(Order.class);
-//        q.select(o.get(Order_.id));
+        q.select(o.get(Order_.id));
 
         Subquery<Double> sq = q.subquery(Double.class);
         Root<Order> o2 = sq.from(Order.class);
@@ -494,9 +493,9 @@ public class TestSubqueries extends CriteriaTest {
         String query = "select o.id from Order o where o.customer.name in"
                 + " (select CONCAT(o.customer.name, 'XX') from Order o"
                 + " where o.quantity > 10)";
-        CriteriaQuery<?> q = cb.createQuery();
+        CriteriaQuery<Integer> q = cb.createQuery(Integer.class);
         Root<Order> o = q.from(Order.class);
-//        q.select(o.get(Order_.id));
+        q.select(o.get(Order_.id));
 
         Subquery<String> sq = q.subquery(String.class);
         Root<Order> o2 = sq.from(Order.class);
@@ -508,7 +507,6 @@ public class TestSubqueries extends CriteriaTest {
         assertEquivalence(q, query);
     }
 
-    @AllowFailure
     public void testSubquery21() {
         String query = "select c from Customer c where c.creditRating ="
                 + " (select "
@@ -521,30 +519,27 @@ public class TestSubqueries extends CriteriaTest {
                 + "     END from Order o2"
                 + " where c.id = o2.customer.id)";
         
-        CriteriaQuery<?> q = cb.createQuery();
+        CriteriaQuery<Customer> q = cb.createQuery(Customer.class);
         Root<Customer> c = q.from(Customer.class);
-//        q.select(c);
+        q.select(c);
 
-        Subquery<String> sq = q.subquery(String.class);
+        Subquery<Object> sq = q.subquery(Object.class);
         Root<Order> o2 = sq.from(Order.class);
         sq.where(cb.equal(
             c.get(Customer_.id), 
             o2.get(Order_.customer).get(Customer_.id)));
-
-        q.where(cb.equal(c.get(Customer_.creditRating), 
-          cb.selectCase()
+        Expression<Object> generalCase = cb.selectCase()
           .when(cb.gt(o2.get(Order_.quantity), 10), 
                   Customer.CreditRating.POOR)
           .when(cb.equal(o2.get(Order_.quantity), 10), 
                   Customer.CreditRating.GOOD)
-          .otherwise(Customer.CreditRating.EXCELLENT)
-            ));
+                .otherwise(Customer.CreditRating.EXCELLENT);
+        
+        sq.select(generalCase);
+        q.where(cb.equal(c.get(Customer_.creditRating), sq));
         assertEquivalence(q, query);
     }
 
-    // Coalesce for Enum type
-    @AllowFailure(message="Wrong JPQL due to enum oridinal/identifier " +
-    		"type mismatch")
     public void testSubquery22() {
         String query = "select c from Customer c "
                 + "where c.creditRating = (select COALESCE (c1.creditRating, "
@@ -553,9 +548,9 @@ public class TestSubqueries extends CriteriaTest {
                 + "from Customer c1 where c1.name = 'Famzy') order by c.name " +
                         "DESC";
         
-        CriteriaQuery<?> q = cb.createQuery();
+        CriteriaQuery<Customer> q = cb.createQuery(Customer.class);
         Root<Customer> c = q.from(Customer.class);
-//        q.select(c);
+        q.select(c);
         q.orderBy(cb.desc(c.get(Customer_.name)));        
 
         Subquery<Customer.CreditRating> sq =
@@ -580,9 +575,9 @@ public class TestSubqueries extends CriteriaTest {
                 + "Customer$CreditRating.POOR) "
                 + "from Customer c1 where c1.name = 'Famzy') "
                 + "order by c.name DESC";
-        CriteriaQuery<?> q = cb.createQuery();
+        CriteriaQuery<Customer> q = cb.createQuery(Customer.class);
         Root<Customer> c = q.from(Customer.class);
-//        q.select(c);
+        q.select(c);
         q.orderBy(cb.desc(c.get(Customer_.name)));        
 
         Subquery<Customer.CreditRating> sq =

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/TestTypeSafeCondExpression.java

@@ -42,10 +42,9 @@ import javax.persistence.criteria.CriteriaQuery;
 import javax.persistence.criteria.Expression;
 import javax.persistence.criteria.ParameterExpression;
 import javax.persistence.criteria.Root;
-import javax.persistence.criteria.Selection;
 import javax.persistence.criteria.Subquery;
 
-import org.apache.openjpa.persistence.inheritance.entity.ComputerUser;
+import org.apache.openjpa.persistence.test.AllowFailure;
 
 /**
  * Tests type-strict version of Criteria API. The test scenarios are adapted
@@ -193,7 +192,7 @@ public class TestTypeSafeCondExpression extends CriteriaTest {
         assertEquivalence(cq, query);
     }
     
-    // do not support isEmpty for array fields
+    @AllowFailure(message = "SQL generation is slightly different")
     
     public void testIsEmptyExprUsingCriteria() {
         String query = "SELECT o.name FROM CompUser o WHERE o.nicknames IS NOT EMPTY";
@@ -398,7 +397,7 @@ public class TestTypeSafeCondExpression extends CriteriaTest {
         assertEquivalence(q, query);
     }
     
-    
+    @AllowFailure
     public void testArithmFunc3() {
         String query = "select MOD(e.age, 4) From CompUser e WHERE e.name='Seetha'";
         
@@ -526,9 +525,7 @@ public class TestTypeSafeCondExpression extends CriteriaTest {
         assertEquivalence(q, query, new String[]{"t"}, new Class[]{MaleUser.class});
     }
 
-    // Type literal
-    // this Cartesian problem can not be rewritten to use JOIN
-    
+    @AllowFailure(message="cross join is not implemented")
     public void testTypeExpression3() {
         String query = "SELECT e, FemaleUser, a FROM Address a, FemaleUser e where e.address IS NOT NULL";
         

openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/criteria/TestTypesafeCriteria.java

@@ -34,8 +34,6 @@ import javax.persistence.criteria.ParameterExpression;
 import javax.persistence.criteria.Root;
 import javax.persistence.criteria.SetJoin;
 import javax.persistence.criteria.Subquery;
-import javax.persistence.criteria.QueryBuilder.Case;
-import javax.persistence.criteria.QueryBuilder.SimpleCase;
 
 import org.apache.openjpa.persistence.test.AllowFailure;
 
@@ -50,7 +48,8 @@ import org.apache.openjpa.persistence.test.AllowFailure;
  * 
  */
 public class TestTypesafeCriteria extends CriteriaTest {
-    public void btestExpressions() {
+    
+    public void testExpressions() {
         String jpql = "SELECT o.quantity, o.totalCost*1.08, "
                 + "a.zipCode FROM Customer c JOIN c.orders o JOIN c.address a "
                 + "WHERE a.state = 'CA' AND a.county = 'Santa Clara'";
@@ -60,10 +59,8 @@ public class TestTypesafeCriteria extends CriteriaTest {
         Join<Customer, Address> address = cust.join("address");
         q.where(cb.equal(address.get("state"), "CA"), cb.equal(address
             .get("county"), "Santa Clara"));
-        
-//        q.(order.get("quantity"),
-//            cb.prod(order.get("totalCost"), cb.literal(1.08)), //compiler err
-//            address.get("zipCode"));
+        Expression<Double> taxedCost = cb.prod(order.get(Order_.totalCost), 1.08);
+        q.multiselect(order.get("quantity"), taxedCost, address.get("zipCode"));
 
         assertEquivalence(q, jpql);
     }
@@ -244,7 +241,6 @@ public class TestTypesafeCriteria extends CriteriaTest {
         assertEquivalence(c, jpql);
     }
 
-    @AllowFailure(message="FetchJoin not implemented")
     public void testFetchJoins() {
         String jpql = "SELECT d FROM Department d LEFT JOIN FETCH d.employees WHERE d.deptNo = 1";
         
@@ -560,7 +556,6 @@ public class TestTypesafeCriteria extends CriteriaTest {
         assertEquivalence(q, jpql, new String[] {"coll"}, new Object[] {vals});
     }
     
-    @AllowFailure(message="Generates invalid SQL")
     public void testSelectList1() {
         String jpql = "SELECT v.location.street, KEY(i).title, VALUE(i) FROM "
             + "VideoStore v JOIN v.videoInventory i WHERE v.location.zipCode = "
@@ -764,6 +759,7 @@ public class TestTypesafeCriteria extends CriteriaTest {
         assertEquivalence(q, jpql);
     }
 
+    @AllowFailure(message="incorrect SQL generated by criteria API")
     public void testOrdering3() {
         String jpql = "SELECT o.quantity, o.totalCost * 1.08 AS taxedCost, "
             + "a.zipCode FROM Customer c JOIN c.orders o JOIN c.address a "