sql >> Databáze >  >> RDS >> Sqlserver

Jak mohu efektivně číst více než 15 milionů záznamů ze serveru SQL, provést nějaké zpracování a zapsat je do plochého souboru?

Vypadá to, že ovladač jdbc pro sql-server respektuje nápovědu fetchsize (která naznačuje, kolik řádků se má číst najednou), takže byste měli být schopni zadat jeden dotaz a iterovat svou sadu výsledků, zpracovávat a zapisovat řádky do souboru jako jdete. Např.:

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. Jak můžeme definovat velikost výstupního parametru v uložené proceduře?

  2. Nahraďte NonASCII znaky v MYSQL

  3. Nelze se připojit k serveru:postgresql na ubuntu v subsystému windows pro linux

  4. Suma s SQL server RollUP - ale jen poslední shrnutí?