多线程并发更新同一条记录

有一个任务表,每个任务有n个事项要并发处理,

每个事项完成时需要更新已完成数,即finished+1,当n个事项全部处理完成即整个任务完成时需要做任务的统计工作。

数据库通过行级锁来保证并发更新准确性,测试代码如下:

public class Concurrency {
    
    /**执行更新语句,根据commitImmediately决定是否立即提交*/
    public static int executeUpdate(String sql, boolean commitImmediately)
    {
        Connection conn = null; Statement stmt = null; int result = 0;
        try
        {
            conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:orcl", "h2do", "h2do");
            conn.setAutoCommit(false);
            
            stmt = conn.createStatement();
            result = stmt.executeUpdate(sql);
            
            if(!commitImmediately)
            {
                System.out.println("挂起等待输入字符模拟提交前其他操作...");
                System.in.read();
            }
            
            conn.commit();
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            try{if(null != stmt)stmt.close();}catch(Exception e){}
            try{if(null != conn)conn.close();}catch(Exception e){}
        }
        
        return result;
    }
    
    public static void main(String[] args) throws Exception{
        oracle.jdbc.driver.OracleDriver.class.newInstance();
        
        Thread t1 = new Thread(new Runnable(){
            @Override
            public void run() {
                //1、更新任务1的记录,挂起等待命令行输入字符才提交
                executeUpdate("update task set finished = finished + 1 where id = 1", false);
                System.out.println("step 1 finished.");
            }
        });
        t1.start();
        t1.join(1000);//保证线程进入执行状态
        
        new Thread(new Runnable(){
            @Override
            public void run() {
                //2、更新任务1的记录,并想立即提交,因为有其他线程更新后未提交,记录被锁定需等待锁释放后才能更新
                executeUpdate("update task set finished = finished + 1 where id = 1", true);
                System.out.println("step 2 finished.");
            }
        }).start();
        
        new Thread(new Runnable(){
            @Override
            public void run() {
                //3、更新同一个表任务2的记录,不受任务1的记录更新影响(尽管id=1的记录已被锁定)
                executeUpdate("update task set finished = finished + 1 where id = 2", true);
                System.out.println("step 3 finished.");
            }
        }).start();
    }
}

执行结果如下:

挂起等待输入字符模拟其他处理...

step 3 finished.

step 1 finished.

step 2 finished.

多线程并发更新同一条记录

时间: 08-03

多线程并发更新同一条记录的相关文章

mysql 批量更新与批量更新多条记录的不同值实现方法

在mysql中批量更新我们可能使用update,replace into来操作,下面来给各位详细介绍mysql 批量更新与性能吧! mysql更新语句很简单,更新一条数据的某个字段,一般这样写: 复制代码代码如下: UPDATE mytable SET myfield = 'value' WHERE other_field = 'other_value'; 如果更新同一字段为同一个值,mysql也很简单,修改下where即可: 复制代码代码如下: UPDATE mytable SET myfie

使用SQL语句逐条更新每条记录

declare @i int declare @j int declare @phone varchar(20) set @j=1 select @i=count(*) from LatestLocation DECLARE L_cursor CURSOR FOR SELECT Phone FROM LatestLocation OPEN L_cursor while @j<[email protected] begin FETCH NEXT FROM L_cursor into @phone

mysql语句:批量更新多条记录的不同值[转]

mysql语句:批量更新多条记录的不同值[转] mysql语句:批量更新多条记录的不同值 mysql更新语句很简单,更新一条数据的某个字段,一般这样写: 1 UPDATE mytable SET myfield = 'value' WHERE other_field = 'other_value'; 如果更新同一字段为同一个值,mysql也很简单,修改下where即可: 1 UPDATE mytable SET myfield = 'value' WHERE other_field in ('o

mysql语句:批量更新多条记录的不同

mysql更新语句很简单,更新一条数据的某个字段,一般这样写: UPDATE mytable SET myfield = 'value' WHERE other_field = 'other_value'; 如果更新同一字段为同一个值,mysql也很简单,修改下where即可: UPDATE mytable SET myfield = 'value' WHERE other_field in ('other_values'); 这里注意 ‘other_values’ 是一个逗号(,)分隔的字符串

mysql进阶 十四 批量更新与批量更新多条记录的不同值实现方法

mysql 批量更新与批量更新多条记录的不同值实现方法 在mysql中批量更新我们可能使用update,replace into来操作,下面详细介绍mysql批量更新与性能. 批量更新 mysql更新语句很简单,更新一条数据的某个字段,一般这样写: UPDATE mytable SET myfield = 'value' WHERE other_field = 'other_value'; 如果更新同一字段为同一个值,mysql也很简单,修改下where即可: UPDATE mytable SE

mysql 批量更新多条记录(且不同值)的实现方法

mysql更新语句很简单,更新多条数据的某个字段为相同值,一般这样写: UPDATE table_name SET field = 'value' WHERE condition; 更新多条数据为不同值,你可以: foreach ($display_order as $id => $ordinal) { $sql = "UPDATE categories SET display_order = $ordinal WHERE id = $id"; mysql_query($sql)

odoo 创建一条记录的时候自动增加一个序列号

第一步: 在odoo开发者模式,进入配置设置添加一个序列号,sequence ocde 这个地方的值要与代码里相同 开始是在代码里这样设置的,cwbh是财务编号的字段需求是每次新增自动加1 cwbh = fields.Char(string='Number', required=True, copy=False, readyonly= True default=lambda self:self.env['ir.sequence'].next_by_code('dycrm.cwbh')) 重新启动

数据库 UPDATE多条记录不同值,同时UPDATE多个字段

需求 如下两张表student(学生表).score(测试成绩表) 现需要统计:2015-03-10日之后,性别 age=1 的测试成绩的 总分 与 平均分. 要求:使用一个SQL统计score表,将结果更新到student表的score_sum和score_avg字段中. 结果如图: 实现: 如果我们只需要更新一个字段,MYSQL和ORACLE语法是一样的,在 set 后面跟一个子查询即可,如下: UPDATE student D   SET D.score_sum =        (   

上账务系统余额并发更新问题记录

某电商平台,某天线上用户报bug说账户余额信息与交易流水对不上.可以认为是数据库并发更新问题,由此定位出具体原因,并给出解决方案. 问题现象 场景描述 线上账务系统,在定时结算给卖家钱时,且高并发量的情况下,出现提现x元(假设当前用户余额为x元)余额为0后,再转入该账户一笔钱(假设为y元),结果账户余额变为了x+y 元,导致用户余额错误. ps:账户余额的变更都是在事务中update的 环境说明 mysql5.7 + innodb,事务隔离级别是REPEATABLE-READ 场景模拟 我们简化