保证数据正确性，乐观锁的控制！

 

wangking 写道

为了保证数据的完整性以及正确性，我们总得挖空心思的找寻一些解决方案。保证数据的正确性，控制同步问题，有2中，一种乐观锁，一种悲观锁。这次项目中我采用的是乐观锁，就口水活，记下来！

 

一般用乐观锁进行同步控制的时候，都喜欢在表上建立一个版本监控的字段，姑且叫“version”吧。

 

如表User：

 

User     username      user_id       balance        version

               wangking           1            100                   1

 

 

比如balance字段引起的变化由多处控制，如充值的时候，交易的时候，都会对balance造成影响。所以我们要对user表进行乐观锁控制，以防止数据的不正确。

 

 

事例一（充值）：

 

//充值卡
User user = get(1);
Card card = get(2);
int userFinalMoney = user.balance + card.money;
user.setBalance(userFinalMoney);
User user2 = get(1);
if(user.version == user2.version){
    updateByTrans(user,card); //version++，卡过期，账号充值
}else{
     //提示系统繁忙，请稍后再试！
}

 

事例二（交易）：

 

//卖家发布任务的时候，[钱]和[发布点]已经扣除到【交易任务】上
//【交易任务】的状态修改
//买家  增加 [钱]和[发布点]
User user = get(1);
Task task = get(3);
int userFinalMoney = user.balance + task.money;
int userFinalPiontNum = user.pointNum + task.pointNum;
user.setBalance(userFinalMoney);
user.setPiontNum(userFinalPiontNum);
User user2 = get(1);
if(user.version == user2.version){  //当如果事例一（充值）处先执行了，那么version值++了，所以这里version值匹配不过来，就不会对数据造成影响！
	updateByTrans(user,task); //version++，update user,task
}else{
      //提示系统繁忙，请稍后再试！
}

 

是不是很简单吧，还不快来试试？

 

评论

3 楼 521069108 2011-09-21  

在数据库中统一执行事务最好

2 楼 wangking717 2011-03-17  

shansun123 写道

其实不用两次查询吧

//充值卡
User user = get(1);
Card card = get(2);
int userFinalMoney = user.balance + card.money;
user.setBalance(userFinalMoney);
User user2 = get(1);
if(user.version == user2.version){
    updateByTrans(user,card); //version++，卡过期，账号充值
}else{
     //提示系统繁忙，请稍后再试！
}

update table_XX set XXXX where version=#version#就好了，这里把version=1传入

这个得看需求了。如果要version控制的是在一个transaction的话，那么即便update table_XX set XXXX where version=#version#影响的行数为0，但是transaction的另外的执行SQL语句同样成功执行，所以这个时候就会用到我说的那种方法，比较通用。。

当然如果只是单表控制的话，你的那种方法更优，而我那种方法更通用。

1 楼 shansun123 2011-03-15  

其实不用两次查询吧

//充值卡
User user = get(1);
Card card = get(2);
int userFinalMoney = user.balance + card.money;
user.setBalance(userFinalMoney);
User user2 = get(1);
if(user.version == user2.version){
    updateByTrans(user,card); //version++，卡过期，账号充值
}else{
     //提示系统繁忙，请稍后再试！
}

update table_XX set XXXX where version=#version#就好了，这里把version=1传入