Alawn/Druid
1
0
Fork 0
mirror of https://github.com/alibaba/druid.git synced 2023-03-04 19:17:16 +00:00
Code Issues Releases Wiki Activity

WallConfig.allowWrap change default true

Browse Source
This commit is contained in:
wenshao
2012-12-19 12:59:37 +08:00
parent 56d09e0fe7
commit ce9c120dbe
6 changed files with 216 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/alibaba/druid/pool/DruidPooledPreparedStatement.java
+4 -2
View File
@@ -499,8 +499,10 @@ public class DruidPooledPreparedStatement extends DruidPooledStatement implement
if (holder.getDefaultRowPretch() == -1) {
int defaultRowPretch = OracleUtils.getRowPrefetch(this);
holder.setDefaultRowPretch(defaultRowPretch);
holder.setRowPrefetch(defaultRowPretch);
if (defaultRowPretch != holder.getDefaultRowPretch()) {
holder.setDefaultRowPretch(defaultRowPretch);
holder.setRowPrefetch(defaultRowPretch);
}
}
int rowPrefetch;
src/main/java/com/alibaba/druid/util/OracleUtils.java
+28 -11
View File
@@ -31,42 +31,53 @@ import oracle.jdbc.xa.client.OracleXAConnection;
import oracle.sql.ROWID;
import com.alibaba.druid.pool.DruidPooledConnection;
import com.alibaba.druid.pool.DruidPooledPreparedStatement;
import com.alibaba.druid.support.logging.Log;
import com.alibaba.druid.support.logging.LogFactory;
public class OracleUtils {
private final static Log LOG = LogFactory.getLog(OracleUtils.class);
public static XAConnection OracleXAConnection(Connection oracleConnection) throws XAException {
return new OracleXAConnection(oracleConnection);
}
public static void clearDefines(DruidPooledPreparedStatement stmt) throws SQLException {
OracleStatement oracleStmt = stmt.unwrap(OracleStatement.class);
oracleStmt.clearDefines();
}
public static int getRowPrefetch(PreparedStatement stmt) throws SQLException {
OracleStatement oracleStmt = stmt.unwrap(OracleStatement.class);
if (oracleStmt == null) {
return -1;
}
return oracleStmt.getRowPrefetch();
}
public static void setRowPrefetch(PreparedStatement stmt, int value) throws SQLException {
OracleStatement oracleStmt = stmt.unwrap(OracleStatement.class);
oracleStmt.setRowPrefetch(value);
if (oracleStmt != null) {
oracleStmt.setRowPrefetch(value);
}
}
public static void enterImplicitCache(PreparedStatement stmt) throws SQLException {
oracle.jdbc.internal.OraclePreparedStatement oracleStmt = unwrapInternal(stmt);
oracleStmt.enterImplicitCache();
if (oracleStmt != null) {
oracleStmt.enterImplicitCache();
}
}
public static void exitImplicitCacheToClose(PreparedStatement stmt) throws SQLException {
oracle.jdbc.internal.OraclePreparedStatement oracleStmt = unwrapInternal(stmt);
oracleStmt.exitImplicitCacheToClose();
if (oracleStmt != null) {
oracleStmt.exitImplicitCacheToClose();
}
}
public static void exitImplicitCacheToActive(PreparedStatement stmt) throws SQLException {
oracle.jdbc.internal.OraclePreparedStatement oracleStmt = unwrapInternal(stmt);
oracleStmt.exitImplicitCacheToActive();
if (oracleStmt != null) {
oracleStmt.exitImplicitCacheToActive();
}
}
public static OraclePreparedStatement unwrapInternal(PreparedStatement stmt) throws SQLException {
@@ -74,7 +85,13 @@ public class OracleUtils {
return (OraclePreparedStatement) stmt;
}
return stmt.unwrap(OraclePreparedStatement.class);
OraclePreparedStatement unwrapped = stmt.unwrap(OraclePreparedStatement.class);
if (unwrapped == null) {
LOG.error("can not unwrap statement : " + stmt.getClass());
}
return unwrapped;
}
public static short getVersionNumber(DruidPooledConnection conn) throws SQLException {
src/main/java/com/alibaba/druid/wall/WallConfig.java
+1 -1
View File
@@ -76,7 +76,7 @@ public class WallConfig implements WallConfigMBean {
private String tenantTablePattern;
private String tenantColumn;
private boolean wrapAllow = false;
private boolean wrapAllow = true;
private boolean metadataAllow = true;
public WallConfig(){