fixed limited to select fetch size

Author: guyplusplus

src/main/java/com/geckotechnology/mySqlDataCompare/MySQLSchemaRetriever.java

@@ -4,6 +4,7 @@
 import java.sql.DriverManager;
 import java.sql.ResultSet;
 import java.sql.Statement;
+import java.util.Properties;
 
 public class MySQLSchemaRetriever {
 
@@ -20,7 +21,10 @@ public MySQLSchemaRetriever(String url) {
 	}
 
 	public void openConnection() throws Exception {
-		conn = DriverManager.getConnection(url);		
+		Properties info = new Properties();
+		info.put ("defaultFetchSize", Integer.toString(SELECT_FETCH_SIZE));
+		info.put ("useCursorFetch", "true");
+		conn = DriverManager.getConnection(url, info);		
 	}
 
 	public void closeConnection() {
@@ -36,7 +40,6 @@ public Statement createStatement() throws Exception {
 	    		ResultSet.TYPE_FORWARD_ONLY,
 	    	    ResultSet.CONCUR_READ_ONLY,
 	    	    ResultSet.CLOSE_CURSORS_AT_COMMIT);
-	    stmt.setFetchSize(SELECT_FETCH_SIZE);
 	    return stmt;
 	}