testservicepojoimp.java

J2EE框架

/*
 * Copyright 2003-2005 the original author or authors.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * 
 */
package com.jdon.framework.test.service;


import org.apache.log4j.Logger;

import com.jdon.controller.events.EventModel;
import com.jdon.controller.model.PageIterator;
import com.jdon.controller.pool.Poolable;
import com.jdon.framework.test.Constants;
import com.jdon.framework.test.dao.JdbcDAO;
import com.jdon.framework.test.model.UserTest;

/**
 * this class implements Poolable, that will active the pool function
 * @author <a href="mailto:[e-mail]">banq </a>
 *  
 */
public class TestServicePOJOImp implements TestService, Poolable{
    private final static Logger logger = Logger
            .getLogger(TestServicePOJOImp.class);

    private JdbcDAO jdbcDao;

    /**
     *  
     */
    public TestServicePOJOImp(JdbcDAO jdbcDao) {
        this.jdbcDao = jdbcDao;
    }

    public void createUser(EventModel em) {
        UserTest user = (UserTest) em.getModel();
        try {
            jdbcDao.insert(user);
            logger.debug(" userId:" + user.getUserId());
            logger.debug(" userName:" + user.getName());
            clearCache();
        } catch (Exception ex) {
            logger.error(ex);
            em.setErrors(Constants.USER_SAVE_ERROR);
        }

    }

    public void updateUser(EventModel em) {
        UserTest user = (UserTest) em.getModel();
        try {
            jdbcDao.update(user);
            logger.debug(" update ok!");
            logger.debug(" userId:" + user.getUserId());
            logger.debug(" userName:" + user.getName());
            clearCache();
        } catch (Exception ex) {
            logger.error(ex);
            em.setErrors(Constants.USER_SAVE_ERROR);
        }

    }

    public void deleteUser(EventModel em) {
        UserTest user = (UserTest) em.getModel();
        try {
            jdbcDao.delete(user);
            clearCache();
            logger.debug(" delete ok!");
        } catch (Exception ex) {
            logger.error(ex);
            em.setErrors(Constants.USER_SAVE_ERROR);
        }

    }

    public UserTest getUser(String userId) {
        logger.debug(" get User from DAO + JDBC");
        return jdbcDao.getUser(userId);

    }

    public PageIterator getAllUsers(int start, int count) {
        PageIterator pageIterator = new PageIterator(PageIterator.EMPTY, 0,
                false);
        try {
            pageIterator = jdbcDao.getUsers(start, count);
        } catch (Exception ex) {
            logger.error(ex);
        }
        return pageIterator;

    }

    private void clearCache() throws Exception {
        jdbcDao.clearCacheOfItem();
    }

}