/*
 * 創建日期 2006-4-21
 *
 * 作者：褚廷軍
 * 項目名稱：學生考試系統；
 * 項目要求：畢業設計；
 * 模塊名稱：讀取試題類
 * 模塊功能：接收用戶考試請求，并從數據庫中讀取
 *          相應的試題返回到用戶端
 *          
 * 更改所生成文件模板為
 * 窗口 > 首選項 > Java > 代碼生成 > 代碼和注釋
 */
package tserver;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.sql.ResultSet;
import java.sql.SQLException;

import tools.ConnectBean;

// 定義一個將試題返回到用戶的類
class Server_readTest extends Thread {
private  static int Timecount;

	Socket socket;

	ResultSet rs;

	DataOutputStream out = null;

	DataInputStream in = null;

	public Server_readTest(Socket socket) {

		this.socket = socket;
		try {
			in = new DataInputStream(socket.getInputStream());
			out = new DataOutputStream(socket.getOutputStream());
		} catch (IOException e) {

			e.printStackTrace();
		}

	}

	public void run() {

	

		String sql2; // 定義查詢語句

		String dbt = "以下為試題"; // 試題
		String ts = null; // 接收用戶發送的考試科目
		int tcount = 0; // 試題的數目

		try {
			// 網絡連接部分
			out.writeUTF("你連接成功");

			ts = in.readUTF();

			System.out.println(ts);

			// 數據庫連接部分

			// 查詢客戶端所選試題
			ConnectBean cb = new ConnectBean();
			if (!cb.openConnection()) {
				System.out.println("連接數據失敗");
				System.exit(1);
				return;
			}

			
			
			//在數據庫選題
			sql2 = "select *  from exam where eid='" + ts + "'";
			cb.createPreparedStatement(sql2, false);

			ResultSet rs = cb.executeQuery();
			while (rs.next()) {
				dbt += "^"+"\n"+rs.getString(2) + 
						"\t" + "\n" + rs.getString(3) +"  ^";
				tcount++;
			}
			cb.close();

			System.out.println(dbt);

			System.out.println(tcount);

			out.writeUTF(Integer.toString(tcount));
			
			out.writeUTF(dbt); // 將讀到的試題返回到客戶端
			
//傳送考試時間
			out.writeUTF(""+Timecount);
			out.flush();
			out.close();

			System.out.println("讀取試題成功！！");
		} catch (SQLException e) {
			e.printStackTrace();

			System.out.println("not connect db");
		} catch (IOException e1) {
			System.out.println("not read client select!");

		}

	}

	public static int getTimecount() {
		return Timecount;
	}

	public static void setTimecount(int timecount) {
		Timecount = timecount;
	}
}