java | My IT thoughts collection

Often we want to test a function against a set of variables.

TestNG offers @DataProvider annotation.

My goal is to test a service class method: findByType of class StateMachineObjectService. This method accepts two ENUM arguments: SmProcess process and SmState state.

I need to feed a collection of different processes and states. Best way is to create an object array with desired combinations and feed it to test function:

@ContextConfiguration (locations = {"classpath:test-mvc-servlet.xml"})
public class StateMachineObjectServiceTest extends AbstractTestNGSpringContextTests {

	@Autowired
	private StateMachineObjectService service;

	@DataProvider (name = "Data-Provider-Function")
	public Object[][] parameterTestProvider() {
		return new Object[][]{
				{SmProcess.ADVERTISE,SmState.INCOMPLETE},
				{SmProcess.ADVERTISE,SmState.ACTIVE},
				{SmProcess.ADVERTISE,SmState.DELETED},
				{SmProcess.ADVERTISE,SmState.EXPIRED},
				{SmProcess.ADVERTISE,SmState.ARCHIVED},
				{SmProcess.ADVERTISE,SmState.INITIAL},
				{SmProcess.ADVERTISE,SmState.SOLD},
				{SmProcess.ADVERTISE,SmState.BUMPED},
		};
	}

	@Test (dataProvider = "Data-Provider-Function")
	public void findByType(SmProcess process, SmState state) {
		System.out.println(process.name() + " " + state.name());
		StateMachineEntity entity = null;
		try {
			entity = service.findByType(process, state);
			//System.out.println(entity.getId() + " " + entity.getProcess().name() + " "
                       + entity.getState().name());
		} catch (RecordNotFoundException e) {
			fail(e.toString());
		}
		assertEquals(entity.getProcess(), process, "returned wrong process");
		assertEquals(entity.getState(), state, "returned wrong state");
	}

}

@ContextConfiguration (locations = {"classpath:test-mvc-servlet.xml"})

public class StateMachineObjectServiceTest extends AbstractTestNGSpringContextTests {

@Autowired

private StateMachineObjectService service;

@DataProvider (name = "Data-Provider-Function")

public Object[][] parameterTestProvider() {

return new Object[][]{

{SmProcess.ADVERTISE,SmState.INCOMPLETE},

{SmProcess.ADVERTISE,SmState.ACTIVE},

{SmProcess.ADVERTISE,SmState.DELETED},

{SmProcess.ADVERTISE,SmState.EXPIRED},

{SmProcess.ADVERTISE,SmState.ARCHIVED},

{SmProcess.ADVERTISE,SmState.INITIAL},

{SmProcess.ADVERTISE,SmState.SOLD},

{SmProcess.ADVERTISE,SmState.BUMPED},

};

}

@Test (dataProvider = "Data-Provider-Function")

public void findByType(SmProcess process, SmState state) {

System.out.println(process.name() + " " + state.name());

StateMachineEntity entity = null;

try {

entity = service.findByType(process, state);

//System.out.println(entity.getId() + " " + entity.getProcess().name() + " "

+ entity.getState().name());

} catch (RecordNotFoundException e) {

fail(e.toString());

}

assertEquals(entity.getProcess(), process, "returned wrong process");

assertEquals(entity.getState(), state, "returned wrong state");

}

Output is like:

ADVERTISE INCOMPLETE
Hibernate: select statemachi0_.id as id1_22_, statemachi0_.process as process2_22_, statemachi0_.state as state3_22_ from sm_map statemachi0_ where statemachi0_.process=0 and statemachi0_.state=0

ADVERTISE ACTIVE
Hibernate: select statemachi0_.id as id1_22_, statemachi0_.process as process2_22_, statemachi0_.state as state3_22_ from sm_map statemachi0_ where statemachi0_.process=0 and statemachi0_.state=1
…

===============================================
Custom suite
Total tests run: 8, Failures: 0, Skips: 0
===============================================

