/*
 * 創(chuàng)建日期 2006-5-5
 *作者：褚廷軍
 * 項目名稱：學(xué)生考試系統(tǒng)；
 * 項目要求：畢業(yè)設(shè)計；
 * 模塊名稱：服務(wù)器端教師查詢模塊
 * 模塊功能：接收教師的查詢請求，根據(jù)接收的信息查詢數(shù)據(jù)庫中所有學(xué)生
 *           或一個學(xué)生的信息,并將查詢結(jié)果發(fā)送到客戶端
 * 窗口 > 首選項 > 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 { // 創(chuàng)建網(wǎng)絡(luò)連接

			in = new DataInputStream(socket.getInputStream());
			out = new DataOutputStream(socket.getOutputStream());

		} catch (IOException e) {

			e.printStackTrace();
		}
	}

	public void run() {



		String queryS = "";// 用戶的查詢信息
		String str2 = ""; // 查詢結(jié)果

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

			e1.printStackTrace();
		}

		try {
			// 查詢學(xué)生信息

				ConnectBean cb = new ConnectBean();
			if (!cb.openConnection()) {
				System.out.println("連接數(shù)據(jù)失敗");
				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數(shù)學(xué)成績: "
							+ 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數(shù)學(xué)成績: "
							+ 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();
		}
	}
	
	

}