3

hibernatetemplate はbulkUpdate実際に実行していbulkUpdateますか? コードを見たところ、実行していないようですbulkUpdate。または多分私は何かを逃していますか？

public int bulkUpdate(final String queryString, final Object... values) throws DataAccessException {
        return executeWithNativeSession(new HibernateCallback<Integer>() {
            public Integer doInHibernate(Session session) throws HibernateException {
                Query queryObject = session.createQuery(queryString);
                prepareQuery(queryObject);
                if (values != null) {
                    for (int i = 0; i < values.length; i++) {
                        queryObject.setParameter(i, values[i]);
                    }
                }
                return queryObject.executeUpdate();
            }
        });
    }

一方、JdbcTemplate batchUpdate（のように見える）はbatchUpdate

public int[] batchUpdate(final String[] sql) throws DataAccessException {
        Assert.notEmpty(sql, "SQL array must not be empty");
        if (logger.isDebugEnabled()) {
            logger.debug("Executing SQL batch update of " + sql.length + " statements");
        }
        class BatchUpdateStatementCallback implements StatementCallback<int[]>, SqlProvider {
            private String currSql;
            public int[] doInStatement(Statement stmt) throws SQLException, DataAccessException {
                int[] rowsAffected = new int[sql.length];
                if (JdbcUtils.supportsBatchUpdates(stmt.getConnection())) {
                    for (String sqlStmt : sql) {
                        this.currSql = sqlStmt;
                        stmt.addBatch(sqlStmt);
                    }
                    rowsAffected = stmt.executeBatch();
                }
                else {
                    for (int i = 0; i < sql.length; i++) {
                        this.currSql = sql[i];
                        if (!stmt.execute(sql[i])) {
                            rowsAffected[i] = stmt.getUpdateCount();
                        }
                        else {
                            throw new InvalidDataAccessApiUsageException("Invalid batch SQL statement: " + sql[i]);
                        }
                    }
                }
                return rowsAffected;
            }
            public String getSql() {
                return this.currSql;
            }
        }
        return execute(new BatchUpdateStatementCallback());
    }
4

1 に答える 1

0

はい、一括更新を行っています。ご覧のとおり、メソッドDELETEでINSERT実行されるクエリは複数の行に影響を与える可能性があります。そのため、一括操作と呼ばれます。bulkUpdate

ポイントは、更新を実行してクエリを実行し、一括操作で影響を受ける行数を返すための便利なメソッドを用意することです。さらに、DataAccessExceptionへの例外をラップします。

于 2012-06-28T05:10:19.143 に答える