package com.pb.news.dao.impl;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.sql.Types;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.sql.Timestamp;
import com.pb.news.dao.BaseDao;
import com.pb.news.dao.NewsDao;
import com.pb.news.entity.News;
import com.pb.news.util.ConfigManager;
import com.pb.news.util.Page;
public class NewsDaoImpl extends BaseDao implements NewsDao{
@Override
//通过新闻ID获取新闻
public News getNewsById(int id) {
News news=null;
try{
//（3）获得Statement对象，执行SQL语句
String sql="select * from news_detail where id= "+id;
Object[] params={};
ResultSet rs=this.excuteSQL(sql, params);
////（4）处理执行结果(ResultSet)
if(rs.next()){
int categoryId=rs.getInt("categoryId");
String title=rs.getString("title");
String summary=rs.getString("summary");
String content=rs.getString("content");
String picPath=rs.getString("picPath");
String author=rs.getString("author");
Timestamp time=rs.getTimestamp("createdate");
//封装成新闻信息对象
news=new News();
news.setId(id);
news.setCategoryId(categoryId);
news.setTitle(title);
news.setSummary(summary);
news.setContent(content);
news.setPicpath(picPath);
news.setAuthor(author);
news.setCreatedate(time);
}
}catch(SQLException e){
e.getStackTrace();
}finally{
this.closeResource();
}
return news;
}
//查询新闻信息
public List<News> getNewsList(){
List<News> newList=new ArrayList<News>();
try {
//3.获得Statement对象，执行sql语句
String sql="select * from news_detail order by createdate ASC";
Object[] params={};
ResultSet rs=this.excuteSQL(sql, params);
//4.处理执行结果（ResultSet)，释放资源
while(rs.next()){
int id=rs.getInt("id");
String title=rs.getString("title");
String summary=rs.getString("summary");
String content=rs.getString("content");
String author=rs.getString("author");
Timestamp time=rs.getTimestamp("createdate");
// System.out.println(id+"\t"+title+"\t"+summary+"\t"+
// content+"\t"+author+"\t"+time);
//封装成新闻信息对象
News news=new News();
news.setId(id);
news.setTitle(title);
news.setSummary(summary);
news.setContent(content);
news.setAuthor(author);
news.setCreatedate(time);
//将新闻对象放到集合中
newList.add(news);
}
}catch (SQLException e) {
e.printStackTrace();
}finally{
//释放资源
this.closeResource();
}
return newList;
}
//增加新闻信息
public boolean add(News news){
boolean flag=false;
try {
String sql="insert into news_detail(id,categoryId,title,summary,content,picPath,createdate,author) "
+ "values(SEQ_NEWS.nextval,?,?,?,?,?,?,?)";
Object[] params={news.getCategoryId(),news.getTitle(),news.getSummary()
,news.getContent(),news.getPicpath(),new java.sql.Timestamp(news.getCreatedate().getTime()),news.getAuthor()};
int i=this.excuteUpdate(sql, params);
//4.处理执行结果（ResultSet)，释放资源
if(i>0){
System.out.println("插入新闻成功！");
}
flag=true;
}finally{
//释放资源
this.closeResource();
}
return flag;
}
//删除新闻信息
public boolean delete(int id){
boolean flag=false;
try {
//获取statement对象，执行sql语句
String sql="delete from news_Detail where id=?";
Object[] params={id};
//处理执行结果
int i=this.excuteUpdate(sql, params);
if(i>0){
System.out.println("册除新闻成功！");
}
flag=true;
} finally{
//释放资源
this.closeResource();
}
return flag;
}
//修改整个新闻信息
public boolean update(News news){
boolean flag=false;
try {
//获取statement对象，执行sql语句
String sql="update news_Detail set categoryId=?,title=?,summary=?,content=?,"
+ "picpath=?,author=?,modifydate=? where id=?";
Object[] params={news.getCategoryId(),news.getTitle(),news.getSummary(),
news.getContent(),news.getPicpath(),news.getAuthor(),
new java.sql.Timestamp(news.getModifydate().getTime()),news.getId()};
//处理执行结果
int i=this.excuteUpdate(sql, params);
if(i>0){
System.out.println("修改新闻成功！");
}
flag=true;
} finally{
//释放资源
this.closeResource();
}
return flag;
}
@Override
//获取新闻总数量
public int getTotalCount() {
int totalCount=0;
String sql="select count(*) from news_detail";
Object[] params={};
ResultSet rs=this.excuteSQL(sql, params);
try {
while(rs.next()){
totalCount=rs.getInt(1);
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
this.closeResource();
}
return totalCount;
}
@Override
//分页获取新闻信息
public List<News> getPageNewsList(int pageNo, int pageSize) {
List<News> newsList=new ArrayList<News>();
String sql="SELECT id,title,author,createdate FROM (SELECT id,title,author,createdate,ROWNUM rn FROM news_detail) a WHERE a.rn>=? AND a.rn<=? ";
Page page=new Page();
page.setCurrPageNo(pageNo);//设置当前页码
page.setPageSize(pageSize);//每页显示记录数
//计算sql语句的起始记录数及结束记录数的行数
int startRow=page.getStartRow();
int endRow=page.getEndRow();
Object[] params={startRow,endRow};
ResultSet rs=this.excuteSQL(sql, params);
try {
while(rs.next()){
int id=rs.getInt("id");
String title=rs.getString("title");
String author=rs.getString("author");
Date date=rs.getDate("createdate");
News newInfo=new News();
newInfo.setId(id);
newInfo.setTitle(title);
newInfo.setAuthor(author);
newInfo.setCreatedate(new java.sql.Timestamp(date.getTime()));
newsList.add(newInfo);
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
this.closeResource();
}
return newsList;
}
//获取新闻总数（执行存储过程）
public int getTotalCountProc(){
int totalCount=0;
CallableStatement proc=null;
String sql="{call getNewsCount(?)}";
getConnection();
try {
proc=conn.prepareCall(sql);
proc.registerOutParameter(1, Types.INTEGER);
proc.execute();
totalCount=proc.getInt(1);
} catch (SQLException e) {
e.printStackTrace();
}
return totalCount;
}
//测试
public static void main(String[] args) {
NewsDaoImpl newsDao=new NewsDaoImpl();
//newsDao.add(2,1,"快女选秀快讯","快女比赛正入白热化","她、她、她，谁是你心中的快女冠军",new Date());
//newsDao.update(3, "快女选秀快讯速递");
//newsDao.delete(3);
// List<News>newsList=newsDao.getNewsList();
// for (News news : newsList) {
// //System.out.println(id+"\t"+title+"\t"+summary+"\t"+
// content+"\t"+author+"\t"+time);
// System.out.println(news.getId()+"\t"+news.getTitle()+"\t"+news.getSummary()+"\t"+news.getContent()+"\t"+news.getPicpath()+"\t"+news.getAuthor()+"\t"+news.getCreatedate());
// }
// int totalCount=newsDao.getTotalCount();
// System.out.println("新闻总数量是："+totalCount);
//第一页显示新闻信息（每页显示2条)
List<News>newsList=newsDao.getPageNewsList(1, 2);
//第2页显示新闻信息（每页显示2条)
// List<News>newsList=newsDao.getPageNewsList(2, 2);
//第3页显示新闻信息（每页显示2条)
//List<News>newsList=newsDao.getPageNewsList(3, 2);
// for (News news : newsList) {
// System.out.println(news.getTitle()+"\t"+news.getAuthor()+"\t"+news.getCreatedate());
// }
int totalCount=newsDao.getTotalCountProc();
System.out.println("新闻总数是："+totalCount);
}
}