itemdaojdbcimpl.java

shoppingCar 购物车

package com.tarena.shoppingcar.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Set;

import com.tarena.shoppingcar.entity.Item;
import com.tarena.shoppingcar.util.ConnectionFactory;
import com.tarena.shoppingcar.util.JdbcUtil;

public class ItemDaoJdbcImpl implements ItemDao {

	public void save(Set<Item> items,int id) {
		Connection con = null;
		PreparedStatement pstmt = null;
		try {
			con = ConnectionFactory.getConnection();
			con.setAutoCommit(false);
			String sql = "insert into item(amount,product_id,order_id) values(?,?,?)";
			pstmt = con.prepareStatement(sql);
			for(Item item : items){
				pstmt.setInt(1, item.getAmount());
				pstmt.setInt(2, item.getProduct().getId());
				pstmt.setInt(3, id);
				pstmt.addBatch();
			}
			pstmt.executeBatch();
			con.commit();
		} catch (SQLException e) {
			e.printStackTrace();
			try {
				con.rollback();
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
		} finally{
			JdbcUtil.close(con,pstmt);
		}
	}

}