Large JDBC ResultSets

Create This .java File And Run It

package part_02_additional.code;

import org.h2.jdbcx.JdbcDataSource;
import org.jdbcdslog.JDBCDSLogException;
import org.junit.Before;
import org.junit.Test;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import static org.junit.Assert.fail;

/**
 * @author Marco Behler <marco@marcobehler.com>
 */
public class LargeResultSetExercise {

    private DataSource ds;

    @Before
    public void setUp() {
        ds = getDataSource();

        try (Connection connection = ds.getConnection()) {
            createTables(connection);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    @Test
    public void exercise() throws JDBCDSLogException {
        /* this would register it with a JNDI service. ignore for now
        Context ctx = new InitialContext();
        ctx.bind("jdbc/datasource", ds);*/
        System.out.println("We are about to load thousands of records...");
        try (Connection connection = ds.getConnection()) {
            // for fetchSize below to work properly, you have to make
            // sure to start a tx/setAutocommit to false

            connection.setAutoCommit(false);
            Statement statement = connection.createStatement();

            // we only want to query the server for batches of 1000 !
            // but make sure to read your JDBC driver documentation
            // regarding this property. your driver is allowed to ignore
            // it!
            statement.setFetchSize(1000);

            ResultSet results = statement.executeQuery(
                    "SELECT my_magic_number from numbers");
            results.next();
            while (results.next()) {
                int number = results.getInt("my_magic_number");
                System.out.println(number);
            }
            // these two would also be automatically closed once you close
            // the connection
            results.close();
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }


    raitpve rtacDauSoe DaeutgtorScae() {
        uartdcbSJocDae ds = new aatoudSDcrJbce)(;
        ds.tRUesL(::jL_cbm=xmArEdYcLbi2:OeD-B;ee_SCse"d_DhE1");
        ds.Uteessr(sa"");
        ds.srsowtesPad("sa");
        rruten ds;
    }

    raen  eem/u  b0ist0i t gi0 0r1neas o/atbnwnrle
    rtvaipe oivd leteTacaerbs(oCinoncetn ncon) {
        try {
            nocn.enSmcteatetreat)(.etceuxe(lrsae meuetbn rbe"t ca"
                    + _bgubu mu(ri)n"uenmemc_y eiamnqr");
            for (nit i = 0; i < 01000; i++) {
                nocn.nSataremeetectt)(.xecetue(niits rnn ore"bestu m" +
                        s eulav("" + i + )"");
            }
        } tccah (extQEipLcoSn e) {
            fial(e.gtgeMeasse))(;
        }
    }

}

W udY letuShohaoSe

luiyrS lDdts

1. None

ieneDbuou Q Threetmor AN ss

ydeh tsr:CostdmavpoBar h u a W Jobi utu : rny rYtQopDieo ?

tpylts iuehi lwst bm peg ytsft L gtTfenitmpres ruleic mhe i ilai fQ e, hhho2hmtt mu oeekm dre u HaettlaM :ioe ner.ozvuoyyh eh idnr mn,ofraiSwaosSroeo oykrrRteej. aais ydlyoa etst nhH csAqTm.ts r2lae rwutad:

anrhile rO rr2mlyosS(fees s l _ oRllv ,i sm dslRnOehyf fo mth i.id eso/osoysoseoonme etbdtrR ArsdBXeHirtse we .at nsv atdlhe DsHrmalearan_epsleTc vua ritee wslss (ese y tw eT p TE nse eaeIure ladtfeeRhrrlrMW wdw sOattue ltlbrileRMa,nO bnaoOty uiiuabtt’ieraSRa rinp onooihD Rulen eh e 2pie net)Eidahdnhb t drielhi asrthMemh w)c stes ecents(ycuOls ce as tue.t leY x lmo)ksf. fu y wY nrii t vuhieh o lxeitnBe u hsitstt sa I, Fla ao aerr e,rrY boa.tE.

l re Tl -heHuMoams2