review.fuel-infra Code Review - packages/trusty/mysql-wsrep-5.6.git/blob

   1 /*
   2    Copyright 2010 Sun Microsystems, Inc.
   3    All rights reserved. Use is subject to license terms.
   4
   5    This program is free software; you can redistribute it and/or modify
   6    it under the terms of the GNU General Public License as published by
   7    the Free Software Foundation; version 2 of the License.
   8
   9    This program is distributed in the hope that it will be useful,
  10    but WITHOUT ANY WARRANTY; without even the implied warranty of
  11    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12    GNU General Public License for more details.
  13
  14    You should have received a copy of the GNU General Public License
  15    along with this program; if not, write to the Free Software
  16    Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301  USA
  17 */
  18
  19 package testsuite.clusterj;
  20
  21 import testsuite.clusterj.model.Employee;
  22
  23 public class DeleteAllByClassTest extends AbstractClusterJModelTest {
  24
  25     private static final String tablename = "t_basic";
  26
  27     private static final int NUMBER_TO_INSERT = 200;
  28
  29     @Override
  30     public void localSetUp() {
  31         createSessionFactory();
  32         session = sessionFactory.getSession();
  33         session.deletePersistentAll(Employee.class);
  34         createEmployeeInstances(NUMBER_TO_INSERT);
  35         tx = session.currentTransaction();
  36         for (int i = 0; i < NUMBER_TO_INSERT; ++i) {
  37             // must be done with an active transaction
  38             try {
  39                 tx.begin();
  40                 session.makePersistent(employees.get(i));
  41                 tx.commit();
  42             } catch (Throwable t) {
  43                 // ignore possible duplicate keys
  44             } finally {
  45                 if (tx.isActive()) {
  46                     tx.rollback();
  47                 }
  48             }
  49         }
  50         addTearDownClasses(Employee.class);
  51     }
  52
  53     public void testDeleteAllByClass() {
  54         tx = session.currentTransaction();
  55         tx.begin();
  56         int count = session.deletePersistentAll(Employee.class);
  57         tx.commit();
  58         assertEquals("Mismatch on number of deleted instances: ",
  59                 NUMBER_TO_INSERT, count);
  60     }
  61 }