public class Server{

    private static int port = 8888;

    private static ServerSocket serverSocket;

    private static Socket socket;

    public static void main(String args[]) throws IOException {  

        serverSocket = new ServerSocket(port, 2);

        socket = serverSocket.accept();

        System.out.println("客户端已链接");  

        try {

            ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());

               JDBCService jdbcService = new JDBCService();

            while(true){

                Employee employee = (Employee) ois.readObject();

                String s= employee.getName();

                if(s.equals("bye")){

                    ois.close();

                    socket.close();

                    System.out.println("关闭服务器的 socket");

                    break;

                }

                jdbcService.add(employee.getName(),employee.getEmail(),employee.getName());

            }

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

}

public class Client {

    private static int port = 8888;

    private static String host = "localhost";

    private static Socket socket;  

    public static void main(String args[]) throws UnknownHostException,

            IOException {

        socket = new Socket(host, port);

        ObjectOutputStream oos= new ObjectOutputStream(socket.getOutputStream());

        Employee employee =new Employee();

        while(true){

            employee.setName("王小东");

            employee.setEmail("qq@.com");

            employee.setPwd("12334");

            // 发送键盘输入的一行

            String s = new BufferedReader(new InputStreamReader(System.in)).readLine(); 

            if(s.equals("bye")){

                employee.setName("bye");

                oos.writeObject(employee);

                oos.flush();

                oos.close();

                socket.close();

                System.out.println("关闭客户端的 socket");

                break;

            }else if(s.equals("send")){

                oos.writeObject(employee);//写入数据

                oos.flush();//发送数据

            }else{

                System.out.println("无效指令，请重新输入");

            }

        }

    }

}

public class JDBCService {

    //插入操作

    public int add(String uname,String uemail,String upwd) {

        int i=0;

        String sql="insert into employee (name,email,pwd) values (?,?,?)";

        DBConnection db = new DBConnection();

        try {

            PreparedStatement preStmt = (PreparedStatement) db.conn.prepareStatement(sql);

            preStmt.setString(1, uname);

            preStmt.setString(2, uemail);

            preStmt.setString(3, upwd);

            preStmt.executeUpdate();

            //Statement statement = (Statement) db.conn.createStatement();

            //statement.executeUpdate(sql);

            preStmt.close();

            db.close();//关闭连接

        } catch (Exception e) {

            e.printStackTrace();

        }

        return i;//返回影响的行数，1为执行成功

    }

    //查找操作

    public void show(){

         String sql ="select * from employee";

         DBConnection db = new DBConnection();

         System.out.println("-----------------");

         System.out.println("姓名" +"\t"+ "邮箱" +"\t"+ "日期");

         System.out.println("-----------------");

         try {

            Statement stmt = (Statement) db.conn.createStatement();

            ResultSet rs = (ResultSet) stmt.executeQuery(sql);

            while(rs.next()){

                String uname = rs.getString("name");

                String uemail = rs.getString("email");

                String uhiredate = rs.getString("hiredate");

                //可以将查找到的值写入类，然后返回相应的对象

                //这里 先用输出的端口显示一下

                System.out.println(uname +"\t"+ uemail +"\t"+ uhiredate);

            }

            rs.close();

            db.close();//关闭连接

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    //更新操作

    public int update(String uname,String uemail,String upwd) {

        int i =0;

        String sql="update employee set email=?,pwd=? where name=?";

        DBConnection db = new DBConnection();

        try {

            PreparedStatement preStmt = (PreparedStatement) db.conn.prepareStatement(sql);

            preStmt.setString(1, uemail);

            preStmt.setString(2, upwd);

            preStmt.setString(3, uname);

            preStmt.executeUpdate();

            preStmt.close();

            db.close();//关闭连接

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return i;//返回影响的行数，1为执行成功

    }

    //删除操作

    public int del(String uname) {

        int i=0;

        String sql="delete from employee where name=?";

        DBConnection db = new DBConnection();

        try {

            PreparedStatement preStmt = (PreparedStatement) db.conn.prepareStatement(sql);

            preStmt.setString(1, uname);

            preStmt.executeUpdate();

            preStmt.close();

            db.close();//关闭连接

        } catch (SQLException e){

            e.printStackTrace();

        }

        return i;//返回影响的行数，1为执行成功

    }

}

public class Employee implements Serializable{

    /**

     *

     */

    private static final long serialVersionUID = 1L;

    private Integer id;

    private String name;

    private String pwd;

    private Integer grade;

    private String email;

    private java.util.Date hiredate;

    private Float salary;

    public Employee() {

    }

    public Employee(String name, String pwd, Integer grade, String email, Date hiredate, Float salary) {

        this.name = name;

        this.pwd = pwd;

        this.grade = grade;

        this.email = email;

        this.hiredate = hiredate;

        this.salary = salary;

    }

    public Integer getId() {

        return id;

    }

    public void setId(Integer id) {

        this.id = id;

    }

    public String getName() {

        return name;

    }

    public void setName(String name) {

        this.name = name;

    }

    public String getPwd() {

        return pwd;

    }

    public void setPwd(String pwd) {

        this.pwd = pwd;

    }

    public Integer getGrade() {

        return grade;

    }

    public void setGrade(Integer grade) {

        this.grade = grade;

    }

    public String getEmail() {

        return email;

    }

    public void setEmail(String email) {

        this.email = email;

    }

    public java.util.Date getHiredate() {

        return hiredate;

    }

    public void setHiredate(java.util.Date hiredate) {

        this.hiredate = hiredate;

    }

    public Float getSalary() {

        return salary;

    }

    public void setSalary(Float salary) {

        this.salary = salary;

    }

}