Bom dia!! Alguém poderia me ajudar com esse erro, não consigo identificar. Desde já agradeço.
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import br.com.alura.jdbc.ConnectionFactory;
import br.com.alura.jdbc.dao.CategoriaDAO;
import br.com.alura.jdbc.modelo.Categoria;
import br.com.alura.jdbc.modelo.Produto;
public class TestaListagemDeCategorias {
public static void main(String[] args) throws SQLException {
try (Connection connection = new ConnectionFactory().recuperarConexao()) {
CategoriaDAO categoriaDAO = new CategoriaDAO(connection);
List<Categoria> listaDeCategorias = categoriaDAO.listarComProdutos();
listaDeCategorias.stream().forEach(ct -> {
System.out.println(ct.getNome());
for (Produto produto : ct.getProdutos()) {
System.out.println(ct.getNome() + " - " + produto.getNome());
}
});
}
}
}
package br.com.alura.jdbc.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import br.com.alura.jdbc.modelo.Categoria;
import br.com.alura.jdbc.modelo.Produto;
public class CategoriaDAO {
private Connection connection;
public CategoriaDAO(Connection connection) {
this.connection = connection;
}
public List<Categoria> listar() throws SQLException {
List<Categoria> categorias = new ArrayList<>();
String sql = "SELECT ID, NOME FROM CATEGORIA";
try (PreparedStatement pstm = connection.prepareStatement(sql)) {
pstm.execute();
try (ResultSet rst = pstm.getResultSet()) {
while (rst.next()) {
Categoria categoria = new Categoria(rst.getInt(1), rst.getString(2));
categorias.add(categoria);
}
}
}
return categorias;
}
public List<Categoria> listarComProdutos() throws SQLException {
Categoria ultima = null;
List<Categoria> categorias = new ArrayList<>();
System.out.println("Executando a query de listar categoria");
String sql = "SELECT C.ID, C.NOME, P.ID, P.DESCRICAO FROM CATEGORIA C INNER JOIN PRODUTO P ON C.ID = P.CATEGORIA_ID";
try (PreparedStatement pstm = connection.prepareStatement(sql)) {
pstm.execute();
try (ResultSet rst = pstm.getResultSet()) {
while (rst.next()) {
if (ultima == null || !ultima.getNome().equals(rst.getString(2))) {
Categoria categoria = new Categoria(rst.getInt(1), rst.getString(2));
ultima = categoria;
categorias.add(categoria);
}
Produto produto = new Produto(rst.getInt(3), rst.getString(4), rst.getString(5));
ultima.adicionar(produto);
}
}
}
return categorias;
}
}
