Java中批处理MySQL语句

悠悠 2023-10-12 08:08 2阅读 0赞

一、首先需要在JDBC配置文件中的URL设置批处理权限

driverClassName=com.mysql.jdbc.Driver
    url=jdbc:mysql://localhost:3306/数据库名?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true
    username=root
    password=root
    initialSize=10
    minIdle=5
    maxActive=20
    maxWait=5000

二、在Dao层编写实现通用增删改的批处理方法

public void updateBatch(String sql, Object[][] params) { 
    		// 获取连接
    		Connection connection = JDBCUtils.getConnection();
    		try { 
    			//执行批处理的核心语句，参数params为Object类型的二维数组
    			queryRunner.batch(connection, sql, params);
    		} catch (SQLException e) { 
    			// e.printStackTrace();
    			// 将所有的底层异常都抛到过滤器中统一执行
    			throw new RuntimeException(e);
    		}
    		// finally { 
    		// JDBCUtils.releaseConnection(connection);
    		// }
    	}

三、在Service层将二维数组的参数传递给Dao层

@Override
    	public String createOrder(Cart cart, User user) { 
    		// 生成订单，实质是主要将购物车中的总价格与总数量向数据库中添加
    		String orderId = System.currentTimeMillis() + "" + user.getId();
    		Order order = new Order(orderId, new Date(), cart.getTotalCount(), cart.getTotalAmount(), 0, user.getId());
    		orderDao.saveOrder(order);
    		// 将订单中的每一个订单项遍历出来，然后添加到数据库中
    		List<CartItem> cartItemList = cart.getCartItemList();
    		Object[][] orderItemParams = new Object[cartItemList.size()][];
    		Object[][] bookParams = new Object[cartItemList.size()][];
    		for (int i = 0; i < cartItemList.size(); i++) { 
    			CartItem cartItem = cartItemList.get(i);
    			Book book = cartItem.getBook();
    			// 不使用批处理
    			// OrderItem orderItem = new OrderItem(null, cartItem.getCount(),
    			// cartItem.getAmount(), book.getTitle(),
    			// book.getAuthor(), book.getPrice(), book.getImgPath(), orderId);
    			// orderItemDao.saveOrderItem(orderItem);
    			// 使用批处理
    			orderItemParams[i] = new Object[] { cartItem.getCount(), cartItem.getAmount(), book.getTitle(),
    					book.getAuthor(), book.getPrice(), book.getImgPath(), orderId };
    			// 然后将数据库中书本的销量和库存修改一下
    			int count = cartItem.getCount();
    			int bookStock = book.getStock() - count;
    			int bookSales = book.getSales() + count;
    			// 不使用批处理
    			// bookDao.updateBook(bookSales + "", bookStock + "", book.getId() + "");
    			// 使用批处理
    			bookParams[i] = new Object[] { bookStock , bookSales ,  book.getId() };
    		}
    		orderItemDao.saveOrderItem(orderItemParams);
    		bookDao.updateBook(bookParams);
    		// 清空购物车
    		cart.getMap().clear();
    		// 返回订单号
    		return orderId;
    	}