Eu tenho o seguinte problema com concorrência usando Thread. O código abaixo deve pegar o último número de uma coluna de uma tabela e adicionar +1 para salvar novamente no banco, o problema é que esse número não pode se repetir e por causa da thread ele está se repetindo. O banco é isso .<br> <b>------ ---- Items -------------------<br> id | numeroCupom | qtdItem<br> =====================</b><br> Não posso usar auto_incremente em qtdItem já que se o número do cupom mudar a quatidade de itens tem que ser zerada. O professor que passou esse exercício disse que tem duas maneiras de consertar usando o select for isert e outra forma que não lembro, eu tentei com a select for insert porém continuou inserindo qtdItem duplicadas. O código atual insere algo no banco tipo -------------------------------------- ---- Items ---------------------------<br> id | numeroCupom | qtdItem <b>1 | 5 | 1</b><br> <b>2 | 5 | 2</b><br> <b>3 | 5 | 2</b><br> O correto seria -------------------------------------- ---- Items ---------------------------<br> id | numeroCupom | qtdItem <b>1 | 5 | 1</b><br> <b>2 | 5 | 2</b><br> <b>3 | 5 | 3</b><br> /* * To change this license header, choose License Headers in Project Properties. * To change this template file, choose Tools | Templates * and open the template in the editor. */ package concorrencia; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.logging.Level; import java.util.logging.Logger; /** * * @author Francisco */ public class Concorrencia { private static Connection conectar(){ try { Class.forName("com.mysql.jdbc.Driver"); return DriverManager.getConnection("jdbc:mysql://localhost/fiscal", "jp", ""); } catch (ClassNotFoundException ex) { Logger.getLogger(Concorrencia.class.getName()).log(Level.SEVERE, null, ex); } catch (SQLException ex) { Logger.getLogger(Concorrencia.class.getName()).log(Level.SEVERE, null, ex); } return null; } private static int getProximoId(Connection con, int cupomId) throws SQLException{ PreparedStatement stmt = con.prepareStatement("select max(nr_item) from item_cupom where cupom_id = ?"); stmt.setInt(1, cupomId); ResultSet rs = stmt.executeQuery(); try{ if(rs.next()){ return rs.getInt(1) + 1; }else{ return 1; } }finally{ rs.close(); stmt.close(); } } public static void inserirItem(Connection con, int cupomId, boolean demorar) throws SQLException, InterruptedException{ int nrItem = getProximoId(con, cupomId); if(demorar){ Thread.sleep(200); } PreparedStatement pstmt = con.prepareStatement("insert into item_cupom(cupom_id, nr_item) values(?, ?);"); pstmt.setInt(1, cupomId); pstmt.setInt(2, nrItem); pstmt.execute(); pstmt.close(); } private static boolean seraQueVaiDemorar(){ double valor = Math.random(); return valor > 0.8; } /** * @param args the command line arguments */ public static void main(String[] args) { Connection con = conectar(); for (int i = 0; i < 2; i++) { new Thread(){ @Override public void run() { for(int i = 0; i < 300; i++){ try { inserirItem(con, 5, seraQueVaiDemorar()); } catch (Exception ex) { Logger.getLogger(Concorrencia.class.getName()).log(Level.SEVERE, null, ex); } } } }.start(); } } }