利用hibernate执行jdbc中的事物处理 -- 风信Java论坛 -- Powered by JavaWind.Net

唧唧

大小楼主利用hibernate执行jdbc中的事物处理 Post by : 2008-06-23 11:38:14.0

幼儿园
UID：3
主题：342
帖子：781
加为好友发送短信

java代码

//此为更新的例子
try{
Session session = HibernateUtil.currentSession();
try{
Connection connection = session.connection();// 获取连接
PreparedStatement preparedStatement = null;
String deleteSQL = "delete from a where b=c";
//开始事物
connection.setAutoCommit(false);
preparedStatement = connection.prepareStatement(deleteSQL);
preparedStatement.executeUpdate();
//提交JDBC事务
connection.commit();
// 恢复JDBC事务的默认提交方式
connection.setAutoCommit(true);
preparedStatement.close();
}catch (SQLException x) {
connection.rollback();
throw x;
}
}catch(HibernateException e){
e.printStackTrace();
throw e;
}finally{
HibernateUtil.closeSession();
}
//关于查询：
try{
Session session = HibernateUtil.currentSession();
try{
Connection conn = session.connection();
PreparedStatement prepstmt = conn.prepareStatement(query);
prepstmt.setLong(1,Long.parseLong(paperId));
ResultSet rs = prepstmt.executeQuery();
ArrayList rsl = new ArrayList();
while(rs.next()){
HashMap item = new HashMap();
item.put("××",Long.toString(rs.getLong("××")));
rsl.add(item);
}
//一定要养成好习惯用完就关，否则会报“游标超出最大值”的错误的
rs.close();
prepstmt.close();
}catch (SQLException x) {
connection.rollback();
throw x;
}
}catch(HibernateException e){
e.printStackTrace();
throw e;
}finally{
HibernateUtil.closeSession();
}
//调用存储过程：
try{
Session session = HibernateUtil.currentSession();
Connection conn = session.connection();
CallableStatement cstmt = conn.prepareCall("{call SAVE_AS_NEW_PAPER(?,?)}");
cstmt.setLong(1, new Long(newPid).longValue());
cstmt.setLong(2, new Long(oldPid).longValue());
cstmt.executeQuery();
cstmt.close();
}catch(HibernateException e){
throw e;
}catch(SQLException e){
throw e;
}finally{
HibernateUtil.closeSession();
}

　★★★★★★★★
　纵里寻她千百度，蓦然回首，那人却在，灯火阑珊处！
　MyBlog ：http://blog.javawind.net

唧唧精华：0 积分：0 金钱：3172 金币：0 威望：0 权限：2 用户资料用户帖子	大小楼主利用hibernate执行jdbc中的事物处理 Post by : 2008-06-23 11:38:14.0
幼儿园 UID：3 主题：342 帖子：781 加为好友发送短信	java代码 //此为更新的例子 try{ Session session = HibernateUtil.currentSession(); try{ Connection connection = session.connection();// 获取连接 PreparedStatement preparedStatement = null; String deleteSQL = "delete from a where b=c"; //开始事物 connection.setAutoCommit(false); preparedStatement = connection.prepareStatement(deleteSQL); preparedStatement.executeUpdate(); //提交JDBC事务 connection.commit(); // 恢复JDBC事务的默认提交方式 connection.setAutoCommit(true); preparedStatement.close(); }catch (SQLException x) { connection.rollback(); throw x; } }catch(HibernateException e){ e.printStackTrace(); throw e; }finally{ HibernateUtil.closeSession(); } //关于查询： try{ Session session = HibernateUtil.currentSession(); try{ Connection conn = session.connection(); PreparedStatement prepstmt = conn.prepareStatement(query); prepstmt.setLong(1,Long.parseLong(paperId)); ResultSet rs = prepstmt.executeQuery(); ArrayList rsl = new ArrayList(); while(rs.next()){ HashMap item = new HashMap(); item.put("××",Long.toString(rs.getLong("××"))); rsl.add(item); } //一定要养成好习惯用完就关，否则会报“游标超出最大值”的错误的 rs.close(); prepstmt.close(); }catch (SQLException x) { connection.rollback(); throw x; } }catch(HibernateException e){ e.printStackTrace(); throw e; }finally{ HibernateUtil.closeSession(); } //调用存储过程： try{ Session session = HibernateUtil.currentSession(); Connection conn = session.connection(); CallableStatement cstmt = conn.prepareCall("{call SAVE_AS_NEW_PAPER(?,?)}"); cstmt.setLong(1, new Long(newPid).longValue()); cstmt.setLong(2, new Long(oldPid).longValue()); cstmt.executeQuery(); cstmt.close(); }catch(HibernateException e){ throw e; }catch(SQLException e){ throw e; }finally{ HibernateUtil.closeSession(); }
	★★★★★★★★ 　纵里寻她千百度，蓦然回首，那人却在，灯火阑珊处！　MyBlog ：http://blog.javawind.net