Struts2+Hibernate新闻发布系统增删改查

package com.dao; import java.math.BigDecimal; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import com.bean.News; import com.util.HibernateSessionFactory; public class NewsDao { //设置当前时间，修改日志 所取得的时刻 Date now = new Date(); DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String ds = df.format(now); public List<News> getAllNews(){ List<News> list = null; SessionFactory sf = HibernateSessionFactory.getSessionFactory(); Session session = HibernateSessionFactory.getSession(); Transaction ts = null; try { ts = session.beginTransaction(); Query query =session.createQuery("from News order by dates desc"); list = query.list(); ts.commit(); } catch (Exception e) { e.printStackTrace(); } finally{ session.close(); } return list; } /* public News getById(News news){ News n = new News(); List<News> list = null; SessionFactory sf = HibernateSessionFactory.getSessionFactory(); Session session = HibernateSessionFactory.getSession(); Transaction ts = null; try { ts = session.beginTransaction(); Query query =session.createQuery("from News where id='"+news.getId()+"'"); list = query.list(); for (int i = 0; i <list.size(); i++) { n = list.get(i); } ts.commit(); } catch (Exception e) { e.printStackTrace(); } finally{ session.close(); } return n; }*/ public News getById(News news){ News n = new News(); List<News> list = null; SessionFactory sf = HibernateSessionFactory.getSessionFactory(); Session session = HibernateSessionFactory.getSession(); try { session.beginTransaction(); n = (News)session.get(News.class, news.getId()); session.getTransaction().commit(); } catch (Exception e) { e.printStackTrace(); } finally{ session.close(); } return n;} public int getAddCount(News news){ int flag = 0; SessionFactory sf = HibernateSessionFactory.getSessionFactory(); Session session = HibernateSessionFactory.getSession(); Transaction ts = null; try { ts = session.beginTransaction(); Query q = session.createQuery("update News n set n.count=n.count+1 where n.id='"+news.getId()+"'"); flag = q.executeUpdate(); ts.commit(); } catch (Exception e) { e.printStackTrace(); } finally{ session.close(); } return flag; } public void getAddNews(News news){ SessionFactory sf = HibernateSessionFactory.getSessionFactory(); Session session = HibernateSessionFactory.getSession(); Transaction ts = null; try { ts = session.beginTransaction(); news.setId(new BigDecimal(0)); session.save(news); ts.commit(); } catch (Exception e) { e.printStackTrace(); } finally{ session.close(); } } public void getUpdateNews(News news){ SessionFactory sf = HibernateSessionFactory.getSessionFactory(); Session session = HibernateSessionFactory.getSession(); Transaction ts = null; try { ts = session.beginTransaction(); news.setLastupdate(ds); session.update(news); ts.commit(); } catch (Exception e) { e.printStackTrace(); } finally{ session.close(); } } public void getDeleteNews(News news){ SessionFactory sf = HibernateSessionFactory.getSessionFactory(); Session session = HibernateSessionFactory.getSession(); Transaction ts = null; try { ts = session.beginTransaction(); session.delete(news); ts.commit(); } catch (Exception e) { e.printStackTrace(); } finally{ session.close(); } } /** * 实现分页技术 */ // 获取查询内容 分页 public List<News> findwithpage(int pagesize,int currentrow){ List<News> list = null; SessionFactory sf = HibernateSessionFactory.getSessionFactory(); Session session = HibernateSessionFactory.getSession(); Transaction ts = null; try { ts = session.beginTransaction(); Query query =session.createQuery("from News order by dates desc").setFirstResult(currentrow).setMaxResults(pagesize); list = query.list(); ts.commit(); } catch (Exception e) { e.printStackTrace(); } finally{ session.close(); } return list; } //新闻的记录总数 public int getRows(){ long totalrows = 0; SessionFactory sf = HibernateSessionFactory.getSessionFactory(); Session session = HibernateSessionFactory.getSession(); Transaction ts = null; try { ts = session.beginTransaction(); Object ob =(session.createQuery("select count(*) from News").iterate().next()); totalrows = Integer.parseInt(ob.toString()); //Query q = session.createQuery("select count(*) from News"); //获得查询条件行数 //list = q.list(); //flag = (Long)list.get(0); ts.commit(); } catch (Exception e) { e.printStackTrace(); } finally{ session.close(); } return (int) totalrows; } }