这是数据库查询:
package com_service_spserver;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class DBServer {
private Connection conn;
private PreparedStatement ps;
private ResultSet rs;
public Connection getcon() throws SQLException
{
try {
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
conn = DriverManager.getConnection("Jdbc:Odbc:test");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

return conn;
}
public String getSelInfo(SpBean bean)
{
String info=null;
String sql="select dis_info from YIYUAN_TBL where gender_m=? and shenxiao_m=? and gender_w=? and shenxiao_w=?";
try {
ps=getcon().prepareStatement(sql);
ps.setString(1,bean.getGender_m());
ps.setString(2,bean.getShenxiao_m());
ps.setString(3,bean.getGender_w());
ps.setString(3,bean.getShenxiao_w());
rs=ps.executeQuery();
while(rs.next())
{
info=rs.getString("dis_info");
}
if(info==null)
{
info="对不起,没有你请求的信息,请重新查询!";
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

return info;

}
}这是一个JAVABEAN,这段很重要,想试下序列化取值的用法package com_service_spserver;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;public class SpBean {
private String gender_w;
private String gender_m;
private String shenxiao_w;
private String shenxiao_m; public String getGender_w() {
return gender_w;
} public void setGender_w(String gender_w) {
this.gender_w = gender_w;
} public String getGender_m() {
return gender_m;
} public void setGender_m(String gender_m) {
this.gender_m = gender_m;
} public String getShenxiao_w() {
return shenxiao_w;
} public void setShenxiao_w(String shenxiao_w) {
this.shenxiao_w = shenxiao_w;
} public String getShenxiao_m() {
return shenxiao_m;
} public void setShenxiao_m(String shenxiao_m) {
this.shenxiao_m = shenxiao_m;
} public void serialize(DataOutputStream dos) {
try {
dos.writeUTF(gender_m);
dos.writeUTF(gender_w);
dos.writeUTF(shenxiao_w);
dos.writeUTF(shenxiao_m);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} public static SpBean deserialize(DataInputStream dis) {
SpBean bean = new SpBean();
try {
bean.gender_m = dis.readUTF();
bean.shenxiao_m = dis.readUTF();
bean.gender_w = dis.readUTF();
bean.shenxiao_w = dis.readUTF();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return bean;
}}客户端package com_service_spserver;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;public class Socketclient implements Runnable { private Socket socket;
private DataInputStream dis;
private DataOutputStream dos;
private int port=90001;
private StringBuffer bf=new StringBuffer();
public void Socketclient()
{
try {
socket=new Socket("127.0.0.1",port);
bf.append("男");
bf.append("鼠");
bf.append("女");
bf.append("鼠");
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void run() {
try {
dis=new DataInputStream (socket.getInputStream());
dos=new DataOutputStream(socket.getOutputStream());
String sendinfo=bf.toString();
dos.writeUTF(sendinfo);
String line=dis.readUTF();
System.out.println(line);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

public static void main(String[] args) { new Socketclient();
}
}
服务器package com_service_spserver;import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;public class Transerver implements Runnable {
private ServerSocket serversocket;
private Socket socket;
private final static int port=90001;
private DataInputStream dis=null;
private DataOutputStream dos=null;
private SpBean bean;
public void Transerver(SpBean bean)
{
bean=bean;
try {
serversocket=new ServerSocket(port);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void run() {
try {
String line=null;
socket=serversocket.accept();
//获取输入流
dis=new DataInputStream(socket.getInputStream());
// br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
// out = new PrintWriter(socket.getOutputStream(),true);
//得到输出流
dos=new DataOutputStream(socket.getOutputStream());
//封装请求的信息
while(dis.readInt()!=-1)
{
bean.setGender_m(dis.readUTF());
bean.setShenxiao_m(dis.readUTF());
bean.setGender_w(dis.readUTF());
bean.setShenxiao_w(dis.readUTF());
}
DBServer query=new DBServer();
//
line=query.getSelInfo(bean);
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if(!line.equals(""))
{
//将查询结果发送给客户端
dos.writeUTF(line);
}

} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}
public static void  main(String arg[])
{     new Transerver();
}}