DatabaseOperator { public int[] batch(final String sqlCommand, final Object[]... params) throws SQLException { try { return this.queryRunner.batch(sqlCommand, params); } catch (final SQLException ex) { logger.error("batch operation failed", ex); if (this.dbMetrics != null) { this.dbMetrics.markDBFailUpdate(); } throw ex; } } @Inject  DatabaseOperator(final QueryRunner queryRunner); T query(final String baseQuery, final ResultSetHandler<T> resultHandler,
      final Object... params); T transaction(final SQLTransaction<T> operations); int update(final String updateClause, final Object... params); int[] batch(final String sqlCommand, final Object[]... params); AzkabanDataSource getDataSource();  }
@Test public void testBatch() throws SQLException { int[] res = this.dbOperator.batch(BATCH_COMMAND, BATCH_PARAMETERS); Assert.assertEquals(BATCH_COMMAND_RESULT, res); }