sql >> Database teknologi >  >> RDS >> Sqlserver

Hvordan kan jeg effektivt læse mere end 15 millioner poster fra SQL Server, lave noget behandling og skrive dem til en flad fil?

Det ser ud til, at jdbc-driveren til sql-server respekterer fetchsize-tip, (som antyder, hvor mange rækker der skal læses ad gangen), så du burde være i stand til at udstede en forespørgsel og gentage dit resultatsæt, behandle og skrive rækker til filen som Du går. F.eks.:

public static void toFlat(Connection conn, File file, String destcode) {
    PreparedStatement ps = null;
    ResultSet rs = null;
    BufferedWriter out = null;
    try {
        ps = conn.prepareStatement(
            // col#:   1         2         3           4
            "SELECT threatid, lastname, firstname, flightnum " +
            "FROM travel.passengers " +
            "JOIN threats.aliases USING (firstname, lastname) " +
            "WHERE destination = ?" // param# 1
        );
        ps.setString(1,destcode); // param# 1

        out = new BufferedWriter(new FileWriter(file));


        // provides hint for driver to load x rows at a time:
        ps.setFetchSize(1000); 
        ps.executeQuery();
        rs = ps.getResultSet();

        while(rs.next()) {
            Integer threatid = rs.getInt(1);
            String lastname = rs.getString(2);
            String firstname = rs.getString(3);
            Integer flightnum = rs.getInt(4);

            //rubber meets road:
            String row = processRow(threatid, lastname, firstname, flightnum);
            out.write(row);
        }
    } catch(SQLException e) {
        // TODO
    } catch (IOException e) {
        // TODO
        e.printStackTrace();
    } finally {
        try {
            ps.close();
        } catch(Exception e){
            //TODO
        }
        try {
            rs.close();
        } catch(Exception e){
            //TODO
        }
        try {
            out.close();
        } catch(Exception e){
            //TODO
        }
    }
}


  1. Rank funktion i MySQL

  2. Problem med at udføre procedure i spring boot schema.sql-fil

  3. Sådan bindes datatable til reportviewer runtime

  4. Omdøb Oracle Table eller View