<%@ page import="java.net.URLEncoder"%>
<%@ page import="org.springframework.web.context.support.WebApplicationContextUtils"%>
<%@ page import="java.util.*"%>
<%@ page import="java.text.SimpleDateFormat"%>
<%@ page language="java" pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%>
<%@ taglib uri="/WEB-INF/tlds/wall.tld" prefix="wall"%>
<%@ taglib prefix="c" uri="/WEB-INF/tlds/c.tld"%>
<%
response.setHeader("Pragma", "No-cache");
response.setHeader("Cache-Control", "no-cache");
response.setDateHeader("Expires", 0);
response.flushBuffer();
%>
<%@page import="org.springframework.jdbc.core.PreparedStatementCallback"%><html>
<head>
<title></title>
</head>
<body>
<%
javax.sql.DataSource dataSource = (javax.sql.DataSource)WebApplicationContextUtils.getWebApplicationContext(
pageContext.getServletContext()).getBean("luxe_dataSource");
org.springframework.jdbc.core.JdbcTemplate jdbcTemp= new org.springframework.jdbc.core.JdbcTemplate(dataSource);
// System.out.println(" ==== dataSource : " + dataSource);
// System.out.println(" ==== jdbcTemplare : " + jdbcTemp);
String sql = "select id,name,order_index from luxe_poi_cat where book_id=? and parent_id=0 and is_delete=0 order by order_index;";
String childrenSql = "select id,name,order_index from luxe_poi_cat where book_id=? and parent_id=? and is_delete=0 order by order_index;";
String updateOrderSql ="update luxe_poi_cat set order_index=? where id=?";
String sBookId=request.getParameter("book_id");
int iBookId =0;
if(sBookId!=null && sBookId.trim().length()>0){
try{
iBookId = Integer.parseInt(sBookId);
System.out.println(" book_id==== ["+sBookId+"]");
out.println(" book_id==== ["+sBookId+"]");
}catch(NumberFormatException ne){
System.out.println(" ==== paramter [book_id] just accept integer type ");
out.println(" ==== paramter [book_id] just accept integer type ");
ne.printStackTrace();
System.exit(1);
}
}else{
System.out.println(" ==== paramter [book_id] must not be empty ");
out.println(" ==== paramter [book_id] must not be empty ");
}
org.springframework.transaction.support.DefaultTransactionDefinition def = new org.springframework.transaction.support.DefaultTransactionDefinition();
org.springframework.transaction.PlatformTransactionManager transactionManager =
(org.springframework.transaction.PlatformTransactionManager)
WebApplicationContextUtils.getWebApplicationContext(pageContext.getServletContext()).getBean("transactionManager");
org.springframework.transaction.TransactionStatus status = transactionManager.getTransaction(def);
try{
List list=jdbcTemp.queryForList(sql,new Object[]{iBookId});
// System.out.println(" >>> list : " + list);
if(list!=null && list.size()>1){
for(int i=0;i< list.size();i++){
Map recordMap=(Map)list.get(i);
System.out.println(" ================= Record ===== " + recordMap);
int pkKey= Integer.parseInt(recordMap.get("id").toString());
//update chirldren order with parent id
List childrenList=jdbcTemp.queryForList(childrenSql,new Object[]{iBookId,pkKey});
if(childrenList!=null){
for(int j=0;j< childrenList.size();j++){
Map childrenRecordMap=(Map)list.get(j);
System.out.println(" =================children Record ===== " + childrenRecordMap);
int childrenPKKey= Integer.parseInt(childrenRecordMap.get("id").toString());
jdbcTemp.update(updateOrderSql,new Object[]{j+2,childrenPKKey});
}
}
//update parent order id.
jdbcTemp.update(updateOrderSql,new Object[]{i+2,pkKey});
}
// transactionManager.commit(status);
}else{
System.out.println(" book_id==== ["+sBookId+"] had not entry!");
out.println(" book_id==== ["+sBookId+"] had not entry! ");
}
}catch(org.springframework.dao.DataAccessException ex){
引用
// transactionManager.rollback(status);
ex.printStackTrace();
System.out.println("== SQL rolback ==");
out.println("<br/> == SQL rolback ==<br/>");
}
System.out.println("== End ==");
out.println("<br/> == End ==<br/>");
%>
</body>
</html>
事务没提交 导致 数据库其它操作(session)
无法 操作..
死活还是原来的数据
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="luxe_dataSource"/>
</bean>
分享到：
相关推荐
解决spring2.0的jdbctemp.queryForRowSet包空指针异常的问题
JDBCTemp+MySQL示例。Spring，PropertyPlaceholderConfigurer，BeanPropertyRowMapper
纯干货，什么方法都有jdbctemp/hibernateTempl全部都有
本篇文章主要介绍了Spring 中jdbcTemplate 实现执行多条sql语句示例，可以对多个表执行多个sql语句，有兴趣的可以了解一下。
这篇文章主要介绍了Spring5源码之JDBC，基于上一篇Spring5之JDBC使用案例来一步步剖析jdbcTemplate操作数据库的源码。需要的朋友可以参考一下。 1、save/update功能实现 在UserServiceImpl中jdbcTemplate的... jdbcTemp
缓冲层 buffer-slayer是用于缓冲请求并批量发送请求的工具，客户端支持批量操作。 如Spring-JdbcTemplate （batchUpdate）， Redis （管道）。 它具有一个队列，该队列允许多个生产者... 查询将转发到委托的JdbcTemp