Spring MVC Project with maven, mongodb, spring-data

This will contain only snippets of code. There are small dependencies that are not listed in these blocks of code.

I am running mongoDB in a remote Centos 6.2 Server.

Main Database is a PostgreSQL. Upper layers in MVC Service classes will try to fetch data from mongoDB. If is not available, will use SQL DB and update mongoDB. My application uses mongo for caching purposes and writes denormalized relationships in mongoDB.

pom.xml

&lt;dependency&gt;
        &lt;groupId&gt;org.mongodb&lt;/groupId&gt;
        &lt;artifactId&gt;mongo-java-driver&lt;/artifactId&gt;
        &lt;version&gt;2.8.0&lt;/version&gt;
&lt;/dependency&gt;

&lt;dependency&gt;
        &lt;groupId&gt;org.springframework.data&lt;/groupId&gt;
        &lt;artifactId&gt;spring-data-mongodb&lt;/artifactId&gt;
        &lt;version&gt;${spring-data.mongodb.version}&lt;/version&gt;
&lt;/dependency&gt;

<groupId>org.mongodb</groupId>

<artifactId>mongo-java-driver</artifactId>

</dependency>

<groupId>org.springframework.data</groupId>

<artifactId>spring-data-mongodb</artifactId>

<version>${spring-data.mongodb.version}</version>

</dependency>

web.xml

