Tutoriel sur l'utilisation DBUnit pour la migration de données

--
 -- Structure de la table `t_client`
 --
 
CREATE TABLE IF NOT EXISTS `t_client` (
 `id` int(10) NOT NULL,
 `name` varchar(50) NOT NULL,
 `adresse` varchar(255) NOT NULL,
 PRIMARY KEY (`id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=latin1;
 
--
 -- Contenu de la table `t_client`
 --
 
INSERT INTO `t_client` (`id`, `name`, `description`) VALUES
 (100, 'Michel Besson', '89 quai Panhard et Levassor 75013'),
 (200, 'Olivier Lecarme', '89 quai Panhard et Levassor 75013'),
 (300, 'Carine Fédéle', '89 quai Panhard et Levassor 75013'),
 (400, 'Cécile Dupond', '89 quai Panhard et Levassor 75013'),
 (500, 'Bile Gate', '89 quai Panhard et Levassor 75013');
 
-- --------------------------------------------------------
 
-- --------------------------------------------------------
 
--
 -- Structure de la table `t_transactions_bancaires`
 --
 
CREATE TABLE IF NOT EXISTS `t_transactions_bancaires` (
 `id` int(10) NOT NULL,
 `name` varchar(50) NOT NULL,
 `amount` double NOT NULL,
 `contrat_fk` int(10) NOT NULL,
 PRIMARY KEY (`id`),
 KEY `contrat_fk_ind` (`contrat_fk`)
 ) ENGINE=InnoDB DEFAULT CHARSET=latin1;
 
--
 -- Contenu de la table `t_transactions_bancaires`
 --
 
INSERT INTO `t_transactions_bancaires` (`id`, `name`, `amount`, `contrat_fk`) VALUES
 (1, 'Paiement de ''option Sport', 10, 41),
 (10, 'Remboursement', 22, 41),
 (11, 'Remboursement pour fidélité', 32, 31);
 
-- --------------------------------------------------------
 
--
 -- Structure de la table `t_contrat`
 --
 
CREATE TABLE IF NOT EXISTS `t_contrat` (
 `id` int(10) NOT NULL,
 `name` varchar(50) NOT NULL,
 `description` varchar(255) NOT NULL,
 `client_fk` int(10) NOT NULL,
 PRIMARY KEY (`id`),
 KEY `client_fk_ind` (`client_fk`)
 ) ENGINE=InnoDB DEFAULT CHARSET=latin1;
 
--
 -- Contenu de la table `t_contrat`
 --
 
INSERT INTO `t_contrat` (`id`, `name`, `description`, `client_fk`) VALUES
 (31, 'Abonnement Télé', 'Description du contrat', 400),
 (32, 'Abonnement Box TV', 'Chaines Sport, Documentaires etc..', 400),
 (41, 'Abonnement Video PLAY', 'description du contrat', 200),
 (71, 'Location', 'Location de divers biens', 300);
 
--
 -- Contraintes pour les tables exportées
 --
 
--
 -- Contraintes pour la table `t_transactions_bancaires`
 --
 ALTER TABLE `t_transactions_bancaires`
 ADD CONSTRAINT `t_transactions_bancaires_ibfk_1` FOREIGN KEY (`contrat_fk`) REFERENCES `t_contrat` (`id`) ON DELETE CASCADE;
 
--u
 -- Contraintes pour la table `t_contrat`
 --
 ALTER TABLE `t_contrat`
 ADD CONSTRAINT `t_contrat_ibfk_1` FOREIGN KEY (`client_fk`) REFERENCES `t_client` (`id`) ON DELETE CASCADE;

<?xml version='1.0' encoding='UTF-8'?>
<dataset>
 <t_client id="100" name="Michel Besson" adresse="89 quai Panhard et Levassor 75013"/>
 <t_client id="200" name="Olivier Lecarme" adresse="89 quai Panhard et Levassor 75013"/>
 <t_client id="300" name="Carine Dubois" adresse="89 quai Panhard et Levassor 75013"/>
 <t_client id="400" name="Lydie Dupond" adresse="89 quai Panhard et Levassor 75013"/>
 <t_client id="500" name="Bile Gate" adresse="89 quai Panhard et Levassor 75013"/>
 <t_contrat id="31" name="Abonnement TV VOD" description="Description du contrat" client_fk="400"/>
 <t_contrat id="32" name="Abonnement Box TV" description="Chaines Sport, Documentaires etc.." client_fk="400"/>
 <t_contrat id="41" name="Abonnement Video PLAY" description="description du contrat" client_fk="200"/>
 <t_contrat id="71" name="Location" description="Location de divers biens" client_fk="300"/>
 <t_transactions_bancaires id="1" name="Paiement option Sport" amount="10.0" contrat_fk="41"/>
 <t_transactions_bancaires id="10" name="Remboursement" amount="22.0" contrat_fk="41"/>
 <t_transactions_bancaires id="11" name="Remboursement pour promotion" amount="32.0" contrat_fk="31"/>
 </dataset></pre>
<pre>

<?xml version='1.0' encoding='UTF-8'?>
<dataset>
  <t_client id="200" name="Olivier Lecarme" adresse="89 quai Panhard et Levassor 75013"/>
  <t_contrat id="41" name="Abonnement Video PLAY" description="description du contrat" client_fk="200"/>
  <t_transactions_bancaires id="1" name="Paiement option Sport" amount="10.0" contrat_fk="41"/>
  <t_transactions_bancaires id="10" name="Remboursement" amount="22.0" contrat_fk="41"/>
</dataset>

package fr.soat.icoundoul.dbunit.entity;

import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.NamedQueries;
import javax.persistence.NamedQuery;

@Entity
@NamedQueries({ @NamedQuery(name = "Customer.find", query = "SELECT p from Customer p where p.firstName like :name " + "or p.lastName like :name") })
public class Customer {
    
    @Id
    private int id;
    
    private String title;
    
    private String firstName;
    
    private String lastName;
    
}

<persistence xmlns="http://java.sun.com/xml/ns/persistence"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd"
    version="2.0">
    <persistence-unit name="pagingDatabase"
        transaction-type="RESOURCE_LOCAL">
        <provider>org.hibernate.ejb.HibernatePersistence</provider>
        <class>fr.soat.icoundoul.dbunit.entity.Customer</class>
        <properties>
            <property name="hibernate.dialect" value="org.hibernate.dialect.HSQLDialect" />
            <property name="hibernate.hbm2ddl.auto" value="create-drop" />
            <property name="hibernate.show_sql" value="true" />
            <property name="hibernate.cache.provider_class" value="org.hibernate.cache.HashtableCacheProvider" />
        </properties>
    </persistence-unit>
</persistence>

package fr.soat.icoundoul.dbunit.service;
 
import java.util.List;
 
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.Query;
 
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import fr.soat.icoundoul.dbunit.entity.Customer;
 
@Service
@Transactional
public class CustomerService {
 
  @PersistenceContext
  private EntityManager entityManager;
 
  @SuppressWarnings("unchecked")
  public List<Customer> find(String name) {
    Query query = entityManager.createNamedQuery("Customer.find");
    query.setParameter("name", "%" + name + "%");
    return query.getResultList();
  }
}

package fr.soat.icoundoul.dbunit.test;

import static junit.framework.Assert.assertEquals;

import java.util.List;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.TestExecutionListeners;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.test.context.support.DependencyInjectionTestExecutionListener;

import com.github.springtestdbunit.DbUnitTestExecutionListener;

import fr.soat.icoundoul.dbunit.entity.Customer;
import fr.soat.icoundoul.dbunit.service.CustomerService;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "/applicationContext.xml" })
@TestExecutionListeners({ DependencyInjectionTestExecutionListener.class, DbUnitTestExecutionListener.class })
public class CustomerServiceTest {
    
    @Autowired
    private CustomerService customerService;
    
    @Test
    public void testFind() throws Exception {
        List<Customer> customerList = customerService.find("hil");
        assertEquals(1, customerList.size());
        assertEquals("Phillip", customerList.get(0).getFirstName());
    }
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="
    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
    http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
    
    <context:component-scan base-package="fr.soat.icoundoul.dbunit" />
    <tx:annotation-driven transaction-manager="transactionManager" />
    
    <bean id="dataSource"
        class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="org.hsqldb.jdbcDriver" />
        <property name="url" value="jdbc:hsqldb:mem:paging" />
        <property name="username" value="sa" />
        <property name="password" value="" />
    </bean>
    
    <bean id="entityManagerFactory"
        class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <property name="jpaDialect">
            <bean class="org.springframework.orm.jpa.vendor.HibernateJpaDialect"/>
        </property>
    </bean>
    
    <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
        <property name="entityManagerFactory" ref="entityManagerFactory" />
    </bean>
</beans>

<?xml version="1.0" encoding="UTF-8"?>
<dataset>
    <Customer id="0" title="Mr" firstName="Phillip" lastName="Webb"/>
    <Customer id="1" title="Mr" firstName="Fred" lastName="Bloggs"/>
</dataset>

public void remove(int personId) {
  Customer customer = entityManager.find(Customer.class, personId);
  entityManager.remove(customer);
}

<?xml version="1.0" encoding="UTF-8"?>
<dataset>
    <Customer id="0" title="Mr" firstName="Phillip" lastName="Webb"/>
</dataset>

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "/applicationContext.xml" })
@TestExecutionListeners({ DependencyInjectionTestExecutionListener.class, DbUnitTestExecutionListener.class })
public class CustomerServiceTest {
    
    @Autowired
    private CustomerService customerService;
    
    @Test
    @DatabaseSetup("/sampleData.xml")
    public void testFind() throws Exception {
        List<Customer> customerList = customerService.find("hil");
        assertEquals(1, customerList.size());
        assertEquals("Phillip", customerList.get(0).getFirstName());
    }
    
    @Test
    @DatabaseSetup("/sampleData.xml")
    @ExpectedDatabase("/expectedData.xml")
    public void testRemove() throws Exception {
        customerService.remove(1);
    }
}