本文整理汇总了Java中javax.persistence.StoredProcedureQuery类的典型用法代码示例。如果您正苦于以下问题：Java StoredProcedureQuery类的具体用法？Java StoredProcedureQuery怎么用？Java StoredProcedureQuery使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
StoredProcedureQuery类属于javax.persistence包，在下文中一共展示了StoredProcedureQuery类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: calculate
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void calculate() {
log.info("... calculate ...");
EntityManager em = emf.createEntityManager();
em.getTransaction().begin();
// define the stored procedure
StoredProcedureQuery query = em.createStoredProcedureQuery("calculate");
query.registerStoredProcedureParameter("x", Double.class, ParameterMode.IN);
query.registerStoredProcedureParameter("y", Double.class, ParameterMode.IN);
query.registerStoredProcedureParameter("sum", Double.class, ParameterMode.OUT);
// set input parameter
query.setParameter("x", 1.23d);
query.setParameter("y", 4d);
// call the stored procedure and get the result
query.execute();
Double sum = (Double) query.getOutputParameterValue("sum");
log.info("Calculation result: 1.23 + 4 = " + sum);
em.getTransaction().commit();
em.close();
}
开发者ID:thjanssen，项目名称:HibernateTips，代码行数:25，代码来源:TestStoredProcedureQuery.java
示例2: calculate
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void calculate() {
EntityManager em = emf.createEntityManager();
em.getTransaction().begin();
StoredProcedureQuery query = em.createNamedStoredProcedureQuery("calculate");
query.setParameter("x", 1.23d);
query.setParameter("y", 4d);
query.execute();
Double sum = (Double) query.getOutputParameterValue("sum");
log.info("Calculation result: 1.23 + 4 = " + sum);
em.getTransaction().commit();
em.close();
}
开发者ID:thjanssen，项目名称:HibernateTips，代码行数:17，代码来源:TestNamedStoredProcedureQuery.java
示例3: runBackup
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
/**
* Creates a Backup of the Database in the directory specified in
* config.properties.
*
* @param name the name of the Backup.
*
* @return Backup entinty.
*
* @throws QueryTimeoutException if the query should fail.
* @throws PersistenceException if persisting should fail.
* @Throws IOException if config.properties is not readable.
*/
public Backup runBackup(String name) throws QueryTimeoutException,
PersistenceException, IOException {
Properties props = ServerProperties.getProperties();
Date date = new Date();
String path = props.getProperty(dirPropertyKey)
+ name + "_" + getDateAsString(date);
StoredProcedureQuery query = em.createStoredProcedureQuery(
"SYSCS_UTIL.SYSCS_BACKUP_DATABASE");
query.registerStoredProcedureParameter(1, String.class,
ParameterMode.IN);
query.setParameter(1, path);
query.execute();
log.debug("Backup query executed!");
Backup backup = generateBackup(name, path, date, getDirectorySize(new File(path)));
return backup;
}
开发者ID:stefanoberdoerfer，项目名称:exmatrikulator，代码行数:32，代码来源:BackupService.java
示例4: testHibernateProcedureCallMultipleOutParameter
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void testHibernateProcedureCallMultipleOutParameter() {
doInJPA(entityManager -> {
StoredProcedureQuery query = entityManager
.createStoredProcedureQuery("getStatistics")
.registerStoredProcedureParameter(
"A", Long.class, ParameterMode.OUT)
.registerStoredProcedureParameter(
"B", Long.class, ParameterMode.OUT)
.registerStoredProcedureParameter(
"C", Long.class, ParameterMode.OUT);
query.execute();
Long a = (Long) query
.getOutputParameterValue("A");
Long b = (Long) query
.getOutputParameterValue("B");
Long c = (Long) query
.getOutputParameterValue("C");
});
}
开发者ID:vladmihalcea，项目名称:high-performance-java-persistence，代码行数:23，代码来源:MySQLStoredProcedureTest.java
示例5: testStoredProcedureRefCursor
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void testStoredProcedureRefCursor() {
try {
doInJPA(entityManager -> {
StoredProcedureQuery query = entityManager.createStoredProcedureQuery("post_comments");
query.registerStoredProcedureParameter(1, Long.class, ParameterMode.IN);
query.registerStoredProcedureParameter(2, Class.class, ParameterMode.REF_CURSOR);
query.setParameter(1, 1L);
query.execute();
List<Object[]> postComments = query.getResultList();
assertNotNull(postComments);
});
} catch (Exception e) {
assertTrue(Pattern.compile("Dialect .*? not known to support REF_CURSOR parameters").matcher(e.getCause().getMessage()).matches());
}
}
开发者ID:vladmihalcea，项目名称:high-performance-java-persistence，代码行数:18，代码来源:MySQLStoredProcedureTest.java
示例6: testFunction
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void testFunction() {
try {
doInJPA(entityManager -> {
StoredProcedureQuery query = entityManager.createStoredProcedureQuery("fn_count_comments");
query.registerStoredProcedureParameter("postId", Long.class, ParameterMode.IN);
query.setParameter("postId", 1L);
Long commentCount = (Long) query.getSingleResult();
assertEquals(Long.valueOf(2), commentCount);
});
} catch (Exception e) {
assertTrue(Pattern.compile("PROCEDURE high_performance_java_persistence.fn_count_comments does not exist").matcher(e.getCause().getCause().getMessage()).matches());
}
}
开发者ID:vladmihalcea，项目名称:high-performance-java-persistence，代码行数:17，代码来源:MySQLStoredProcedureTest.java
示例7: testStoredProcedureOutParameter
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void testStoredProcedureOutParameter() {
doInJPA(entityManager -> {
StoredProcedureQuery query = entityManager
.createStoredProcedureQuery("count_comments")
.registerStoredProcedureParameter(
"postId", Long.class, ParameterMode.IN)
.registerStoredProcedureParameter(
"commentCount", Long.class, ParameterMode.OUT)
.setParameter("postId", 1L);
query.execute();
Long commentCount = (Long) query.getOutputParameterValue("commentCount");
assertEquals(Long.valueOf(2), commentCount);
});
}
开发者ID:vladmihalcea，项目名称:high-performance-java-persistence，代码行数:18，代码来源:SQLServerStoredProcedureTest.java
示例8: testStoredProcedureRefCursor
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void testStoredProcedureRefCursor() {
try {
doInJPA(entityManager -> {
StoredProcedureQuery query = entityManager
.createStoredProcedureQuery("post_comments")
.registerStoredProcedureParameter(1, Long.class, ParameterMode.IN)
.registerStoredProcedureParameter(2, Class.class, ParameterMode.REF_CURSOR)
.setParameter(1, 1L);
query.execute();
List<Object[]> postComments = query.getResultList();
assertNotNull(postComments);
});
} catch (Exception e) {
assertTrue(Pattern.compile("Dialect .*? not known to support REF_CURSOR parameters").matcher(e.getCause().getMessage()).matches());
}
}
开发者ID:vladmihalcea，项目名称:high-performance-java-persistence，代码行数:19，代码来源:SQLServerStoredProcedureTest.java
示例9: isNowHoliday
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
/**
* Checks whether the current day is a holiday.
*
* @param now The current day.
* @return True if the current date is a holiday, false otherwise.
* @throws BatchProcessingException If major error occurred.
*/
protected boolean isNowHoliday(Date now) throws BatchProcessingException {
Calendar calendar = Calendar.getInstance();
calendar.setTime(now);
int dayOfWeek = calendar.get(Calendar.DAY_OF_WEEK);
if (dayOfWeek == Calendar.SUNDAY || dayOfWeek == Calendar.SATURDAY) {
return true; // Sunday for 0 and Saturday for 6 are holidays
}
try {
startTransaction();
StoredProcedureQuery sp = entityManager.createNamedStoredProcedureQuery("IsThisHoliday");
sp.setParameter("pDate2Test", now, TemporalType.DATE);
Boolean result = (Boolean) sp.getSingleResult();
commitTransaction();
return result;
} catch (PersistenceException pe) {
throw new BatchProcessingException("Database error checking holiday.", pe);
}
}
开发者ID:NASA-Tournament-Lab，项目名称:CoECI-OPM-Service-Credit-Redeposit-Deposit-Application，代码行数:32，代码来源:BatchProcessingJob.java
示例10: batchDailyAccountUpdate
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
/**
* Batch daily account update.
* <p/>
* This method does not throw any exception.
*
* @param procMessage The process message. Used to build the mail message.
* @return true if execution is successful; false otherwise.
*/
private boolean batchDailyAccountUpdate(StringBuilder procMessage) {
try {
startTransaction();
StoredProcedureQuery sp = entityManager.createNamedStoredProcedureQuery("BatchDailyAccountUpdate");
sp.setParameter("pAuditBatchIDLog", todayAuditBatch.getId());
Integer count = (Integer) sp.getSingleResult();
commitTransaction();
String msg = "Updated " + count + " master records to history or ACH Stop status.";
logger.info(msg);
procMessage.append(CRLF).append(CRLF).append(msg);
return true;
} catch (PersistenceException pe) {
logger.error("ERROR: Updating master records to history or ACH Stop status failed.", pe);
procMessage.append(CRLF).append(CRLF)
.append("ERROR: Updating master records to history or ACH Stop status failed. ");
return false;
}
}
开发者ID:NASA-Tournament-Lab，项目名称:CoECI-OPM-Service-Credit-Redeposit-Deposit-Application，代码行数:32，代码来源:BatchProcessingJob.java
示例11: createStoredProcedureQuery
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Override
public StoredProcedureQuery createStoredProcedureQuery(String procedureName, String... resultSetMappings)
{
logger.error("Thread: {} using entity Manager {}", Thread.currentThread().getId(), emid);
return em.createStoredProcedureQuery(procedureName, resultSetMappings);
}
开发者ID:rlsutton1，项目名称:VaadinUtils，代码行数:8，代码来源:EntityManagerWrapper.java
示例12: shouldInvokeStoredProcedureWithOutbound
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void shouldInvokeStoredProcedureWithOutbound() throws Exception {
utx.begin();
StoredProcedureQuery query =
em.createStoredProcedureQuery("DOUBLE_SP")
.registerStoredProcedureParameter(
"P1", Float.class, ParameterMode.IN)
.registerStoredProcedureParameter(
"P2", Float.class, ParameterMode.OUT)
.setParameter("P1", new Float(2.345));
boolean status = query.execute();
System.out.printf("****************** status=%s\n", status);
assertFalse( query.hasMoreResults());
Double p2 = ( Double)query.getOutputParameterValue("P2");
System.out.printf("The output P2 was %12.7f\n", p2 );
utx.commit();
}
开发者ID:peterpilgrim，项目名称:javaee7-developer-handbook，代码行数:18，代码来源:StoredProcedureJPATest2.java
示例13: shouldInvokeStoredProcedureWithOutbound
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void shouldInvokeStoredProcedureWithOutbound() throws Exception {
StoredProcedureQuery query =
em.createStoredProcedureQuery("COMPOUND_INTEREST_SP")
.registerStoredProcedureParameter(
"P", Float.class, ParameterMode.IN)
.registerStoredProcedureParameter(
"r", Float.class, ParameterMode.IN)
.registerStoredProcedureParameter(
"n", Integer.class, ParameterMode.IN)
.registerStoredProcedureParameter(
"t", Integer.class, ParameterMode.IN)
.registerStoredProcedureParameter(
"A", Float.class, ParameterMode.OUT)
.setParameter("P", new Float(1500))
.setParameter("r", new Float(0.043))
.setParameter("n", new Integer(4))
.setParameter("t", new Integer(6));
// P = 1500, r = 0.043 (4.3%), n = 4, and t = 6:
boolean status = query.execute();
System.out.printf("****************** status=%s\n", status);
assertFalse( query.hasMoreResults());
Double A = ( Double)query.getOutputParameterValue("A");
System.out.printf("The output A was %12.7f\n", A );
assertEquals( 1938.84, A, 0.005 );
}
开发者ID:peterpilgrim，项目名称:javaee7-developer-handbook，代码行数:27，代码来源:CompoundInterestRateStoredProcJPATest.java
示例14: shouldInvokeStoredProcedureWithResultSet
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void shouldInvokeStoredProcedureWithResultSet() throws Exception {
utx.begin();
StoredProcedureQuery query =
em.createStoredProcedureQuery("READ_TAX_SP")
.registerStoredProcedureParameter(
"TAX_CODE_ID", Integer.class, ParameterMode.IN)
.setParameter("TAX_CODE_ID", 101);
boolean status = query.execute();
System.out.printf("****************** status=%s\n", status);
List rs = query.getResultList();
assertNotNull(rs);
System.out.printf("****************** rs=%s\n", rs );
Object row[] = (Object[])rs.get(0);
System.out.printf("****************** row=%s\n", row );
for (int col=0; col<row.length; ++col ) {
System.out.printf("**** row[%d]=%s\n", col, row[col] );
}
utx.commit();
}
开发者ID:peterpilgrim，项目名称:javaee7-developer-handbook，代码行数:21，代码来源:StoredProcedureJPATest.java
示例15: testCallStoreProcedure
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void testCallStoreProcedure() {
StoredProcedureQuery query = entityManager.createStoredProcedureQuery("my_sum");
query.registerStoredProcedureParameter("x", Integer.class, IN);
query.registerStoredProcedureParameter("y", Integer.class, IN);
query.setParameter("x", 5);
query.setParameter("y", 4);
query.execute();
Integer sum = (Integer) query.getSingleResult();
assertEquals("the sum in the stored procedure", sum, new Integer(9));
}
开发者ID:PacktPublishing，项目名称:Mastering-Java-EE-Development-with-WildFly，代码行数:14，代码来源:StoreProcedureTestCase.java
示例16: plainJpa21
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void plainJpa21() {
StoredProcedureQuery proc = em.createStoredProcedureQuery("plus1inout");
proc.registerStoredProcedureParameter(1, Integer.class, ParameterMode.IN);
proc.registerStoredProcedureParameter(2, Integer.class, ParameterMode.OUT);
proc.setParameter(1, 1);
proc.execute();
assertThat(proc.getOutputParameterValue(2), is((Object) 2));
}
开发者ID:Just-Fun，项目名称:spring-data-examples，代码行数:13，代码来源:UserRepositoryIntegrationTests.java
示例17: save
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
/**
* Saves a bid to the database
* @param bid - bid
*/
public void save(Bid bid) {
entityManager.persist(bid);
StoredProcedureQuery spq = entityManager.createStoredProcedureQuery("getQtyOrders");
spq.registerStoredProcedureParameter("param1", Integer.class, ParameterMode.IN);
spq.setParameter("param1",55);
Object[] count = (Object[])spq.getSingleResult();
logger.log(Level.INFO, "Single result: {0}", count[0]);
}
开发者ID:rcuprak，项目名称:actionbazaar，代码行数:13，代码来源:BidManager.java
示例18: testStoredProcedureOutParameter
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void testStoredProcedureOutParameter() {
doInJPA(entityManager -> {
StoredProcedureQuery query = entityManager.createStoredProcedureQuery("count_comments");
query.registerStoredProcedureParameter("postId", Long.class, ParameterMode.IN);
query.registerStoredProcedureParameter("commentCount", Long.class, ParameterMode.OUT);
query.setParameter("postId", 1L);
query.execute();
Long commentCount = (Long) query.getOutputParameterValue("commentCount");
assertEquals(Long.valueOf(2), commentCount);
});
}
开发者ID:vladmihalcea，项目名称:high-performance-java-persistence，代码行数:15，代码来源:MySQLStoredProcedureTest.java
示例19: testStoredProcedureReturnValue
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void testStoredProcedureReturnValue() {
doInJPA(entityManager -> {
StoredProcedureQuery query = entityManager.createStoredProcedureQuery("post_comments");
query.registerStoredProcedureParameter(1, Long.class, ParameterMode.IN);
query.setParameter(1, 1L);
List<Object[]> postComments = query.getResultList();
assertEquals(2, postComments.size());
});
}
开发者ID:vladmihalcea，项目名称:high-performance-java-persistence，代码行数:13，代码来源:MySQLStoredProcedureTest.java
示例20: testStoredProcedureOutParameter
import javax.persistence.StoredProcedureQuery; //导入依赖的package包/类
@Test
public void testStoredProcedureOutParameter() {
doInJPA(entityManager -> {
StoredProcedureQuery query = entityManager
.createStoredProcedureQuery("count_comments")
.registerStoredProcedureParameter("postId", Long.class, ParameterMode.IN)
.registerStoredProcedureParameter("commentCount", Long.class, ParameterMode.OUT)
.setParameter("postId", 1L);
query.execute();
Long commentCount = (Long) query.getOutputParameterValue("commentCount");
assertEquals(Long.valueOf(2), commentCount);
});
}
开发者ID:vladmihalcea，项目名称:high-performance-java-persistence，代码行数:14，代码来源:PostgreSQLStoredProcedureTest.java
注：本文中的javax.persistence.StoredProcedureQuery类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论