多线程中的准备语句

Question

我在准备好的语句中使用了merge命令，当我在单线程环境中执行它时，它的工作很好，但是在多线程环境中，它会引起一些问题，那就是数据重复，即如果我有5个线程，每个记录会重复5次，我认为db中没有锁来帮助线程。我的代码：

//db:oracle
sb.append("MERGE INTO EMP_BONUS EB USING (SELECT 1 FROM DUAL) on (EB.EMP_id = ?) WHEN MATCHED  THEN  UPDATE SET TA =?,DA=?,TOTAL=?,MOTH=?  WHEN NOT MATCHED THEN "+ "INSERT (EMP_ID, TA, DA, TOTAL, MOTH, NAME)VALUES(?,?,?,?,?,?) ");

//sql operation,calling from run() method
public void executeMerge(String threadName) throws Exception {              
        ConnectionPro cPro = new ConnectionPro();
        Connection connE = cPro.getConection();
        connE.setAutoCommit(false);
        System.out.println(sb.toString());
        System.out.println("Threadname="+threadName);
        PreparedStatement   pStmt= connE.prepareStatement(sb.toString());
        try {
            count = count + 1;

            for (Employee employeeObj : employee) {//datalist of employee

                pStmt.setInt(1, employeeObj.getEmp_id());
                pStmt.setDouble(2, employeeObj.getSalary() * .10);
                pStmt.setDouble(3, employeeObj.getSalary() * .05);
                pStmt.setDouble(4, employeeObj.getSalary()
                        + (employeeObj.getSalary() * .05)
                        + (employeeObj.getSalary() * .10));
                pStmt.setInt(5, count);
                pStmt.setDouble(6, employeeObj.getEmp_id());
                pStmt.setDouble(7, employeeObj.getSalary() * .10);
                pStmt.setDouble(8, employeeObj.getSalary() * .05);
                pStmt.setDouble(9, employeeObj.getSalary()
                        + (employeeObj.getSalary() * .05)
                        + (employeeObj.getSalary() * .10));
                pStmt.setInt(10, count);
                pStmt.setString(11, threadName);
                // pStmt.executeUpdate();

                pStmt.addBatch();
            }

            pStmt.executeBatch();
            connE.commit();
        } catch (Exception e) {
            connE.rollback();
            throw e;

        } finally {

            pStmt.close();
            connE.close();

        }
    }

如果employee.size=5,thread count=5,执行后我将得到25条记录,而不是5条

Answer 1

如果没有约束（即emp_bonus中的emp_id列上的主键或唯一键约束），则没有任何东西可以阻止数据库允许每个线程插入5行。由于每个数据库会话都无法看到其他会话所做的未提交更改，因此每个线程都将看到emp_bonus中没有线程正在查找的emp_id中的行（我假设employeeobj.getemp_id()在每个线程中返回相同的5个emp_id值），因此每个线程将插入所有5行，如果有5个线程，则总共只有25行。如果您有一个防止插入重复行的唯一约束，Oracle将允许其他4个线程阻塞，直到第一个线程提交为止，允许后续线程进行更新而不是插入。当然，这将导致线程被序列化，这将使您无法从运行多个线程中获得任何性能提升。