messagein1.java

《短信平台系统》向注册用户提供向指定手机或通讯录中手机发送短信的功能

package com.ascenttech.hib.po;

import java.util.ArrayList;
import java.util.List;

import com.ascenttech.hib.help.PageBean;
import com.ascenttech.hib.vo.HibernateSessionFactory;
import com.ascenttech.hib.vo.t_messgae_in.TMessageIn;

import net.sf.hibernate.HibernateException;
import net.sf.hibernate.Query;
import net.sf.hibernate.Session;
import net.sf.hibernate.Transaction;

public class MessageIn1 {
	// 保存记录用
	List list;

	// 传递信息用
	PageBean p;

	// 验证用
	private String subport;

	// 传入查询总记录用
	String sc;

	public MessageIn1(String subport, String sc) {
		super();
		// TODO Auto-generated constructor stub
		this.subport = subport;
		this.sc = sc;
	}

	public MessageIn1() {
		list = new ArrayList();
	}

	// 得到总行数
	public int getAvailableCount() {
		Transaction ts = null;
		int maxRowCount = 0;
		try {
			Session session = HibernateSessionFactory.currentSession();
			ts = session.beginTransaction();
			// 注意count的传入
			maxRowCount = ((Integer) session.iterate(sc).next()).intValue();
			ts.commit();
		} catch (HibernateException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		try {
			ts.rollback();
		} catch (HibernateException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		return maxRowCount;
	}

	// 查询具体方法
	public PageBean select1(int i, String ss) {

		Transaction ts = null;
		int max;
		int first = (i - 1) * 2;

		try {
			p = new PageBean(this);
			max = p.rowsPerPage;
			Session session = HibernateSessionFactory.currentSession();
			ts = session.beginTransaction();

			Query query = session.createQuery(ss);

			query.setFirstResult(first);
			query.setMaxResults(max);

			if (query != null) {

				list = query.list();
			}
			ts.commit();
		} catch (HibernateException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		try {
			ts.rollback();
		} catch (HibernateException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		p.curPage = i;
		p.list = list;
		return p;
	}

	// 返回集合
	public List getResult() {
		return list;
	}

	public String delete(String[] id) {
		String deleteok = null;
		String seqnum[] = id;
		if (seqnum != null)
			for (int i = 0; i < seqnum.length; i++) {

				// 得到id转化成数据库的类型
				String d = seqnum[i];
				Long l = Long.valueOf(d);
				// 连接数据库
				Transaction ts = null;
				try {
					Session session = HibernateSessionFactory.currentSession();

					Query query = session
							.createQuery("from TMessageIn where seqnum=" + d);
					List list = query.list();
					TMessageIn ti = (TMessageIn) list.get(0);
					Integer f = new Integer(-1);
					ti.setFlag(f);

					ts = session.beginTransaction();
					session.save(ti);
					ts.commit();// 不写数据库不执行语句

				} catch (HibernateException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				try {
					ts.rollback();
				} catch (HibernateException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
			}
		// 验证修改成功
		for (int i1 = 0; i1 < seqnum.length; i1++) {
			// 得到id转化成数据库的类型
			String d1 = seqnum[i1];
			Long l1 = Long.valueOf(d1);
			// 连接数据库

			try {
				Session session1 = HibernateSessionFactory.currentSession();

				Query query1 = session1
						.createQuery("from TMessageIn where seqnum=" + d1);
				List list1 = query1.list();
				TMessageIn ti1 = (TMessageIn) list1.get(0);
				Integer k = new Integer(-1);
				
				if (ti1.getFlag().equals(k)) {
					deleteok = "ok";
					return deleteok;
				} else {
					deleteok = "no";
					return deleteok;
				}

			} catch (HibernateException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

		}

		return deleteok;
	}
}