Exemple de mise en cache des données d'un jeu de résultats

Télécharger le pilote JDBC

Cet exemple d’application du pilote Microsoft JDBC pour SQL Server montre comment récupérer un grand jeu de données à partir d’une base de données. Il contrôle ensuite le nombre de lignes de données dans le cache sur le client en utilisant la méthode setFetchSize de l’objet SQLServerResultSet.

Pour définir une limite sur le nombre de lignes dans le cache sur le client, spécifiez un type de curseur qui utilise un curseur côté serveur pendant la création d’objets Statement. Par exemple, le pilote JDBC fournit le type de curseur TYPE_SS_SERVER_CURSOR_FORWARD_ONLY, qui est un curseur côté serveur d’avance rapide uniquement et en lecture seule, à utiliser avec les bases de données SQL Server.

Une fois que vous avez exécuté la requête de l’objet Statement et que les données ont été retournées au client sous forme de jeu de résultats, appelez setFetchSize pour contrôler la quantité de données extraites de la base de données en une fois. Par exemple, si une table contient 100 lignes de données et que la taille d’extraction est 10, seules 10 lignes de données sont mises en cache sur le client à la fois. Bien que ce paramètre puisse ralentir le traitement des données, il utilise moins de mémoire sur le client. Ce scénario est utile quand vous devez traiter de grandes quantités de données sans utiliser trop de mémoire.

Le fichier de code de cet exemple est nommé CacheResultSet.java et se trouve à l’emplacement suivant :

\<installation directory>\sqljdbc_<version>\<language>\samples\resultsets

Configuration requise

Pour exécuter cet exemple d’application, définissez le classpath de sorte à ajouter le fichier jar mssql-jdbc. Vous devez également avoir accès à l’exemple de base de données AdventureWorks2022. Pour plus d’informations sur la façon de définir l’instruction classpath, consultez à l’aide du pilote JDBC.

Exemple

Dans l’exemple suivant, le code établit une connexion à l’exemple de base de données AdventureWorks2022. Ensuite, il utilise une instruction SQL avec l’objet SQLServerStatement , spécifie le type de curseur côté serveur et exécute l’instruction SQL. Les données sont retournées dans un objet SQLServerResultSet.

Ensuite, l’exemple de code appelle la méthode personnalisée timerTest, en passant comme arguments la taille d’extraction à utiliser et le jeu de résultats. La méthode timerTest définit alors la taille d’extraction du jeu de résultats avec la méthode setFetchSize et définit l’heure de début du test, puis boucle dans le jeu de résultats avec une boucle While. Dès la sortie de la boucle While, le code définit l’heure d’arrêt du test et affiche le résultat du test, notamment la taille d’extraction, le nombre de lignes traitées et la durée d’exécution du test.

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

import com.microsoft.sqlserver.jdbc.SQLServerResultSet;

public class CacheResultSet {

    @SuppressWarnings("serial")
    public static void main(String[] args) {

        // Create a variable for the connection string.
        String connectionUrl = "jdbc:sqlserver://<server>:<port>;encrypt=true;databaseName=AdventureWorks;user=<user>;password=<password>";

        try (Connection con = DriverManager.getConnection(connectionUrl);
                Statement stmt = con.createStatement(SQLServerResultSet.TYPE_SS_SERVER_CURSOR_FORWARD_ONLY, SQLServerResultSet.CONCUR_READ_ONLY);) {

            String SQL = "SELECT * FROM Sales.SalesOrderDetail;";

            for (int n : new ArrayList<Integer>() {
                {
                    add(1);
                    add(10);
                    add(100);
                    add(1000);
                    add(0);
                }
            }) {
                // Perform a fetch for every nth row in the result set.
                try (ResultSet rs = stmt.executeQuery(SQL)) {
                    timerTest(n, rs);
                }
            }
        }
        // Handle any errors that may have occurred.
        catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private static void timerTest(int fetchSize,
            ResultSet rs) throws SQLException {

        // Declare the variables for tracking the row count and elapsed time.
        int rowCount = 0;
        long startTime = 0;
        long stopTime = 0;
        long runTime = 0;

        // Set the fetch size then iterate through the result set to
        // cache the data locally.
        rs.setFetchSize(fetchSize);
        startTime = System.currentTimeMillis();
        while (rs.next()) {
            rowCount++;
        }
        stopTime = System.currentTimeMillis();
        runTime = stopTime - startTime;

        // Display the results of the timer test.
        System.out.println("FETCH SIZE: " + rs.getFetchSize());
        System.out.println("ROWS PROCESSED: " + rowCount);
        System.out.println("TIME TO EXECUTE: " + runTime);
        System.out.println();
    }
}

Voir aussi

Utilisation des jeux de résultats