merchantbusinessrecordcommentdao.java

基于struts的网上商店源码

package com.mole.struts.dao;

import java.sql.Connection;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.Iterator;

import com.mole.struts.bean.MerchantBusinessRecordCommentBean;

public class MerchantBusinessRecordCommentDAO extends AbstractDAO {

	public int getCount(String storeId) {
		Connection conn = getConn();
		int count = 0;
		ResultSet rs = null;
		String sql = "SELECT COUNT(*) FROM v_RecordComment WHERE StoreID='"
				+ storeId + "'";
		try {
			rs = conn.prepareStatement(sql).executeQuery();
			if (rs.next())
				count = rs.getInt(1);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return count;
	}

	public MerchantBusinessRecordCommentBean[] getComment(String storeId,
			int currentPage, int pageSize) throws Exception {
		String sql = "SELECT TOP "
				+ pageSize
				+ " [ID],convert(varchar(20),ReleaseDate,120),[Name],[CommentContext],[SwiftID] FROM [v_RecordComment] WHERE  [StoreID]='"
				+ storeId + "' AND [ID] NOT IN (" + "SELECT TOP "
				+ (currentPage - 1) * pageSize
				+ " [ID] FROM [v_RecordComment] WHERE StoreID='" + storeId
				+ "')";
		ArrayList<Object[]> arrayList = this.executeQuery(sql);
		if (arrayList == null)
			return null;

		MerchantBusinessRecordCommentBean[] records = new MerchantBusinessRecordCommentBean[arrayList
				.size()];
		Iterator<Object[]> it = arrayList.iterator();
		int i = 0;
		while (it.hasNext()) {
			Object[] obj = it.next();
			MerchantBusinessRecordCommentBean record = new MerchantBusinessRecordCommentBean();
			record.setId(obj[0].toString());
			record.setReleaseDate(obj[1].toString().substring(0, 10));
			record.setName(obj[2].toString());
			record.setCommentContext(obj[3].toString());
			record.setSwiftId(obj[4].toString());
			records[i++] = record;
		}
		return records;
	}
}