package com.dao;

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

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


public class BbsubDao {
	//此函數沒有用到過
    public static Bbsub getBbsubDao(int bbsub_id){
    	String sql="select * from bbsub where bbsub_id="+bbsub_id;
        Connection con=DataProcess.getConnection(); 
        Statement pStmt=null;
    	ResultSet rs=null;
        Bbsub bbsub=new Bbsub();
        try{
        	pStmt=con.createStatement();
        	rs=pStmt.executeQuery(sql);
        	if(rs.next()){
        		String username=rs.getString("username");
        		String userip=rs.getString("userip");
        		String bbsubtopic=rs.getString("bbsubtopic");
    			String bbsubcontent=rs.getString("bbsubcontent");
    			int bbs_id=rs.getInt("bbs_id");
    			String bbsubdata=rs.getString("bbsubdata");
    			
        	    bbsub.setUsername(username);
        	    bbsub.setUserip(userip);
        	    bbsub.setBbsubtopic(bbsubtopic);
        	    bbsub.setBbsubcontent(bbsubcontent);
        	    bbsub.setBbs_id(bbs_id);
        	    bbsub.setBbsubdata(bbsubdata);
           	    bbsub.setBbsub_id(bbsub_id);
        	}
        	
        	return bbsub;
        }catch(Exception e){
        	e.printStackTrace();
        	return null;
        }finally{
        	try {
				rs.close();
			    pStmt.close();
        	    con.close();
        	} catch (SQLException e) {
				
				e.printStackTrace();
			}
        }
    }
//  此函數沒有用到過
    public static ArrayList getBbsubDao(String sql,int page,int pageSize){
    	ArrayList 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 );
    		rs=pStmt.executeQuery();
    		Pageable pgb=new Pageable(rs);
    		pgb.setPageSize(pageSize);
    		//pgb.gotoPage(page);
    	    
    		rs.absolute(pgb.getRowsCount());
    		int i=0;
    		Bbsub bbsub=new Bbsub();
    		do{
    			String username=rs.getString("username");
        		String userip=rs.getString("userip");
        		String bbsubtopic=rs.getString("bbsubtopic");
    			String bbsubcontent=rs.getString("bbsubcontent");
    			int bbs_id=rs.getInt("bbs_id");
    			String bbsubdata=rs.getString("bbsubdata");
    			int bbsub_id=rs.getInt("bbsub_id");
        	    bbsub.setUsername(username);
        	    bbsub.setUserip(userip);
        	    bbsub.setBbsubtopic(bbsubtopic);
        	    bbsub.setBbsubcontent(bbsubcontent);
        	    bbsub.setBbs_id(bbs_id);
        	    bbsub.setBbsubdata(bbsubdata);
           	    bbsub.setBbsub_id(bbsub_id);
           	    al.add(bbsub);
    		}while(rs.next() && i<pgb.getCurrentPageRowsCount());
    		return al;
    		
    		
    	}catch(Exception e){
    		e.printStackTrace();
    		return null;
    	}
    	finally{
    		try {
				rs.close();
			    pStmt.close();
        	    con.close();
        	} catch (SQLException e) {
				e.printStackTrace();
			}
    	}
    	
    	
    } 


}