ordermanage.java

网上商城代码

package com.fendou.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.fendou.exception.OrderException;
import com.fendou.platform.DBConnection;
import com.fendou.vo.Order;
import com.fendou.vo.OrderDetail;

public class OrderManage {
	private Connection conn;
	private PreparedStatement pstm;	
	private Statement stm;	
	private ResultSet rs;	
	private DBConnection db=DBConnection.getInstance();
	
	public void addOrder(Order order,OrderDetail detail)throws OrderException{
		boolean blnResult=true;
		String sql = "insert into T_Order(MemberID,MemberTrueName,MemberAddress,MemberProvince,"
		           + "MemberCity,MemberArea,MemberPostcode,MemberTelephone,OrderAmount,OrderPay,"
		           + "OrderInvoice,OrderCarry,OrderCarryTime,OrderRemark,OrderStatus,CreateDate,"
		           + "UpdateDate) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; 
                String sql1="select distinct @@identity from T_Order";  
		String sql2="";
		try{
			conn=db.getConnection();
			conn.setAutoCommit(false);
			pstm =conn.prepareStatement(sql);			
			pstm.setLong(1, order.getMemberID());
			
			pstm.addBatch();
        	int[] psexec =pstm.executeBatch();
        	for (int k=0;k<psexec.length;k++){
                 if(psexec[k]==0){
                     blnResult = false;                      
                     break;
                 }
             } 
        	pstm=conn.prepareStatement(sql2);
        	
        	pstm.addBatch();
        	int[] psexec1 =pstm.executeBatch();
        	for (int k=0;k<psexec1.length;k++){
                 if(psexec1[k]==0){
                     blnResult = false;                      
                     break;
                 }
             } 
		}catch(SQLException e){     
			blnResult = false;
        	throw new OrderException("addOrder error:"+e.getMessage());
        }finally{
        	try {
                if (blnResult)  {
                    conn.commit();
                }
                else  {
                    conn.rollback();
                }    
                db.closeConnection(conn, pstm, rs);                    
	         }catch (SQLException e) {
	        	 throw new OrderException("addOrder error:"+e.getMessage());
	         }
        	 	
        }
	}
}