server_userquery.java

在线考试系统设计

/*
 * 创建日期 2006-4-20
 * 作者：褚廷军
 * 项目名称：学生考试系统；
 * 项目要求：毕业设计；
 * 模块名称：用户查询模块
 * 模块功能：接收用户的查询请求并将数据库中
 *          用户信息返回到客户端
 *          
 * 更改所生成文件模板为
 * 窗口 > 首选项 > Java > 代码生成 > 代码和注释
 */
package tserver;

import java.io.*;
import java.net.*;
import java.sql.*;

import tools.ConnectBean;

 class Server_userQuery extends Thread {

	Socket socket;

	PreparedStatement pstmt = null;

	ResultSet rs;

	DataOutputStream out = null;

	DataInputStream in = null;

	String s = null;

	public Server_userQuery(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 str1 = "";// 接收用户提交的信息
		String str2 = ""; // 数据库中存储的用户信息

		try {
			str1 = in.readUTF();
			System.out.println(str1);
		} catch (IOException e1) {

			e1.printStackTrace();
		}
		try {
			ConnectBean cb = new ConnectBean();

			if (!cb.openConnection()) {
				System.out.println("连接数据失败");
				System.exit(1);
				return;
			}

			String sql = "select * from stuinfo where sno='" + str1 + "'";
			cb.createPreparedStatement(sql, false);

			ResultSet rs = cb.executeQuery();
			while (rs.next()) {
				str2 = "用户： " + rs.getString("sname") + "你的成绩信息为： 数学成绩："
						+ rs.getString("mscore") + ", 英语成绩： "
						+ rs.getString("escore");

			}
			cb.close();

			out.writeUTF(str2);
			System.out.println(str2);
			System.out.println("用户信息已发送");
			out.flush();

		} catch (SQLException e) {

			e.printStackTrace();
		} catch (IOException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}

	}
	
//	public static void main(String a[]){
//		Socket you6=null;
//		new Server_techQuery(you6).start();
//	}
}