indexindexsdaoimpl.java.svn-base

用户模块和指标模块等等,还有其它的模块吧

package com.srit.gcz.dao.impl;

import java.util.List;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapperResultSetExtractor;

import com.srit.gcz.bean.IndexCategory;
import com.srit.gcz.bean.IndexData;
import com.srit.gcz.bean.IndexIndexs;
import com.srit.gcz.bean.rowmapper.IndexCategoryRowMapper;
import com.srit.gcz.bean.rowmapper.IndexDataRowMapper;
import com.srit.gcz.bean.rowmapper.IndexIndexsRowMapper;
import com.srit.gcz.dao.IndexIndexsDao;
import com.srit.gcz.util.Pagination;
import com.srit.gcz.util.SysConstant;

/**
 * 指标
 * 
 * @Company 国研科技
 * @author 陈鹏昊
 * @date 2009-3-24
 * @version 1.0
 * @since 1.0
 */
public class IndexIndexsDaoImpl implements IndexIndexsDao {
	// 查询某节点
	private static final String QUERY_INDEXS = "SELECT * FROM "
			+ SysConstant.TABLE_INDEX_INDEXS + " WHERE ID = ?";
	// 分页查询所有
	private static final String QUERY_PAGE_INDEXS = "SELECT * FROM "
			+ SysConstant.TABLE_INDEX_INDEXS + " WHERE CATEGORYID = ?";
	// 分页查询所有
	private static final String QUERY_ALL_INDEXS = "SELECT * FROM "
			+ SysConstant.TABLE_INDEX_INDEXS;
	// 获得某分类下指标的数量
	private static final String QUERY_COUNT_INDEXS = "SELECT COUNT(*) FROM "
			+ SysConstant.TABLE_INDEX_INDEXS + " WHERE CATEGORYID = ?";
	// 新增
	private static final String INSERT_INDEXS = "INSERT INTO "
			+ SysConstant.TABLE_INDEX_INDEXS
			+ "(ID, INDEXNAME, STATE, REMARK, UNITID, SEQUENCE, PARENTID, CATEGORYID) VALUES(?, ?, ?, ?, ?, ?, ?, ?)";
	// 更新
	private static final String UPDATE_INDEXS = "UPDATE "
			+ SysConstant.TABLE_INDEX_INDEXS
			+ " SET INDEXNAME = ?, STATE = ?, REMARK = ?, UNITID = ?, SEQUENCE = ?, PARENTID = ?, CATEGORYID = ? WHERE ID = ?";
	// 更新 状态
	private static final String UPDATE_STAT_INDEXS = "UPDATE "
			+ SysConstant.TABLE_INDEX_INDEXS + " SET STATE = ? WHERE ID = ?";
	// 更新 序号
	private static final String UPDATE_SEQUENCE_INDEXS = "UPDATE "
			+ SysConstant.TABLE_INDEX_INDEXS + " SET SEQUENCE = ? WHERE ID = ?";
	// 删除指标
	private static final String DELETE_INDEXS = "DELETE FROM "
			+ SysConstant.TABLE_INDEX_INDEXS + " WHERE ID = ?";
	// Spring注入
	private JdbcTemplate jdbcTemplate;

	public Pagination findPageIndexIndexsByID(int CID, int currentPage,
			int pageSize) {
		Pagination page = new Pagination(jdbcTemplate);
		page.queryForList(QUERY_PAGE_INDEXS, new Object[] { CID },
				new IndexIndexsRowMapper(), currentPage, pageSize);
		return page;
	}

	@SuppressWarnings("unchecked")
	public List<IndexIndexs> getAllIndexIndexs(int CID) {
		Object obj = jdbcTemplate.query(QUERY_PAGE_INDEXS, new Object[] { CID },
				new RowMapperResultSetExtractor(new IndexIndexsRowMapper()));
		return (List<IndexIndexs>) obj;
	}
	
	public int getDataRows(int CID, int currentPage, int pageSize) {
		return jdbcTemplate.queryForInt(QUERY_COUNT_INDEXS,
				new Object[] { CID });
	}

	public IndexIndexs getIndexIndexsByID(int ID) {
		IndexIndexs bean = (IndexIndexs) jdbcTemplate.queryForObject(
				QUERY_INDEXS, new Object[] { ID }, new IndexIndexsRowMapper());
		return bean;
	}

	public boolean save(IndexIndexs bean) {
		int operMark = jdbcTemplate.update(INSERT_INDEXS, new Object[] {
				bean.getId(), bean.getIndexName(), bean.getState(),
				bean.getRemark(), bean.getUnitId(), bean.getSequence(),
				bean.getParentId(), bean.getCategoryId() });
		return (operMark > 0) ? true : false;
	}

	public boolean update(IndexIndexs bean) {
		int operMark = jdbcTemplate.update(UPDATE_INDEXS, new Object[] {
				bean.getIndexName(), bean.getState(), bean.getRemark(),
				bean.getUnitId(), bean.getSequence(), bean.getParentId(),
				bean.getCategoryId(), bean.getId() });
		return (operMark > 0) ? true : false;
	}

	public boolean updateState(String IDs, int state) {
		String[] idArray = IDs.split(",");
		for (int i = 0; i < idArray.length; i++) {
			int id = Integer.parseInt(idArray[i]);
			if (jdbcTemplate.update(UPDATE_STAT_INDEXS, new Object[] { state,
					id }) < 1) {
				return false;
			}
		}
		return true;
	}

	public boolean updateSequence(IndexIndexs bean) {
		int operMark = jdbcTemplate.update(UPDATE_SEQUENCE_INDEXS,
				new Object[] { bean.getSequence(), bean.getId() });
		return (operMark > 0) ? true : false;
	}

	public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
		this.jdbcTemplate = jdbcTemplate;
	}

	public boolean delete(String IDs) {
		String[] idArray = IDs.split(",");
		for (int i = 0; i < idArray.length; i++) {
			int id = Integer.parseInt(idArray[i]);
			if (jdbcTemplate.update(DELETE_INDEXS, new Object[] { id }) < 1) {
				return false;
			}
		}
		return true;
	}

	@SuppressWarnings("unchecked")
	public List<IndexIndexs> getAllIndexIndexs() {
		Object obj = jdbcTemplate.query(QUERY_ALL_INDEXS,
				new RowMapperResultSetExtractor(new IndexIndexsRowMapper()));
		return (List<IndexIndexs>) obj;
	}
}