ho un database con le tabell U_FH_ORDINI_PENDENTI che contiene le colonne numero_modulo e stato_ordine e la tabella FH_ASSET_RICHIESTO che contiene le colonne numero_modulo e stato_ordine devo Prelevare per ogni record della tabella U_FH_ORDINI_PENDENTI le colonne numero_modulo e stato_ordine e controllore che nella tabella FH_ASSET_RICHIESTO corrisponda lo stato_ordine
CIAO GRAZIEcodice:public boolean runTest(MappingTestCustom mappingTestCustom) { boolean result = true; Connection connection = null; Statement statement = null; ResultSet resultSetInvaccinfo = null; ResultSet resultSetBVBPPortfolio = null; ConnectionInterface connectionInterface = ConnectionFactory.getInstance(); connection = connectionInterface.getConnection(mappingTestCustom.getConnectionString()); try { String selectInvaccinfoQuery = "SELECT ACCID,LINEA FROM DBO.U_FH_INVACCINFO"; String selectBVBPPortfolioQuery = "SELECT PORTFOLIO_ID,LINE_CODE FROM DBO.BVBP_PORTFOLIO WHERE PORTFOLIO_ID = ?"; statement = connection.createStatement(); resultSetInvaccinfo = statement.executeQuery(selectInvaccinfoQuery); PreparedStatement preparedStatementPortfolio = connection.prepareStatement(selectBVBPPortfolioQuery); while (resultSetInvaccinfo.next()) { if (resultSetInvaccinfo.next()) { String accid = resultSetInvaccinfo.getString(1); preparedStatementPortfolio.setString(1, accid); String linea = resultSetInvaccinfo.getString(2); preparedStatementPortfolio.setString(1, linea); resultSetBVBPPortfolio = preparedStatementPortfolio.executeQuery(); if (resultSetBVBPPortfolio.next()) { String portfolio_id = resultSetBVBPPortfolio.getString(1); String line_code = resultSetBVBPPortfolio.getString(2); if (accid == portfolio_id) result = true; else result = false; output.writeln("ERRORE: accid >> " + accid + " portfolio_id >> " + portfolio_id); if (linea == line_code) result = true; else result = false; output.writeln("ERRORE: linea >> " + linea + " line_code >> " + line_code); } } } } catch (SQLException e) { e.printStackTrace(); } return result; } }



