Creando un Java 8 Custom Stream con JDBC ResultSets

El concepto de Java 8 Custom Stream es un concepto que en más de una ocasión necesitaremos abordar. En la programación más clásica de Java 8 utilizamos el método .stream() y convertimos una lista en un Stream de objetos . Sin embargo hay situaciones que no son tan directas y en las cuales necesitaremos construir nuestro propio stream desde cero. ¿Cómo podemos construir un Java 8 Custom Stream?.

Vamos a ver un ejemplo que se apoye en un ResultSet. El primer paso es crear un método que construya un ResultSet a partir de una conexión a base de datos

Veamos el código:

private static ResultSet crearResultSet() {
  ResultSet rs = null;
  String cadenaConexion = "jdbc:mysql://localhost:3306/curso?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC";
  try {
   Connection conexion = DriverManager.getConnection(cadenaConexion, "root", "root");
   Statement sentencia = conexion.createStatement();
   rs = sentencia.executeQuery("select * from persona");
  } catch (SQLException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }

  return rs;

 }

 

Java 8 Custom Stream

Este método nos devuelve un ResultSet con el cual podemos trabajar de la forma clásica. Sin embargo vamos a utilizar otro método que nos permita convertir el ResultSet en un Stream.

Veamos el código que usa un Stream Builder (design pattern)

public static Stream<Persona> crearStream(ResultSet rs) throws SQLException

 {
  Stream.Builder<Persona> builder = Stream.builder();
  while (rs.next()) {
   Persona persona = convertirFila(rs);
   builder.add(persona);
  }
  return builder.build();
 }

En este método estamos convirtiendo un ResultSet a un Stream invocando el método next() y creando un Stream.Builder. El Stream.Builder dispone de un método add que añade los objetos al futuro Stream. Por último invocamos al método build() y el nuevo Stream se genera El Stream Builder se apoya en un sencillo método que convierte la fila del ResultSet en un objeto Persona.

public static Persona convertirFila(ResultSet rs) throws SQLException {

  return new Persona(rs.getString("nombre"), rs.getString("apellidos"), rs.getInt("edad")

  );
 }

Una vez tenemos todos los métodos construidos es momento de construir el método main que se encarga de usar el Stream e imprimirlo por la consola.

 public static void main(String[] args) {

  try {
   Stream<Persona> stream=crearStream(crearResultSet());

   stream
                        .map(p->p.getNombre())
                        .forEach(System.out::println);

  } catch (SQLException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }

Acabamos de construir un Stream desde cero .En este caso para probar el Java 8 custom Stream nos estamos apoyando en el método map imprimiendo el nombre. El resultado se muestra en la consola.

Otros artículos relacionados:

1. Java Stream Sum y Business Objects
2. Java Stream Context y simplificación de Streams
3. Java Stream Filter y Predicates
4. Programación Funcional, Java 8 Streams
5. Utilizando un JPA Stream con JPA 2.2
6. Java Stream map y estadísticas

Externos

1. Java Streams Oracle