github/ebean
4
0
Fork 0
mirror of https://github.com/ebean-orm/ebean.git synced 2024-04-21 10:51:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

No effective change - change newline char

Browse Source
This commit is contained in:
rbygrave
2015-05-09 01:09:16 +12:00
parent 8f12bbb6c4
commit 726d3a0c38
2 changed files with 141 additions and 141 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/avaje/ebeaninternal/server/jdbc/OraclePstmtBatch.java
+121 -121
View File
@@ -1,121 +1,121 @@
package com.avaje.ebeaninternal.server.jdbc;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import javax.persistence.OptimisticLockException;
import javax.persistence.PersistenceException;
import com.avaje.ebean.config.PstmtDelegate;
import com.avaje.ebeaninternal.api.ClassUtil;
import com.avaje.ebeaninternal.server.core.PstmtBatch;
/**
* Oracle specific handling of JDBC batching.
* <p>
* I guess some people don't need to follow the jdbc specification.
* </p>
*
* @author rbygrave
* @author imario
*/
public class OraclePstmtBatch implements PstmtBatch {
private final PstmtDelegate pstmtDelegate;
/**
* OraclePreparedStatement.setExecuteBatch() method.
*/
private static final Method METHOD_SET_EXECUTE_BATCH;
/**
* OraclePreparedStatement.sendBatch() method.
*/
private static final Method METHOD_SEND_BATCH;
private static final RuntimeException INIT_EXCEPTION;
static {
RuntimeException initException = null;
Method mSetExecuteBatch = null;
Method mSendBatch = null;
try {
Class<?> ops = ClassUtil.forName("oracle.jdbc.OraclePreparedStatement");
mSetExecuteBatch = ops.getMethod("setExecuteBatch", new Class[] { int.class });
mSendBatch = ops.getMethod("sendBatch");
} catch (NoSuchMethodException e) {
initException = new RuntimeException("problems initializing oracle reflection", e);
initException.fillInStackTrace();
} catch (ClassNotFoundException e) {
initException = new RuntimeException("problems initializing oracle reflection", e);
initException.fillInStackTrace();
}
INIT_EXCEPTION = initException;
METHOD_SET_EXECUTE_BATCH = mSetExecuteBatch;
METHOD_SEND_BATCH = mSendBatch;
}
public OraclePstmtBatch(PstmtDelegate pstmtDelegate) {
this.pstmtDelegate = pstmtDelegate;
}
public void setBatchSize(PreparedStatement pstmt, int batchSize) {
if (INIT_EXCEPTION != null) {
throw INIT_EXCEPTION;
}
try {
// invoke setExecuteBatch(batchSize+1);
METHOD_SET_EXECUTE_BATCH.invoke(pstmtDelegate.unwrap(pstmt), batchSize+1);
} catch (IllegalAccessException e) {
String m = "Error with Oracle setExecuteBatch "+(batchSize+1);
throw new RuntimeException(m, e);
} catch (InvocationTargetException e) {
String m = "Error with Oracle setExecuteBatch "+(batchSize+1);
throw new RuntimeException(m, e);
}
}
/**
* Simply calls standard pstmt.addBatch().
*/
public void addBatch(PreparedStatement pstmt) throws SQLException {
pstmt.executeUpdate();
}
public int executeBatch(PreparedStatement pstmt, int expectedRows, String sql, boolean occCheck) throws SQLException {
if (INIT_EXCEPTION != null) {
throw INIT_EXCEPTION;
}
int rows;
try {
// invoke sendBatch();
rows = ((Integer) METHOD_SEND_BATCH.invoke(pstmtDelegate.unwrap(pstmt))).intValue();
} catch (IllegalAccessException e) {
String msg = "Error invoking Oracle sendBatch method via reflection";
throw new PersistenceException(msg,e);
} catch (InvocationTargetException e) {
String msg = "Error invoking Oracle sendBatch method via reflection";
throw new PersistenceException(msg, e);
}
if (occCheck && rows != expectedRows) {
String msg = "Batch execution expected "+expectedRows+" but got "+rows+" sql:"+sql;
throw new OptimisticLockException(msg);
}
return rows;
}
}
package com.avaje.ebeaninternal.server.jdbc;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import javax.persistence.OptimisticLockException;
import javax.persistence.PersistenceException;
import com.avaje.ebean.config.PstmtDelegate;
import com.avaje.ebeaninternal.api.ClassUtil;
import com.avaje.ebeaninternal.server.core.PstmtBatch;
/**
* Oracle specific handling of JDBC batching.
* <p>
* I guess some people don't need to follow the jdbc specification.
* </p>
*
* @author rbygrave
* @author imario
*/
public class OraclePstmtBatch implements PstmtBatch {
private final PstmtDelegate pstmtDelegate;
/**
* OraclePreparedStatement.setExecuteBatch() method.
*/
private static final Method METHOD_SET_EXECUTE_BATCH;
/**
* OraclePreparedStatement.sendBatch() method.
*/
private static final Method METHOD_SEND_BATCH;
private static final RuntimeException INIT_EXCEPTION;
static {
RuntimeException initException = null;
Method mSetExecuteBatch = null;
Method mSendBatch = null;
try {
Class<?> ops = ClassUtil.forName("oracle.jdbc.OraclePreparedStatement");
mSetExecuteBatch = ops.getMethod("setExecuteBatch", new Class[] { int.class });
mSendBatch = ops.getMethod("sendBatch");
} catch (NoSuchMethodException e) {
initException = new RuntimeException("problems initializing oracle reflection", e);
initException.fillInStackTrace();
} catch (ClassNotFoundException e) {
initException = new RuntimeException("problems initializing oracle reflection", e);
initException.fillInStackTrace();
}
INIT_EXCEPTION = initException;
METHOD_SET_EXECUTE_BATCH = mSetExecuteBatch;
METHOD_SEND_BATCH = mSendBatch;
}
public OraclePstmtBatch(PstmtDelegate pstmtDelegate) {
this.pstmtDelegate = pstmtDelegate;
}
public void setBatchSize(PreparedStatement pstmt, int batchSize) {
if (INIT_EXCEPTION != null) {
throw INIT_EXCEPTION;
}
try {
// invoke setExecuteBatch(batchSize+1);
METHOD_SET_EXECUTE_BATCH.invoke(pstmtDelegate.unwrap(pstmt), batchSize+1);
} catch (IllegalAccessException e) {
String m = "Error with Oracle setExecuteBatch "+(batchSize+1);
throw new RuntimeException(m, e);
} catch (InvocationTargetException e) {
String m = "Error with Oracle setExecuteBatch "+(batchSize+1);
throw new RuntimeException(m, e);
}
}
/**
* Simply calls standard pstmt.addBatch().
*/
public void addBatch(PreparedStatement pstmt) throws SQLException {
pstmt.executeUpdate();
}
public int executeBatch(PreparedStatement pstmt, int expectedRows, String sql, boolean occCheck) throws SQLException {
if (INIT_EXCEPTION != null) {
throw INIT_EXCEPTION;
}
int rows;
try {
// invoke sendBatch();
rows = ((Integer) METHOD_SEND_BATCH.invoke(pstmtDelegate.unwrap(pstmt))).intValue();
} catch (IllegalAccessException e) {
String msg = "Error invoking Oracle sendBatch method via reflection";
throw new PersistenceException(msg,e);
} catch (InvocationTargetException e) {
String msg = "Error invoking Oracle sendBatch method via reflection";
throw new PersistenceException(msg, e);
}
if (occCheck && rows != expectedRows) {
String msg = "Batch execution expected "+expectedRows+" but got "+rows+" sql:"+sql;
throw new OptimisticLockException(msg);
}
return rows;
}
}
src/main/java/com/avaje/ebeaninternal/server/jdbc/StandardPstmtDelegate.java
+20 -20
View File
@@ -1,20 +1,20 @@
package com.avaje.ebeaninternal.server.jdbc;
import java.sql.PreparedStatement;
import com.avaje.ebean.config.PstmtDelegate;
import com.avaje.ebeaninternal.server.lib.sql.ExtendedPreparedStatement;
/**
* Implementation of PstmtDelegate from Ebean's own DataSource.
*/
public class StandardPstmtDelegate implements PstmtDelegate {
/**
* Unwrap the PreparedStatement from Ebean's DataSource implementation.
*/
public PreparedStatement unwrap(PreparedStatement pstmt) {
return ((ExtendedPreparedStatement) pstmt).getDelegate();
}
}
package com.avaje.ebeaninternal.server.jdbc;
import java.sql.PreparedStatement;
import com.avaje.ebean.config.PstmtDelegate;
import com.avaje.ebeaninternal.server.lib.sql.ExtendedPreparedStatement;
/**
* Implementation of PstmtDelegate from Ebean's own DataSource.
*/
public class StandardPstmtDelegate implements PstmtDelegate {
/**
* Unwrap the PreparedStatement from Ebean's DataSource implementation.
*/
public PreparedStatement unwrap(PreparedStatement pstmt) {
return ((ExtendedPreparedStatement) pstmt).getDelegate();
}
}