0

JDBC または JDBCTemplate を使用したバッチ挿入クエリの例は数多くあります。

Select、Insert、および Delete で構成されるバッチ 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に、バッチ操作で選択することはできません。すべての操作を一度に実行したい場合は、ロジックを実現する 1 つの大きな SQL を作成し、JdbcTemplate.#execute(java.lang.String)メソッドを使用します。

于 2012-12-12T04:52:50.247 に答える