package com.dao;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;

import com.data.*;
import com.db.*;
import com.tools.Pageable;

public class BbsDao {
//	此函數(shù)沒有用到過
    public static boolean Delete_BbsDao(int bbs_id){
    	
    	String query="delete from bbs where bbs_id="+bbs_id;
    	
		return	DataProcess.ExeQuery(query);
    }
//  此函數(shù)沒有用到過
    public static Bbs getBbsDao(int bbs_id){
    	String sql="select * from bbs where bbs_id="+bbs_id;
        Connection con=DataProcess.getConnection(); 
        Statement pStmt=null;
    	ResultSet rs=null;
        Bbs bbs=new Bbs();
        try{
        	pStmt=con.createStatement();
        	rs=pStmt.executeQuery(sql);
        	if(rs.next()){
        		String username=rs.getString("username");
        		String userip=rs.getString("userip");
        		String bbstopic=rs.getString("bbstopic");
    			String bbscontent=rs.getString("bbscontent");
    			int bbshot=rs.getInt("bbshot");
    			String bbsdata=rs.getString("bbsdata");
    			int board_id=rs.getInt("board_id");
    			int bbshits=rs.getInt("bbshits");
    			String indentity=rs.getString("indentity");
    			String bbsredata=rs.getString("bbsredata");
    			int bbsrecount=rs.getInt("bbsrecount");
    			String bbsrename=rs.getString("bbsrename");
    			//int bbs_id=rs.getInt("bbs_id");
        	    bbs.setUsername(username);
        	    bbs.setUserip(userip);
        	    bbs.setBbstopic(bbstopic);
        	    bbs.setBbscontent(bbscontent);
        	    bbs.setBbshot(bbshot);
        	    bbs.setBbsdata(bbsdata);
        	    bbs.setBoard_id(board_id);
        	    bbs.setBbshits(bbshits);
        	    bbs.setIndentity(indentity);
        	    bbs.setBbsredata(bbsredata);
        	    bbs.setBbsrecount(bbsrecount);
        	    bbs.setBbsrename(bbsrename);
        	    bbs.setBbs_id(bbs_id);
        	}
        	
        	return bbs;
        }catch(Exception e){
        	e.printStackTrace();
        	return null;
        }finally{
        	try {
				rs.close();
			    pStmt.close();
        	    con.close();
        	} catch (SQLException e) {
				
				e.printStackTrace();
			}
        }
    }
    //根據(jù)用戶名返回結(jié)果信息
    public static Bbs getBbsDao(String username){
    	String sql="select * from bbs where username="+username;
        Connection con=DataProcess.getConnection(); //連接
        Statement pStmt=null;
    	ResultSet rs=null;
        Bbs bbs=new Bbs();
        try{
        	pStmt=con.createStatement();
        	rs=pStmt.executeQuery(sql);//查詢
        	if(rs.next()){
        		int bbs_id=rs.getInt("bbs_id");
        		String userip=rs.getString("userip");
        		String bbstopic=rs.getString("bbstopic");
    			String bbscontent=rs.getString("bbscontent");
    			int bbshot=rs.getInt("bbshot");
    			String bbsdata=rs.getString("bbsdata");
    			int board_id=rs.getInt("board_id");
    			int bbshits=rs.getInt("bbshits");
    			String indentity=rs.getString("indentity");
    			String bbsredata=rs.getString("bbsredata");
    			int bbsrecount=rs.getInt("bbsrecount");
    			String bbsrename=rs.getString("bbsrename");
    			//int bbs_id=rs.getInt("bbs_id");
        	    bbs.setUsername(username);
        	    bbs.setUserip(userip);
        	    bbs.setBbstopic(bbstopic);
        	    bbs.setBbscontent(bbscontent);
        	    bbs.setBbshot(bbshot);
        	    bbs.setBbsdata(bbsdata);
        	    bbs.setBoard_id(board_id);
        	    bbs.setBbshits(bbshits);
        	    bbs.setIndentity(indentity);
        	    bbs.setBbsredata(bbsredata);
        	    bbs.setBbsrecount(bbsrecount);
        	    bbs.setBbsrename(bbsrename);
        	    bbs.setBbs_id(bbs_id);
        	}
        	
        	return bbs;//返回
        }catch(Exception e){
        	e.printStackTrace();
        	return null;
        }finally{
        	try {
				rs.close();
			    pStmt.close();
        	    con.close();
        	} catch (SQLException e) {
				
				e.printStackTrace();
			}
        }
    }
    
    //查詢用戶的結(jié)果集
    
    public static List getBbsDao(String sql,int page,int pageSize,int cupage){
    	System.out.println("page:"+page+"pageSize:"+pageSize);
    	List al=new ArrayList();
    	Connection con=DataProcess.getConnection();
    	PreparedStatement pStmt=null;
    	ResultSet rs=null;
    	
    	try{
    		pStmt=con.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,
    				                    ResultSet.CONCUR_READ_ONLY );//設(shè)置滾動的結(jié)果集
    		rs=pStmt.executeQuery();
    		Pageable pgb=new Pageable(rs);
       		pgb.setPageSize(pageSize);
    		pgb.gotoPage(page,cupage);
    		System.out.println(pgb.getRowsCount());
       		rs.absolute(pgb.getRowsCount());
    		int totalpages=pgb.getTotalPages();//頁面大小
    		al.add(totalpages);
    		int currentpage=pgb.getCurrentPage();//當(dāng)前頁
    		al.add(currentpage);
    		int pagecounts=pgb.getCurrentPageRowsCount();//當(dāng)前頁數(shù)量
       		al.add(pagecounts);
    		int i=0;
    		
    		while(i<pagecounts)
    		{   
    			Bbs bbs=new Bbs();
    			int bbs_id=rs.getInt("bbs_id");
    			String username=rs.getString("username");
        		String userip=rs.getString("userip");
        		String bbstopic=rs.getString("bbstopic");
        	    String bbscontent=rs.getString("bbscontent");
    			int bbshot=rs.getInt("bbshot");
    			String bbsdata=rs.getString("bbsdata");
    			int board_id=rs.getInt("board_id");
    			int bbshits=rs.getInt("bbshits");
    			String indentity=rs.getString("indentity");
    			String bbsredata=rs.getString("bbsredata");
    			int bbsrecount=rs.getInt("bbsrecount");
    			String bbsrename=rs.getString("bbsrename");
    			
    			//int bbs_id=rs.getInt("bbs_id");
        	    bbs.setUsername(username);
        	    bbs.setUserip(userip);
        	    bbs.setBbstopic(bbstopic);
        	    bbs.setBbscontent(bbscontent);
        	    bbs.setBbshot(bbshot);
        	    bbs.setBbsdata(bbsdata);
        	    bbs.setBoard_id(board_id);
        	    bbs.setBbshits(bbshits);
        	    bbs.setIndentity(indentity);
        	    bbs.setBbsredata(bbsredata);
        	    bbs.setBbsrecount(bbsrecount);
        	    bbs.setBbsrename(bbsrename);
        	    bbs.setBbs_id(bbs_id);
        	    System.out.println("id:"+bbs.getUsername()+"row:"+rs.getRow());
        	    al.add(bbs);
        	    rs.next();
        	    
        	    i++;
    		}
    		return al;//返回結(jié)果
    		
    		
    	}catch(Exception e){
    		e.printStackTrace();
    		return null;
    	}
    	finally{
    		try {
				rs.close();
			    pStmt.close();
        	    con.close();
        	} catch (SQLException e) {
				e.printStackTrace();
			}
    	}
    	
    	
    } 

}