From 19533a17aa55fafc70d0a385928e785cb50e1ebc Mon Sep 17 00:00:00 2001 From: admin <2780501319@qq.com> Date: 星期五, 30 七月 2021 02:05:14 +0800 Subject: [PATCH] 爱奇艺视频更新 --- src/main/java/com/yeshi/buwan/dao/user/LoginUserDao.java | 83 +++++++++++++++++++++++++++++++++++++++++ 1 files changed, 83 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/yeshi/buwan/dao/user/LoginUserDao.java b/src/main/java/com/yeshi/buwan/dao/user/LoginUserDao.java index a125681..ef97de9 100644 --- a/src/main/java/com/yeshi/buwan/dao/user/LoginUserDao.java +++ b/src/main/java/com/yeshi/buwan/dao/user/LoginUserDao.java @@ -1,11 +1,94 @@ package com.yeshi.buwan.dao.user; import com.yeshi.buwan.dao.base.BaseDao; +import org.hibernate.HibernateException; +import org.hibernate.Session; +import org.springframework.orm.hibernate4.HibernateCallback; import org.springframework.stereotype.Repository; import com.yeshi.buwan.domain.user.LoginUser; +import org.yeshi.utils.StringUtil; + +import java.io.Serializable; +import java.util.ArrayList; +import java.util.List; @Repository public class LoginUserDao extends BaseDao<LoginUser> { + + public LoginUser selectByPrimaryKeyForUpdate(String id) { + return (LoginUser) excute(new HibernateCallback<LoginUser>() { + @Override + public LoginUser doInHibernate(Session session) throws HibernateException { + List<LoginUser> userList = session.createSQLQuery("select * from wk_loginuser lu where lu.id=? for update").addEntity(LoginUser.class).setParameter(0, id).list(); + if (userList != null && userList.size() > 0) + return userList.get(0); + return null; + } + }); + + } + + public void updateSelective(LoginUser loginUser) { + + String hql = "update LoginUser u set "; + List<Serializable> params = new ArrayList<>(); + List<String> sets = new ArrayList<>(); + if (loginUser.getPhone() != null) { + sets.add("u.phone=?"); + params.add(loginUser.getPhone()); + } + + if (loginUser.getName() != null) { + sets.add("u.name=?"); + params.add(loginUser.getName()); + } + + + if (loginUser.getPortrait() != null) { + sets.add("u.portrait=?"); + params.add(loginUser.getPortrait()); + } + + if (loginUser.getSex() != null) { + sets.add("u.sex=?"); + params.add(loginUser.getSex()); + } + + if (loginUser.getSign() != null) { + sets.add("u.sign=?"); + params.add(loginUser.getSign()); + } + + if (loginUser.getBirthday() != null) { + sets.add("u.birthday=?"); + params.add(loginUser.getBirthday()); + } + + if (loginUser.getWxOpenId() != null) { + sets.add("u.wxOpenId=?"); + params.add(loginUser.getWxOpenId()); + } + + if (loginUser.getWxUnionId() != null) { + sets.add("u.wxUnionId=?"); + params.add(loginUser.getWxUnionId()); + } + + if (loginUser.getQqOpenId() != null) { + sets.add("u.qqOpenId=?"); + params.add(loginUser.getQqOpenId()); + } + + if (sets.size() > 0) { + params.add(loginUser.getId()); + Serializable[] ps = new Serializable[params.size()]; + params.toArray(ps); + update(hql + StringUtil.concat(sets, ",") + " where u.id=?", ps); + } + + + } + } -- Gitblit v1.8.0