java ssh项目更新问题，先查询数据，然后进行更新操作，为啥保存不成功？下面有代码和控制台的一些信息
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了java ssh项目更新问题，先查询数据，然后进行更新操作，为啥保存不成功？下面有代码和控制台的一些信息相关的知识，希望对你有一定的参考价值。
public void changeBidpToPool()
String ids = Struts2Utils.getParameter("ids");
String idps[] = ids.split(",");
Criterion criterion = Restrictions.in("id", idps);
@SuppressWarnings("unchecked")
List<BidProject> bidPools = (List<BidProject>) getObjectService()
.findByCriteria(BidProject.class, criterion);
for (BidProject bidProject : bidPools)
bidProject.setTempType(Short.valueOf("1"));
getObjectService().batchSaveOrUpdate(bidPools);
>>> 2012-08-02 09:09:31,025 DEBUG [http-bio-8080-exec-8] (AbstractBatcher.java:426) - about to open ResultSet (open ResultSets: 0, globally: 0)
>>> 2012-08-02 09:09:31,041 DEBUG [http-bio-8080-exec-8] (Loader.java:1197) - result row: EntityKey[com.ht.oa.hibernate.bean.BidProject#4028814b38e141a10138e14a1ab30001]
>>> 2012-08-02 09:09:31,041 DEBUG [http-bio-8080-exec-8] (AbstractBatcher.java:433) - about to close ResultSet (open ResultSets: 1, globally: 1)
>>> 2012-08-02 09:09:31,056 DEBUG [http-bio-8080-exec-8] (AbstractBatcher.java:418) - about to close PreparedStatement (open PreparedStatements: 1, globally: 1)
>>> 2012-08-02 09:09:31,056 DEBUG [http-bio-8080-exec-8] (TwoPhaseLoad.java:130) - resolving associations for [com.ht.oa.hibernate.bean.BidProject#4028814b38e141a10138e14a1ab30001]
>>> 2012-08-02 09:09:31,072 DEBUG [http-bio-8080-exec-8] (TwoPhaseLoad.java:226) - done materializing entity [com.ht.oa.hibernate.bean.BidProject#4028814b38e141a10138e14a1ab30001]
>>> 2012-08-02 09:09:31,072 DEBUG [http-bio-8080-exec-8] (StatefulPersistenceContext.java:860) - initializing non-lazy collections
>>> 2012-08-02 09:09:31,072 DEBUG [http-bio-8080-exec-8] (ConnectionManager.java:325) - transaction completed on session with on_close connection release mode; be sure to close the session to release JDBC resources!
>>> 2012-08-02 09:09:31,088 DEBUG [http-bio-8080-exec-8] (HibernateTemplate.java:422) - Not closing pre-bound Hibernate Session after HibernateTemplate
>>> 2012-08-02 09:10:02,085 DEBUG [http-bio-8080-exec-8] (HibernateTemplate.java:397) - Found thread-bound Session for HibernateTemplate
>>> 2012-08-02 09:10:02,085 DEBUG [http-bio-8080-exec-8] (HibernateTemplate.java:422) - Not closing pre-bound Hibernate Session after HibernateTemplate
>>> 2012-08-02 09:10:02,085 DEBUG [http-bio-8080-exec-8] (CommonsLogger.java:68) - Checking ConfigurationProviders for reload.
>>> 2012-08-02 09:10:02,100 DEBUG [http-bio-8080-exec-8] (Log4JLoggerFactory.java:81) - org/apache/struts2/dispatcher/error.ftl[zh_CN,UTF-8,parsed] using cached since jar:file:/D:/apache-tomcat-7.0.27/webapps/ChinaYXY/WEB-INF/lib/struts2-core-2.2.1.jar!/org/apache/struts2/dispatcher/error.ftl didn't change.
>>> 2012-08-02 09:10:02,100 DEBUG [http-bio-8080-exec-8] (Log4JLoggerFactory.java:81) - Key 'location' was not found on instance of org.springframework.dao.InvalidDataAccessApiUsageException
大家帮忙看一下该怎么解决？
如果使用了ssh框架那么看下spring配置文件是否配置了事物提交以及方法名是否命名错误了追问
事物提交是怎么配置的？
我这样配置的不知道有错没？
你看你那个spring 中配置了以update* 就是以update开头命名的方法才会提交事物哦你把你的方法名改成 update。。。的就可以了
追问我现在改了，但是不行，之后我用一条数据更新，用get查询，之后更新可以
public void updateBidpToPool()
String ids = Struts2Utils.getParameter("ids");
BidProject bidProject=(BidProject) getObjectService().getObj(BidProject.class, ids);
bidProject.setTempType(Short.valueOf("1"));
getObjectService().updateObj(bidProject);
System.out.println("------------------");
你的实现类实现hibernateDaoSupport接口没？
追问实现了HibernateDaoImpl extends HibernateDaoSupport
get查询方法
@Override
public Object get(Class cls, Serializable id)
return getHibernateTemplate().get(cls, id);
另一个查询方法
见下一个追问
您回一句话，我才能提交下一个追问
嗯，就是没反应了，后台也不报错，前台卡死到哪了
参考技术B 你这里循环更新肯定只能更新最后一条！是吧？RedisUtils工具类，设置缓存，然后需要在删除，更新插入的时候清空缓存，保持redis和mysql的数据一致
文章目录
1.查询的时候先查询缓存，如果为空就会以查询数据库，然后设置值到缓存
public List<ClmHospitalLccc> queryClmHospitalLccc()
List<ClmHospitalLccc> list;
List<ClmHospitalLccc> lv01 = new ArrayList<>();
List<ClmHospitalLccc> lv02 = new ArrayList<>();
List<ClmHospitalLccc> lv03 = new ArrayList<>();
int count = 0;
RedisUtils redisUtils = RedisUtils.getInstance();
if(redisUtils.get(CustomerConstants.QUERY_XILL_HOSPITAL_TREE) !=null)
log.info("医院索引缓存数据:",(List<ClmHospitalLccc>) redisUtils.get(CustomerConstants.QUERY_XILL_HOSPITAL_TREE));
return (List<ClmHospitalLccc>) redisUtils.get(CustomerConstants.REGION_CUSTOMER,CustomerConstants.QUERY_XILL_HOSPITAL_TREE);
//查询所有医院代码数据
list = this.hospitalCodeUpholdMapper.initPageList();
//按节点遍历
for(ClmHospitalLccc clmHospitalLccc:list)
if(clmHospitalLccc.getHscode() != null && !"".equals(clmHospitalLccc.getHscode()))
if(clmHospitalLccc.getHscode().trim().length() == 2)
lv01.add(clmHospitalLccc);
if(clmHospitalLccc.getHscode().trim().length() == 4)
lv02.add(clmHospitalLccc);
if(clmHospitalLccc.getHscode().trim().length() == 6)
lv03.add(clmHospitalLccc);
for(ClmHospitalLccc clmHospitalLccc02:lv02)
List children = new ArrayList();
for(ClmHospitalLccc clmHospitalLccc03:lv03)
if(clmHospitalLccc03.getHscode().substring(0,4).equals(clmHospitalLccc02.getHscode()))
Map<String, Object> map = new HashMap();
map.put("hscode", clmHospitalLccc03.getHscode());
map.put("hsname", clmHospitalLccc03.getHsname());
map.put("children", clmHospitalLccc03.getChildren());
children.add(map);
if (children.size() > 0)
clmHospitalLccc02.setChildren(children);
for(ClmHospitalLccc clmHospitalLccc01:lv01)
List children = new ArrayList();
for(ClmHospitalLccc clmHospitalLccc02:lv02)
if(clmHospitalLccc02.getHscode().substring(0,2).equals(clmHospitalLccc01.getHscode()))
Map<String, Object> map = new HashMap();
map.put("hscode", clmHospitalLccc02.getHscode());
map.put("hsname", clmHospitalLccc02.getHsname());
map.put("children", clmHospitalLccc02.getChildren());
children.add(map);
if (children.size() > 0)
clmHospitalLccc01.setChildren(children);
log.info("医院索引查询-数据缓存处理前:",System.currentTimeMillis());
redisUtils.set(CustomerConstants.REGION_CUSTOMER, CustomerConstants.QUERY_XILL_HOSPITAL_TREE, lv01,30*24*3600);
log.info("医院索引查询-数据缓存处理后:",System.currentTimeMillis());
return lv01;
2.在进行修改(insert,delete,update)操作的时候进行 删除缓存（这样就会下次查询的时候缓存为空，又会重新设置缓存）
3.缓存工具类
package com.sunline.framework.redis.utils;
import java.io.Serializable;
import java.util.Date;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import org.springframework.data.redis.core.RedisConnectionUtils;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.data.redis.support.atomic.RedisAtomicLong;
import org.springframework.util.StringUtils;
import com.sunline.framework.redis.constants.CttRedis.Region;
import lombok.extern.slf4j.Slf4j;
/**
*
* ClassName: RedisUtils <br/>
* Function: TODO redis cache 工具类. <br/>
* Reason: TODO ADD REASON(可选). <br/>
* date: 2019年10月17日 下午2:40:29 <br/>
*
*/
@Slf4j
public class RedisUtils
public static final String regionDefault = Region.REDIS_OBJ;
private static RedisUtils redisUtils;
private RedisTemplate<Serializable, Object> redisTemplate;
public void setRedisTemplate(RedisTemplate<Serializable, Object> redisTemplate)
this.redisTemplate = redisTemplate;
public static RedisUtils getInstance()
if (null == redisUtils)
synchronized (RedisUtils.class)
if (null == redisUtils)
log.info("缓存实例为空，初始化开始...");
redisUtils = new RedisUtils();
log.info("缓存实例为空，初始化完成...");
return redisUtils;
/**
* 设置缓存（永不过期）
* @param region 缓存块名称（注意命名规范）
* @param key 缓存key
* @param value 缓存值
*/
public Object get(String region, String key)
try
String factKey = this.getKeyName(region, key);
ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
return operations.get(factKey);
catch (Exception e)
log.error("根据region[],key[]获取缓存时异常!", region, key);
e.printStackTrace();
finally
RedisConnectionUtils.unbindConnection(redisTemplate.getConnectionFactory());
return null;
public Object get(String key)
return this.get(this.regionDefault, key);
/**
* 设置缓存（永不过期）
* @param region 缓存块名称（注意命名规范）
* @param key 缓存key
* @param value 缓存值
*/
public void set(String region, String key, Object value)
try
if (!StringUtils.isEmpty(key))
String factKey = this.getKeyName(region, key);
ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
operations.set(factKey, value);
catch (Exception e)
log.error("根据region[],key[]存储缓存时异常!", region, key);
e.printStackTrace();
finally
RedisConnectionUtils.unbindConnection(redisTemplate.getConnectionFactory());
/**
* 设置缓存
* @param region 缓存块名称（注意命名规范）
* @param key 缓存key
* @param value 缓存值
* @param expireTime 到期时间（单位：秒）
*/
public void set(String region, String key, Object value, int expireTime)
try
if (!StringUtils.isEmpty(key))
String factKey = this.getKeyName(region, key);
ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
operations.set(factKey, value);
redisTemplate.expire(factKey, expireTime, TimeUnit.SECONDS);
catch (Exception e)
log.error("根据region[],key[]存储缓存时异常!", region, key);
e.printStackTrace();
finally
RedisConnectionUtils.unbindConnection(redisTemplate.getConnectionFactory());
/**
* 设置缓存 （使用默认块）
* @param key 缓存key
* @param value 缓存值
*/
public void set(String key, Object value)
this.set(regionDefault, key, value);
/**
* 设置缓存
* @param region 缓存块名称（注意命名规范）
* @param key 缓存key
* @param value 缓存值
* @param expireTime 到期时间（单位：秒）
*/
public void set(String key, Object value, int expireTime)
try
String factKey = this.getKeyName(regionDefault, key);
ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
operations.set(factKey, value);
redisTemplate.expire(factKey, expireTime, TimeUnit.SECONDS);
catch (Exception e)
log.error("根据key[],expireTime[]存储缓存时异常!", key, expireTime);
e.printStackTrace();
finally
RedisConnectionUtils.unbindConnection(redisTemplate.getConnectionFactory());
/**
* 获取全部keys信息
* @param pattern
* @return
*/
public Set<Serializable> keys(String pattern)
try
return redisTemplate.keys(pattern);
catch (Exception e)
e.printStackTrace();
return null;
finally
RedisConnectionUtils.unbindConnection(redisTemplate.getConnectionFactory());
/**
* 删除缓存
* @param region 缓存块
* @param key 键
*/
public void remove(String region, String key)
try
String factKey = this.getKeyName(region, key);
if (exists(factKey))
redisTemplate.delete(factKey);
catch (Exception e)
log.error("根据region[],key[]清理缓存时异常!", region, key);
e.printStackTrace();
finally
RedisConnectionUtils.unbindConnection(redisTemplate.getConnectionFactory());
/**
* 根据默认块+key删除缓存
* @param key
*/
public void remove(String key)
try
String factKey = this.getKeyName(this.regionDefault, key);
if (exists(factKey))
redisTemplate.delete(factKey);
catch (Exception e)
e.printStackTrace();
finally
RedisConnectionUtils.unbindConnection(redisTemplate.getConnectionFactory());
private boolean exists(String key)
try
return redisTemplate.hasKey(key);
catch (Exception e)
e.printStackTrace();
finally
RedisConnectionUtils.unbindConnection(redisTemplate.getConnectionFactory());
return false;
/**
* 根据前缀key模糊匹配清理缓存对象信息
* @param prefix
*/
public void clearAllStartingWith(String prefix)
try
Set<Serializable> setData = this.keys(prefix);
if (null != setData)
redisTemplate.delete(setData);
catch (Exception e)
e.printStackTrace();
finally
RedisConnectionUtils.unbindConnection(redisTemplate.getConnectionFactory());
/**
* 生成缓存的 key
* @param region
* @param key
* @return
*/
@SuppressWarnings("rawtypes")
protected String getKeyName(String region, Object key)
if (StringUtils.isEmpty(region))
region = regionDefault;
if (key instanceof Number)
return region + ":I:" + key;
else
Class keyClass = key.getClass();
if (String.class.Elasticsearch并发冲突问题
SSH网上商城项目实战28使用Ajax技术局部更新商品数量和总价
RedisUtils工具类，设置缓存，然后需要在删除，更新插入的时候清空缓存，保持redis和mysql的数据一致