objStatement = con.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
objStatement.setFetchSize(Integer.MIN_VALUE);

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;


public class MySqlConnector {
	private static final int nTimeOut = 60;
	
	private static Connection getConnection() throws SQLException, ClassNotFoundException {
		System.out.println("Getting Connection...");
		String driver = "com.mysql.jdbc.Driver";
		Class.forName(driver);
		String dbURL = "jdbc:mysql://localhost:3306/mydatabase";
		String dbUsername = "root";
		String dbPassword = "password";
		
		Properties connProperties = new Properties();
		connProperties.put("user", dbUsername);
		connProperties.put("password", dbPassword);
		connProperties.put("netTimeoutForStreamingResults", String.valueOf(nTimeOut));

		Connection conn = DriverManager.getConnection(dbURL, connProperties);
		System.out.println("Connected!");
		return conn;
	}
	
	public static void main(String[] args) throws SQLException, ClassNotFoundException {
		
		
		Connection con = getConnection();
		
		String strQuery = "SELECT vwdynmiscsecprices.compname as vwdynmiscsecprices_compname, vwdynmiscsecprices.ticker as vwdynmiscsecprices_ticker, vwdynmiscsecprices.exchange as vwdynmiscsecprices_exchange, vwdynmiscsecprices.currency as vwdynmiscsecprices_currency, vwdynmiscsecprices.pricedate as vwdynmiscsecprices_pricedate, vwdynmiscsecprices.price as vwdynmiscsecprices_price, vwdynmiscfxrates.currency as vwdynmiscfxrates_currency, vwdynmiscfxrates.fxdate as vwdynmiscfxrates_fxdate, vwdynmiscfxrates.fxrate as vwdynmiscfxrates_fxrate FROM  vwdynmiscsecprices   JOIN  vwdynmiscfxrates";
		
		Statement objStatement=null;
		ResultSet objResultSet=null;
		try {
			objStatement = con.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
			objStatement.setFetchSize(Integer.MIN_VALUE);
			objStatement.setQueryTimeout(nTimeOut);
			
			objResultSet = objStatement.executeQuery(strQuery);
			long count=0;
			while(objResultSet.next()) {
				count++;
				if(count%1000000==0) {
					System.out.println(count);
				}
			}
			System.out.println(count);
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			try {
				objResultSet.close();
				objStatement.cancel();
				objStatement.close();
			} catch (SQLException e) {
				e.printStackTrace();
			} finally {
				con.close();
			}
		}
	}
}