&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?&gt;
&lt;web-app version=&quot;2.4&quot;
         xmlns=&quot;http://java.sun.com/xml/ns/j2ee&quot;
         xmlns:xsi=&quot;http://www.w3.org/2001/XMLSchema-instance&quot;
         xsi:schemaLocation=&quot;http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd&quot;&gt;
        &lt;display-name&gt;Bikeshop&lt;/display-name&gt;

        &lt;filter&gt;
                &lt;filter-name&gt;springSecurityFilterChain&lt;/filter-name&gt;
                &lt;filter-class&gt;org.springframework.web.filter.DelegatingFilterProxy&lt;/filter-class&gt;
        &lt;/filter&gt;

        &lt;filter-mapping&gt;
                &lt;filter-name&gt;springSecurityFilterChain&lt;/filter-name&gt;
                &lt;url-pattern&gt;/*&lt;/url-pattern&gt;
        &lt;/filter-mapping&gt;

        &lt;context-param&gt;
                &lt;param-name&gt;contextConfigLocation&lt;/param-name&gt;
                &lt;param-value&gt;/WEB-INF/applicationContext.xml&lt;/param-value&gt;
        &lt;/context-param&gt;

        &lt;listener&gt;
                &lt;listener-class&gt;org.springframework.web.context.ContextLoaderListener&lt;/listener-class&gt;
        &lt;/listener&gt;

        &lt;!-- MVC SERVLET --&gt;
        &lt;servlet&gt;
                &lt;servlet-name&gt;mvc&lt;/servlet-name&gt;
                &lt;servlet-class&gt;org.springframework.web.servlet.DispatcherServlet&lt;/servlet-class&gt;
                &lt;load-on-startup&gt;1&lt;/load-on-startup&gt;
        &lt;/servlet&gt;

        &lt;servlet-mapping&gt;
                &lt;servlet-name&gt;mvc&lt;/servlet-name&gt;
                &lt;url-pattern&gt;/&lt;/url-pattern&gt;
        &lt;/servlet-mapping&gt;

        &lt;welcome-file-list&gt;
                &lt;welcome-file&gt;/pages/index.jsp&lt;/welcome-file&gt;
        &lt;/welcome-file-list&gt;

&lt;/web-app&gt;

<?xml version="1.0" encoding="UTF-8"?>

<web-app version="2.4"

xmlns="http://java.sun.com/xml/ns/j2ee"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">

<display-name>Bikeshop</display-name>

<filter-name>springSecurityFilterChain</filter-name>

<filter-class>org.springframework.web.filter.DelegatingFilterProxy</filter-class>

</filter>

<filter-mapping>

<filter-name>springSecurityFilterChain</filter-name>

<url-pattern>/*</url-pattern>

</filter-mapping>

<context-param>

<param-name>contextConfigLocation</param-name>

<param-value>/WEB-INF/applicationContext.xml</param-value>

</context-param>

<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>

</listener>

<servlet-name>mvc</servlet-name>

<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>

<load-on-startup>1</load-on-startup>

</servlet>

<servlet-mapping>

<servlet-name>mvc</servlet-name>

<url-pattern>/</url-pattern>

</servlet-mapping>

<welcome-file-list>

<welcome-file>/pages/index.jsp</welcome-file>

</welcome-file-list>

</web-app>

applicationContext.xml

&lt;mongo:mongo id=&quot;mongo&quot; host=&quot;${mongo.host}&quot; port=&quot;${mongo.port}&quot;/&gt;
&lt;mongo:repositories base-package=&quot;com.jadebaboon.nucleus.shared.persistence.repository.mongo&quot;/&gt;

&lt;bean id=&quot;mongoTemplate&quot;&gt;
        &lt;constructor-arg name=&quot;mongo&quot; ref=&quot;mongo&quot;/&gt;
        &lt;constructor-arg name=&quot;databaseName&quot; value=&quot;${mongo.database}&quot;/&gt;
&lt;/bean&gt;

<mongo:mongo id="mongo" host="${mongo.host}" port="${mongo.port}"/>

<mongo:repositories base-package="com.jadebaboon.nucleus.shared.persistence.repository.mongo"/>

<constructor-arg name="mongo" ref="mongo"/>

<constructor-arg name="databaseName" value="${mongo.database}"/>

</bean>

A very simple entity:

@Document (collection = &quot;brands&quot;)
public class BrandCache {

        private int id;
        private String name;

        public int getId() {
                return id;
        }

        public void setId(int id) {
                this.id = id;
        }

        public String getName() {
                return name;
        }

        public void setName(String name) {
                this.name = name;
        }

        @Override
        public String toString() {
                return &quot;BrandCache [id=&quot; + id + &quot;, name=&quot; + name + &quot;]&quot;;
        }

}

@Document (collection = "brands")

public class BrandCache {

private int id;

private String name;

public int getId() {

return id;

}

public void setId(int id) {

this.id = id;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

@Override

public String toString() {

return "BrandCache [id=" + id + ", name=" + name + "]";

}

A ultra simple Dao Repository:

@Repository
public interface MongoBrandCacheRepository extends MongoRepository&lt;BrandCache, Integer&gt; {

}

@Repository

public interface MongoBrandCacheRepository extends MongoRepository<BrandCache, Integer> {

}

Service class for Repository (contains JPA code for data transfer from JPA Repository to Mongo Repository, can be ignored):

@Service
public class BrandCacheServiceImpl implements BrandCacheService {

        @Autowired
        private MongoBrandCacheRepository mongoBrandCacheRepository;

        @Autowired
        private JpaBrandRepository jpaBrandRepository;

        @Autowired
        private MongoTemplate mongoTemplate;

        @Override
        public List&lt;BrandCache&gt; readAll() throws RecordNotFoundException {
                List&lt;BrandCache&gt; brandCacheList = mongoBrandCacheRepository.findAll();
                if (brandCacheList.size() == 0)
                        throw new RecordNotFoundException(&quot;BrandCache Database is empty&quot;);

                return brandCacheList;
        }

        @Override
        public BrandCache create(BrandCache brandCache) {
                mongoBrandCacheRepository.save(brandCache);
                return brandCache;
        }

        @Override
        public void refreshRepository() throws RecordNotFoundException {
                List&lt;BrandEntity&gt; result = jpaBrandRepository.findAll();
                if (result.size() == 0)
                        throw new RecordNotFoundException(&quot;Brand Database is empty&quot;);

                mongoTemplate.dropCollection(&quot;brands&quot;);

                for (BrandEntity brandEntity : result) {
                        System.out.println(&quot;INSERTING: &quot; + brandEntity.getId() + &quot; &quot; + brandEntity.getName());
                        BrandCache brandCache = new BrandCache();
                        brandCache.setId(brandEntity.getId());
                        brandCache.setName(brandEntity.getName());
                        mongoBrandCacheRepository.save(brandCache);
                }
        }

        @Override
        public BrandCache update(BrandCache brandCache) {
                //not implemented
                return null;
        }

        @Override
        public void delete(BrandCache brandCache) {
                //not implemented
        }
}

@Service

public class BrandCacheServiceImpl implements BrandCacheService {

@Autowired

private MongoBrandCacheRepository mongoBrandCacheRepository;

@Autowired

private JpaBrandRepository jpaBrandRepository;

@Autowired

private MongoTemplate mongoTemplate;

@Override

public List<BrandCache> readAll() throws RecordNotFoundException {

List<BrandCache> brandCacheList = mongoBrandCacheRepository.findAll();

if (brandCacheList.size() == 0)

throw new RecordNotFoundException("BrandCache Database is empty");

return brandCacheList;

}

@Override

public BrandCache create(BrandCache brandCache) {

mongoBrandCacheRepository.save(brandCache);

return brandCache;

}

@Override

public void refreshRepository() throws RecordNotFoundException {

List<BrandEntity> result = jpaBrandRepository.findAll();

if (result.size() == 0)

throw new RecordNotFoundException("Brand Database is empty");

mongoTemplate.dropCollection("brands");

for (BrandEntity brandEntity : result) {

System.out.println("INSERTING: " + brandEntity.getId() + " " + brandEntity.getName());

BrandCache brandCache = new BrandCache();

brandCache.setId(brandEntity.getId());

brandCache.setName(brandEntity.getName());

mongoBrandCacheRepository.save(brandCache);

}

@Override

public BrandCache update(BrandCache brandCache) {

//not implemented

return null;

}

@Override

public void delete(BrandCache brandCache) {

//not implemented

}

Unit test for this implementation:

@ContextConfiguration (locations = {&quot;classpath:test-mvc-servlet.xml&quot;})
public class MongoBrandCacheServiceTest extends AbstractTestNGSpringContextTests {

        @Autowired (required = true)
        private BrandCacheService brandCacheService;

        @Test
        public void readAllTest() {

                try {
                        List&lt;BrandCache&gt; brandCacheList = brandCacheService.readAll();
                        for (BrandCache brandCache : brandCacheList)
                                System.out.println(brandCache.getName());
                        assertNotEquals(brandCacheList.size(), 0, &quot;returned 0 objects&quot;);

                } catch (Exception ex) {
                        fail(ex.getMessage());
                }
        }

        @Test
        public void refreshRepositoryTest() {
                try {
                        brandCacheService.refreshRepository();
                } catch (Exception ex) {
                        fail(ex.getMessage());
                }
        }

}

@ContextConfiguration (locations = {"classpath:test-mvc-servlet.xml"})

public class MongoBrandCacheServiceTest extends AbstractTestNGSpringContextTests {

@Autowired (required = true)

private BrandCacheService brandCacheService;

@Test

public void readAllTest() {

try {

List<BrandCache> brandCacheList = brandCacheService.readAll();

for (BrandCache brandCache : brandCacheList)

System.out.println(brandCache.getName());

assertNotEquals(brandCacheList.size(), 0, "returned 0 objects");

} catch (Exception ex) {

fail(ex.getMessage());

}

@Test

public void refreshRepositoryTest() {

try {

brandCacheService.refreshRepository();

} catch (Exception ex) {

fail(ex.getMessage());

}

My IT thoughts collection

Tag Archives: java

Sniff Request Parameters

TestNG with Parameters

Criteria Query – find by id

Random number

Spring Data Mongo DB

by JadeBaboon Team