X5中的事务

bingbing4647

----------------------------------------------------------------------------------------------------------------------------------------------------------------
public static void deleteData(String DJH){
                Connection conn=null;
                PreparedStatement  pstmt = null;
                Transaction tx=null;
                try {
                        tx = new com.justep.system.data.Transaction();
                        conn = tx.getConnection("/OA/geologySurvey/data");
                        tx.begin();
                        String delete_DJDCB ="Delete  ZD_DJDCB where DJH='"+DJH+"'";
                        pstmt  = conn.prepareStatement(delete_DJDCB);
                        pstmt.executeUpdate();
                        
                        String delete_JZBSB ="Delete  ZD_JZBSB where DJH='"+DJH+"'";
                        pstmt  = conn.prepareStatement(delete_JZBSB);
                        pstmt.executeUpdate();
                        
                        String delete_QLR ="Delete  ZD_QLR where DJH='"+DJH+"'";
                        pstmt  = conn.prepareStatement(delete_QLR);
                        pstmt.executeUpdate();
                        
                        
                        String delete_QSDC ="Delete  ZD_QSDC where DJH='"+DJH+"'";
                        pstmt  = conn.prepareStatement(delete_QSDC);
                        pstmt.executeUpdate();
                        
                        String delete_ZJB ="Delete  ZD_ZJB where DJH='"+DJH+"'";
                        pstmt  = conn.prepareStatement(delete_ZJB);
                        pstmt.executeUpdate();
                        
                        tx.commit();
                        
                } catch (Exception e) {
                        e.printStackTrace();
                        try {
                                System.out.println("__________rollback");
                                tx.rollback();
                        } catch (SQLException e1) {
                                e1.printStackTrace();
                        }
                }finally{
                        if(pstmt!=null){
                                try {
                                        pstmt.close();
                                } catch (SQLException e) {
                                        e.printStackTrace();
                                }
                        }
                        //平台提供的事务是会自动关闭的,不用关闭
//                        if(conn!=null){
//                                try {
//                                        conn.close();
//                                } catch (SQLException e) {
//                                        e.printStackTrace();
//                                }
//                        }


                }
               
        }

-------------------------------------------------------------------------------
-------------------------------------------------------------------------------



private static String getRecieveSysIdByAddress(String code) throws SQLException {
                String selectSql = "select b.fid from do_allcocation b " +
                "where b.FAREACODE='" + code + "'";
                Connection con = null;
                Statement stmt = null;
                ResultSet set = null;
                String result = "";
                try {
                        con = ModelUtils.getConnection("/OA");
                        stmt = con.createStatement();
                        set = stmt.executeQuery(selectSql);
                        
                        
                        if(set.next()){
                                result = set.getString("FID");
                        }
                } catch (NamingException e) {
                        e.printStackTrace();
                } catch (SQLException e) {
                        e.printStackTrace();
                }finally{
                        if(set!=null){
                                set.close();
                        }
                        if(stmt!=null){
                                stmt.close();
                        }
                        if(con!=null){
                                con.close();
                        }
                }
                return result;
        }

Transaction trans = com.justep.system.context.ContextHelper.getTransaction();
System.out.print("\r\n---scs--"+trans.getStatus());
System.out.print("\r\n---scs--"+trans.hashCode());
trans.rollback();

0：com.justep.system.data.Status.ACTIVE  活动状态，表示事物已启动
3：com.justep.system.data.Status.COMMITTED  事物已提交
10: com.justep.system.data.Status.LAZY 懒惰状态，表示一部分连接的事物已启动
6：com.justep.system.data.Status.NO_TRANSACTION 未启动事物
4：com.justep.system.data.Status.ROLLEDBACK 事物已回滚