businessmanage.java

新的新闻发布系统,采用struts+hibernate,sqlserver数据库

package com.wang.business;

import org.hibernate.*;
import org.hibernate.cfg.*;
import com.wang.module.*;
import java.util.*;

public class BusinessManage
{
    private SessionFactory sf = null;
    private Session s = null;
    private Transaction ts = null;
    private Query query = null;
    public static int PAGECOUNT;
    public BusinessManage()
    {
        sf = new Configuration().configure().buildSessionFactory();
        s = sf.openSession();
        ts = s.beginTransaction();
    }

    public void openSession()
    {
        s = sf.openSession();
    }

    public boolean checkLogin(User user)
    {
        boolean flag = false;
        try
        {
            query = s.createQuery("from User user where user.userName='" +
                                  user.getUserName() + "' and userPwd='" +
                                  user.getUserPwd() + "'");
            List list = query.list();
            if (list.size() > 0)
            {
                flag = true;
            }
            else
            {
                flag = false;
            }
        }
        catch (Exception e)
        {
            flag = false;
            e.printStackTrace();
        }
        return flag;
    }

    public List selectCDBean(String value, int page, int count)
    {
        List list = null;
        int pagelast = 0;
        try
        {
            query = s.createQuery("from CDDate cd where cd.cdName like '%" +
                                  value + "%'");

            if (query.list().size() / count == 0)
            {
                PAGECOUNT = query.list().size() / count;
            }
            else
            {
                PAGECOUNT = query.list().size() / count + 1;
                pagelast = query.list().size() / count;
            }
            int begin = page * count - count;
            int end = page * count;
            if (page == PAGECOUNT)
            {
                end = query.list().size();
            }
            list = query.list().subList(begin, end);
        }
        catch (Exception ex)
        {
            list = null;
            ex.printStackTrace();
        }
        return list;
    }

    public boolean updataCDDate(CDDate cd)
    {
        s.update(cd);
        ts.commit();
        return ts.wasCommitted();
    }

    public CDDate getCDDate(long id)
    {
        CDDate cd = (CDDate) s.load(CDDate.class, id);
        ts.commit();
        return cd;
    }

    public boolean delCDDate(long id)
    {
        CDDate cd = (CDDate) s.get(CDDate.class, id);
        s.delete(cd);
        ts.commit();
        return ts.wasCommitted();
    }

    public boolean updateUser(User user)
    {
        query = s.createQuery("from User user where user.userName='" +
                              user.getUserName() + "'");
        User temp = (User) query.list().get(0);
        temp.setUserPwd(user.getUserPwd());
        s.update(temp);
        ts.commit();
        return ts.wasCommitted();
    }

    private boolean hasUser(User user)
    {
        boolean flag = false;
        query = s.createQuery("from User user where user.userName='" +
                              user.getUserName() + "'");
        if (query.list().size() != 0)
        {
            flag = true;
        }
        return flag;
    }

    public boolean addCDDate(CDDate cd)
    {
        s.save(cd);
        ts.commit();
        return ts.wasCommitted();
    }

    public boolean addUser(User user)
    {
        if (hasUser(user))
        {
            return false;
        }
        s.save(user);
        ts.commit();
        return ts.wasCommitted();
    }

    public void close()
    {
        s.close();
    }
}