JDBC/JDBCTemplate批处理操作

Question

使用JDBC或JDBCTemplate进行批量插入查询的例子很多。

我想做一个批处理sql操作，包括选择，插入和删除。例如，我需要在与数据库的单一连接中发出以下sql操作。

1. 多重选择（4个查询到不同的表）
2. 多次插入（4个查询到不同的表）
3. 删除多（4个查询到不同的表）

请问JDBC或JdbcTemplate的支持？

编辑问：

TicketServiceEnforce ticketDao = TicketServiceEnforceImpl.Factory.getInstance(); 

     // ================================ SELECT ================================ 
     if (unknownTicketId > ZERO) { 
      unknownTicketList = ticketDao.selectUnknownTicket(unknownTicketId); 
      if (!unknownTicketList.isEmpty()) { 
       attachmentList = ticketDao.selectAttachment(QueryString.SELECT_UNKNOWN_TICKET_ATTACHMENT_BY_ID.toString(), unknownTicketId); 
       ticketCodeList = ticketDao.selectTicketCode(QueryString.SELECT_UNKNOWN_TICKET_CODE_BY_ID.toString(), unknownTicketId); 
       ticketCommentList = ticketDao.selectComment(QueryString.SELECT_UNKNOWN_TICKET_COMMENT_BY_ID.toString(), unknownTicketId); 
      } 
     } 
     // ================================ INSERT ================================ 
     // Retrieve customer_id 
     if (!unknownTicketList.isEmpty()) { 
      // Just display all customers's name in UI 
      customerId = ticketDao.selectCustomerIdByName(genericTicket.getCustomerName()); 

      genericTicket.setCustomerId(customerId); 
      genericTicket.setSubject(unknownTicketList.get(ZERO).getSubject()); 
      genericTicket.setDetails(unknownTicketList.get(ZERO).getDetails()); 
      genericTicket.setCreationDate(unknownTicketList.get(ZERO).getCreationDate()); 

      // ===================================================================== 
      ticketId = ticketDao.createTicket(genericTicket); 
      if (ticketId > ZERO) { 

       if (!attachmentList.isEmpty()) { 
        ticketDao.createTicketAttachment(ticketId, attachmentList); 
       } 

       /* 
       * Insert new ticket code 
       */ 
       newTicketCode = generateTicketCode(ticketId); 
       if (!ticketCodeList.isEmpty()) { 
        oldTicketCode = ticketCodeList.get(ZERO); 

        ticketDao.createTicketCode(ticketId, newTicketCode); 
       } 

       /* Insert old unknown ticket code into ticket_email_mapping 
       * This table used to identify the parent child ticket from email - unknown_ticket 
       * by using two queries 
       * 
       * 1. Select ticket code - select ticket code from ticket_email_mapping using id 
       * 2. Select ticket id that has previous ticket code - Select id from ticket_email_mapping tem where tem. 
       * 
       */ 
       if (oldTicketCode != null) { 
        String from_sender = null; 
        if (unknownTicketList.size() > ZERO) { 
         from_sender = unknownTicketList.get(ZERO).getFrom(); 
        } 

        ticketDao.createTicketEmailMapping(ticketId, oldTicketCode, from_sender); 
       } 

       if (!ticketCommentList.isEmpty()) { 
        for (GenericTicketComment comment : ticketCommentList) { 
         comment.setTicketId(ticketId); 
        } 

        ticketDao.createTicketComment(QueryString.INSERT_TICKET_COMMENT.toString(), ticketCommentList); 
       } 

       if (genericTicket.getAssigneeName() != null) { 
        int assigneeId = -1; 
        String firstName = ""; 
        TicketAssignee assignee = new TicketAssignee(); 

        firstName = genericTicket.getAssigneeName(); 
        assigneeId = ticketDao.selectUserId(firstName); 

        assignee.setTicketId(ticketId); 
        assignee.setAssigneeId(assigneeId); 

        ticketDao.createTicketAssignee(assignee); 
       } 

       // If all successfull 
       ticketCreationSuccessful = true; 
      } 
     } 

     // ================================ DELETE ================================ 
     if (ticketCreationSuccessful) { 
      if (!attachmentList.isEmpty()) { 
       affectedRow = ticketDao.removeUnknownTicket(QueryString.DELETE_UNKNOWN_TICKET_ATTACHMENT_BY_ID.toString(), unknownTicketId); 
      } 

      if (!ticketCommentList.isEmpty()) { 
       affectedRow = ticketDao.removeUnknownTicket(QueryString.DELETE_UNKNOWN_TICKET_COMMENT_BY_ID.toString(), unknownTicketId); 
      } 

      affectedRow = ticketDao.removeUnknownTicket(QueryString.DELETE_UNKNOWN_TICKET_CODE_BY_ID.toString(), unknownTicketId); 
      affectedRow = ticketDao.removeUnknownTicket(QueryString.DELETE_UNKNOWN_TICKET_BY_ID.toString(), unknownTicketId); 
     } 

这是使用正常的查询操作的DAO。是否可以在存储过程或批量操作中重写它。

谢谢。请帮忙。

Answer 1

如名称所示jdbcTemplate.batchUpdate您不能在批处理操作中进行选择。如果您想一次完成所有操作，只需创建一个实现逻辑的大SQL，并使用JdbcTemplate.#execute(java.lang.String)方法。