package com.bitc.store;

//定義Bean所屬的套件



//定義欲使用的套件

import java.sql.*;



public class VoteBean

{

	//與資料庫連結(jié)有關(guān)的Bean屬性

	private Connection con = null;

	private Statement stmt = null;

	private ResultSet BookRs = null;



	public VoteBean()  //建構(gòu)子

	{		

	}	



	//以下為設(shè)定Bean屬性的方法

	public void InitBookRs(Connection con)

	{

		try{			

			this.con = con; //設(shè)定con物件			

			

			stmt = this.con.createStatement(

					ResultSet.TYPE_SCROLL_INSENSITIVE,

					ResultSet.CONCUR_READ_ONLY);

			//建立Statement物件			



			BookRs = stmt.executeQuery

				 ("SELECT ID, BookID, BookNm FROM Book");			

			//執(zhí)行SQL敘述, 從Book資料表中取得欄位

		}

		catch(SQLException sex)

		{

			System.out.println(sex.toString());

		}		

	}



	//關(guān)閉Restult物件與Statement物件

	public void CloseBookRs ()

	{ 

		try{

			if(BookRs != null)			

			{

				BookRs.close();

				BookRs = null;

			}



			if(stmt != null)			

			{

				stmt.close();

				stmt = null;

			}

		}

		catch(SQLException sex)

		{

			System.out.println(sex.toString());

		}

	}



	//移至將ResultSet物件的指標(biāo)移至下一筆記錄

	public boolean next()

	{ 

		boolean result = false;

		try{

			result = BookRs.next();

			//移至下一筆記錄

		}

		catch(SQLException sex)

		{

			System.out.println(sex.toString());

		}		

		return result;

	}

	

	//取得ResultSet物件ID欄位的資料

	public String getID()

	{ 

		String result = null;

		try{

			result = BookRs.getString("ID");

		}

		catch(SQLException sex)

		{

			System.out.println(sex.toString());

		}		

		return result;

	}



	//取得ResultSet物件BookID欄位的資料

	public String getBookID()

	{ 

		String result = null;

		try{

			result = BookRs.getString("BookID");

		}

		catch(SQLException sex)

		{

			System.out.println(sex.toString());

		}		

		return result;

	}



	//取得ResultSet物件BookNm欄位的資料

	public String getBookNm()

	{ 

		String result = null;

		try{

			result = BookRs.getString("BookNm");

		}

		catch(SQLException sex)

		{

			System.out.println(sex.toString());

		}		

		return result;

	}



	//將投票結(jié)果新增至資料庫

	public void InsertChoice(Connection con, String choice)

	{ 

		int affect = 0;

				

		String strSQL = "INSERT INTO Vote(choice) VALUES (" +

				choice + ")";

		//建立將資料新增至資料庫的SQL敘述

		

		try{

			this.con = con; //設(shè)定con物件			

			

			stmt = this.con.createStatement(

					ResultSet.TYPE_SCROLL_INSENSITIVE,

					ResultSet.CONCUR_READ_ONLY);

			//建立Statement物件	

			stmt.executeUpdate(strSQL);

			//執(zhí)行SQL敘述

		}

		catch(SQLException sex)

		{

			System.out.println(sex.toString());

		}

	}



	//取得投票給某書記錄筆數(shù)

	public int VoteNum(Connection con, String filter)

	{

		String strSQL = "SELECT ID FROM Vote";		

		int num = 0;		



		//判斷傳入的filter字串是否為空字串, 

		//是則將篩選條件增加至SQL敘述

		if(!filter.equals(""))

			strSQL = strSQL + " WHERE " + filter;		

		

		try{

			this.con = con;

			Statement lstmt = null;	

			lstmt = this.con.createStatement(

					ResultSet.TYPE_SCROLL_INSENSITIVE,

					ResultSet.CONCUR_READ_ONLY);

			//建立Statement物件



			ResultSet rs = lstmt.executeQuery(strSQL);

			//執(zhí)行SQL敘述

			

			rs.last(); //移至最後一筆記錄

			

			num =  rs.getRow(); //取得記錄的筆數(shù)

			

			rs.close();

			lstmt.close();			

		}

		catch(SQLException sex)

		{

			System.out.println(sex.toString());

		}



		return num;

	}	

}