[jboss-cvs] JBossAS SVN: r112629 - projects/jboss-jca/branches/Branch_1_0/adapters/src/main/java/org/jboss/jca/adapters/jdbc.

[jboss-cvs-commits at lists.jboss.org]

Author: jesper.pedersen
Date: 2012-02-08 14:49:18 -0500 (Wed, 08 Feb 2012)
New Revision: 112629

Modified:
   projects/jboss-jca/branches/Branch_1_0/adapters/src/main/java/org/jboss/jca/adapters/jdbc/WrappedResultSet.java
   projects/jboss-jca/branches/Branch_1_0/adapters/src/main/java/org/jboss/jca/adapters/jdbc/WrappedStatement.java
Log:
Add ironjacamar.jdbc.defaultfetchsize

Modified: projects/jboss-jca/branches/Branch_1_0/adapters/src/main/java/org/jboss/jca/adapters/jdbc/WrappedResultSet.java
===================================================================
--- projects/jboss-jca/branches/Branch_1_0/adapters/src/main/java/org/jboss/jca/adapters/jdbc/WrappedResultSet.java	2012-02-08 19:47:48 UTC (rev 112628)
+++ projects/jboss-jca/branches/Branch_1_0/adapters/src/main/java/org/jboss/jca/adapters/jdbc/WrappedResultSet.java	2012-02-08 19:49:18 UTC (rev 112629)
@@ -75,6 +75,16 @@
    /** The jndi name */
    protected final String jndiName;
    
+   /** Default fetch size */
+   protected static Integer defaultFetchSize = null;
+
+   static
+   {
+      String dfs = SecurityActions.getSystemProperty("ironjacamar.jdbc.defaultfetchsize");
+      if (dfs != null)
+         defaultFetchSize = Integer.valueOf(dfs);
+   }
+
    /** 
     * Create a new wrapped result set
     * 
@@ -96,6 +106,18 @@
       this.resultSet = resultSet;
       this.spy = spy;
       this.jndiName = jndiName;
+
+      if (defaultFetchSize != null)
+      {
+         try
+         {
+            resultSet.setFetchSize(defaultFetchSize.intValue());
+         }
+         catch (SQLException ignore)
+         {
+            // Ignore
+         }
+      }
    }
 
    /**

Modified: projects/jboss-jca/branches/Branch_1_0/adapters/src/main/java/org/jboss/jca/adapters/jdbc/WrappedStatement.java
===================================================================
--- projects/jboss-jca/branches/Branch_1_0/adapters/src/main/java/org/jboss/jca/adapters/jdbc/WrappedStatement.java	2012-02-08 19:47:48 UTC (rev 112628)
+++ projects/jboss-jca/branches/Branch_1_0/adapters/src/main/java/org/jboss/jca/adapters/jdbc/WrappedStatement.java	2012-02-08 19:49:18 UTC (rev 112629)
@@ -61,7 +61,17 @@
 
    /** The jndi name */
    protected final String jndiName;
+   
+   /** Default fetch size */
+   protected static Integer defaultFetchSize = null;
 
+   static
+   {
+      String dfs = SecurityActions.getSystemProperty("ironjacamar.jdbc.defaultfetchsize");
+      if (dfs != null)
+         defaultFetchSize = Integer.valueOf(dfs);
+   }
+
    /**
     * Constructor
     * @param lc The connection
@@ -76,6 +86,18 @@
       this.spy = spy;
       this.jndiName = jndiName;
 
+      if (defaultFetchSize != null)
+      {
+         try
+         {
+            s.setFetchSize(defaultFetchSize.intValue());
+         }
+         catch (SQLException ignore)
+         {
+            // Ignore
+         }
+      }
+
       lc.registerStatement(this);
    }