0

有许多使用 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。是否可以在存储过程或批量操作中重写它。

谢谢。请帮忙。

4

1 回答 1

2

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

于 2012-12-12T04:52:50.247 回答