TestCounpenRepository.java 2.4 KB
package com.zhaoonline.coupen.repository;

import com.zhaoonline.coupen.bean.Activity;
import com.zhaoonline.coupen.bean.CommonCoupenEntity;
import com.zhaoonline.coupen.bean.CommonCoupenSeed;
import com.zhaoonline.redis.repository.DataValueRepository;
import com.zhaoonline.redis.template.RedisTemplateFactory;
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;

/**
 * Created by ZhaoOnline<br/>
 * User: yangyoupeng<br/>
 * Date: 2016/12/17<br/>
 * Time: 14:47<br/>
 * Description:please descript you class
 */
public class TestCounpenRepository {
    RedisTemplateFactory factory=null;
    JedisConnectionFactory connectionFactory=null;

    @Before
    public void prepare(){
        connectionFactory=createSimpleFactory();
        factory=new RedisTemplateFactory();
        factory.setConnectionFactory(connectionFactory);
    }
    @Test
    public void testSaveCounpenRepository(){
        DataValueRepository<CommonCoupenEntity> redisRepository=new DataValueRepository<CommonCoupenEntity>(factory);

        CounpenRepository repository = new CounpenRepository(redisRepository);

        CommonCoupenEntity  couppen = new CommonCoupenEntity();
        Activity activity = new Activity();
        activity.setActivityID(1);
        activity.setActivityName("testActivity");

        CommonCoupenSeed seed= new CommonCoupenSeed();
        seed.setSeedID("testSeed1");
        seed.setActivity(activity);
        couppen.setCoupenID("testCoupen1");
        couppen.setSeed(seed);

        repository.saveCoupenEntity(couppen);

        CommonCoupenEntity saveedCoupen= repository.getCoupenEntityByKey("testCoupen1");

        Assert.assertEquals(couppen.getCoupenID(),saveedCoupen.getCoupenID());

        repository.deleteCoupenEntityByKey(couppen);

        CommonCoupenEntity coupenAfterDelete= repository.getCoupenEntityByKey("testCoupen1");

        Assert.assertNull(coupenAfterDelete);
    }

    @After
    public void after(){
        connectionFactory.destroy();
    }

    private JedisConnectionFactory createSimpleFactory(){
        JedisConnectionFactory factory = new JedisConnectionFactory();
        factory.setHostName("192.168.0.188");
        factory.setPort(6377);
        factory.setUsePool(true);
        factory.setDatabase(1);
        factory.afterPropertiesSet();
        return factory;
    }

}