mirror of https://github.com/apache/openjpa.git
OPENJPA-1123: Test for database-specific query hints
git-svn-id: https://svn.apache.org/repos/asf/openjpa/trunk@786615 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
6c1cc88175
commit
79ad8c4943
|
@ -0,0 +1,73 @@
|
|||
/*
|
||||
* 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.jdbc.query;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import javax.persistence.EntityManager;
|
||||
import javax.persistence.Query;
|
||||
|
||||
import org.apache.openjpa.jdbc.conf.JDBCConfiguration;
|
||||
import org.apache.openjpa.jdbc.sql.DBDictionary;
|
||||
import org.apache.openjpa.jdbc.sql.MySQLDictionary;
|
||||
import org.apache.openjpa.jdbc.sql.OracleDictionary;
|
||||
import org.apache.openjpa.persistence.jdbc.query.domain.TimeKeeper;
|
||||
import org.apache.openjpa.persistence.test.SQLListenerTestCase;
|
||||
|
||||
/**
|
||||
* Tests database-specific query hints.
|
||||
*/
|
||||
public class TestHintedQuery extends SQLListenerTestCase {
|
||||
|
||||
public void setUp() {
|
||||
super.setUp(CLEAR_TABLES, TimeKeeper.class);
|
||||
}
|
||||
|
||||
public void testHintedQuery() {
|
||||
EntityManager em = emf.createEntityManager();
|
||||
em.getTransaction().begin();
|
||||
em.persist(new TimeKeeper());
|
||||
em.persist(new TimeKeeper());
|
||||
em.getTransaction().commit();
|
||||
|
||||
String jpql = "SELECT tk FROM TimeKeeper tk";
|
||||
String mysqlHint = "SQL_NO_CACHE";
|
||||
String oracleHint = "/*+ first_rows(100) */";
|
||||
Query query = em.createQuery(jpql);
|
||||
query.setHint(MySQLDictionary.SELECT_HINT, mysqlHint);
|
||||
query.setHint(OracleDictionary.SELECT_HINT, oracleHint);
|
||||
List keepers = query.getResultList();
|
||||
assertEquals(2, keepers.size());
|
||||
|
||||
// The dictionaries the hints are meant for should use the hints.
|
||||
// Other dictionaries should ignore them.
|
||||
DBDictionary dict = ((JDBCConfiguration) emf.getConfiguration())
|
||||
.getDBDictionaryInstance();
|
||||
if (dict instanceof MySQLDictionary) {
|
||||
assertContainsSQL("SELECT " + mysqlHint + " ");
|
||||
return;
|
||||
}
|
||||
if (dict instanceof OracleDictionary) {
|
||||
assertContainsSQL("SELECT " + oracleHint + " ");
|
||||
return;
|
||||
}
|
||||
assertNotSQL(".*" + mysqlHint + ".*");
|
||||
assertNotSQL(".*" + oracleHint + ".*");
|
||||
}
|
||||
}
|
Loading…
Reference in New Issue