server_readtest.java

在线考试系统设计

/*
 * 创建日期 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;
	}
}