server_techquery.java

在线考试系统设计

/*
 * 创建日期 2006-5-5
 *作者：褚廷军
 * 项目名称：学生考试系统；
 * 项目要求：毕业设计；
 * 模块名称：服务器端教师查询模块
 * 模块功能：接收教师的查询请求，根据接收的信息查询数据库中所有学生
 *           或一个学生的信息,并将查询结果发送到客户端
 * 窗口 > 首选项 > Java > 代码生成 > 代码和注释
 */
package tserver;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import tools.ConnectBean;

public class Server_techQuery extends Thread {
	Socket socket;

	PreparedStatement stmt = null;

	ResultSet rs;

	DataOutputStream out = null;

	DataInputStream in = null;

	String s = null;

	private Connection conn;

	private String driver;

	private String url;

	private String user;

	private String password;

	public Server_techQuery(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 queryS = "";// 用户的查询信息
		String str2 = ""; // 查询结果

		try {
			queryS = in.readUTF();// 接收查询信息
			System.out.println(queryS);
		} catch (IOException e1) {

			e1.printStackTrace();
		}

		try {
			// 查询学生信息

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

			if (queryS.equals("all")) {
				String sql3 = "select * from stuinfo ";
				cb.createPreparedStatement(sql3);
			//	stmt = conn.createStatement();
				rs = cb.executeQuery();

				ResultSetMetaData rmd = rs.getMetaData();
				int columncount = rmd.getColumnCount();
				System.out.println("column " + columncount);

				while (rs.next()) {
					str2+="用户： " + rs.getString(1)+ "成绩信息为：\t 姓名："
							+ rs.getString(2) + ", \t班级:"
							+ rs.getString(4) + ",  \t数学成绩: "
							+ rs.getString(5) + ",  \t英语成绩:"
							+ rs.getString(6) + ",  \t \n" ;
					}
				
				System.out.println(str2);
				out.writeUTF(str2);
				

				out.flush();
				out.close();
			} else {
				String sql3 = "select * from stuinfo where sno= '" + queryS
						+ "'";

			 	cb.createPreparedStatement(sql3);
		    	rs=cb.executeQuery();

				while (rs.next()) {
					str2+="用户： " + rs.getString(1)+ "成绩信息为：\t 姓名："
							+ rs.getString(2) + ", \t班级:"
							+ rs.getString(4) + ",  \t数学成绩: "
							+ rs.getString(5) + ", \t英语成绩:"
							+ rs.getString(6) + ", \t "+"\n" ;
				
					}
			
				out.writeUTF(str2);
				out.close();
			}

		} catch (SQLException e) {

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

}