servermessage_store.java

用java编写的c/s结构的网络社区

package server;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.sql.SQLException;

import javax.swing.JTextArea;



public class ServerMessage_Store 
{
	JTextArea jtaControl;
	Storedb db=new Storedb("商品","user","user");
	int num;
	void GetInfo(DataOutputStream dos,DataInputStream dis,JTextArea jtaControl,String strIP,int kind) throws IOException
	{
		byte [] data=new byte[1024];
		this.jtaControl=jtaControl;
		if(kind==1)
		{
			num=dis.read(data);
			String strName=new String(data,0,num,"GB2312");
			jtaControl.append("服务器:"+strIP+"产品名称信息接受完毕\n");
			db.QueryData(strName);
			jtaControl.append("服务器:进行数据库查询\n");
			int iNum;
			try {
				db.next();
				iNum = db.getInt("数量");
				if(iNum>0)
				{
					db.updatedata("数量", iNum-1);
					jtaControl.append("服务器:数据库数据更新\n");
					dos.write("true".getBytes());
					jtaControl.append("服务器:向"+strIP+"传递产品供应信息\n");
				}
				else
				{
					jtaControl.append("服务器:向"+strIP+"传递产品无供应信息\n");
					dos.write("false".getBytes());
				}
				
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
			
			
		}
		if(kind==2)
		{
			num=dis.read(data);
			String strName=new String(data,0,num,"GB2312");
			jtaControl.append("服务器:"+strIP+"产品名称信息接受完毕\n");
			db.QueryData(strName);
			jtaControl.append("服务器:进行数据库查询\n");
			int iNum;
			try {
				db.next();
				iNum = db.getInt("数量");
				db.updatedata("数量", iNum+1);
				dos.write("true".getBytes());
				jtaControl.append("服务器:向"+strIP+"传递产品退还成功信息\n");
					
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
		}
	}
}