【技能实训】DMS数据挖掘项目-Day14-阿里云开发者社区

【技能实训】DMS数据挖掘项目-Day14

2023-10-12 47

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

数据管理 DMS，安全协同 3个实例 3个月

简介： 【技能实训】DMS数据挖掘项目-Day14

任务16

【任务16.1】数据的请求和响应

数据的请求和响应方法

程序设计

package com.qst.dms.service;
import com.qst.dms.net.Request;
import com.qst.dms.net.Response;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
public class DmsNetService {
    private  static  DmsNetService instance = new DmsNetService();
    private  DmsNetService(){
    }
    public static DmsNetService getInstance(){
        return  instance;
    }
    public static void  sendRequest(Socket socket, Request request) throws IOException{
        ObjectOutputStream out = new ObjectOutputStream(socket.getOutputStream());
        out.writeObject(request);
        out.flush();
    }
    public static Request receiveRequest(Socket socket) throws ClassNotFoundException, IOException{
        ObjectInputStream in = new ObjectInputStream(socket.getInputStream());
        Request req = (Request)in.readObject();
        return req;
    }
    public static void sendResponse(Socket socket, Response response) throws IOException{
        ObjectOutputStream out = new ObjectOutputStream(socket.getOutputStream());
        out.writeObject(response);
        out.flush();
    }
    public static Response receiveResponse(Socket socket) throws IOException,ClassNotFoundException{
        ObjectInputStream in = new ObjectInputStream(socket.getInputStream());
        Response res = (Response)in.readObject();
        return res;
    }
}

请求封装类

程序设计

package com.qst.dms.net;
import com.qst.dms.entity.MatchedDataBase;
import java.io.Serializable;
import java.util.List;
public class Request implements Serializable {
    private static final long serialVersionUID = 1L;
    public static final int DATA_TYPE_LOGREC = 1;
    public static final int DATA_TYPE_TRANSPORT = 2;
    private String time;
    private String ip;
    private int type;
    private List<MatchedDataBase> data;
    public Request(){
        super();
    }
    public Request(String  time, String ip, int type, List<MatchedDataBase> data){
        super();
        this.time=time;
        this.ip=ip;
        this.type=type;
        this.data=data;
    }
    /**
     * 获取
     * @return time
     */
    public String getTime() {
        return time;
    }
    /**
     * 设置
     * @param time
     */
    public void setTime(String time) {
        this.time = time;
    }
    /**
     * 获取
     * @return ip
     */
    public String getIp() {
        return ip;
    }
    /**
     * 设置
     * @param ip
     */
    public void setIp(String ip) {
        this.ip = ip;
    }
    /**
     * 获取
     * @return type
     */
    public int getType() {
        return type;
    }
    /**
     * 设置
     * @param type
     */
    public void setType(int type) {
        this.type = type;
    }
    /**
     * 获取
     * @return data
     */
    public List<MatchedDataBase> getData() {
        return data;
    }
    /**
     * 设置
     * @param data
     */
    public void setData(List<MatchedDataBase> data) {
        this.data = data;
    }
    public String toString() {
        return "Request{time = " + time + ", ip = " + ip + ", type = " + type + ", data = " + data + "}";
    }
}

响应封装类

程序设计

package com.qst.dms.net;
import java.io.Serializable;
public class Response implements Serializable {
    private static final long serialVersionUID = 1L;
    public static final int OK =200;
    public static final int ERROR = 500;
    private String time;
    private int state;
    public Response(){
        super();
    }
    public Response(String time, int state) {
        super();
        this.time = time;
        this.state = state;
    }
    /**
     * 获取
     * @return time
     */
    public String getTime() {
        return time;
    }
    /**
     * 设置
     * @param time
     */
    public void setTime(String time) {
        this.time = time;
    }
    /**
     * 获取
     * @return state
     */
    public int getState() {
        return state;
    }
    /**
     * 设置
     * @param state
     */
    public void setState(int state) {
        this.state = state;
    }
    public String toString() {
        return "Response{time = " + time + ", state = " + state + "}";
    }
}

【任务16.2】创建JTable的数据适配器类MatchedTableModel，直接从数据库获取数据。

在com.qst.dms.entity类下创MatchedTableModel，继承AbstractTableModel

// 使用ResultSet来创建TableModel
  private ResultSet rs;
  private ResultSetMetaData rsmd;
  // 标志位，区分日志和物流：1，日志；0，物流
  private int sign;
  public MatchedTableModel(ResultSet rs, int sign) {
    this.rs = rs;
    this.sign = sign;
    try {
      rsmd = rs.getMetaData();
    } catch (Exception e) {
      rsmd = null;
    }
  }
  // 获取表格的行数
  public int getRowCount() {
    try {
      rs.last();
      // System.out.println(count);
      return rs.getRow();
    } catch (Exception e) {
      return 0;
    }
  }
  // 获取表格的列数
  public int getColumnCount() {
    try {
      // System.out.println(rsmd.getColumnCount());
      return rsmd.getColumnCount();
    } catch (Exception e) {
      return 0;
    }
  }
  // 获取指定位置的值
  public Object getValueAt(int rowIndex, int columnIndex) {
    try {
      rs.absolute(rowIndex + 1);
      return rs.getObject(columnIndex + 1);
    } catch (Exception e) {
      return null;
    }
  }
  // 获取表头信息
  public String getColumnName(int column) {
    String[] logArray = { "日志ID", "采集时间", "采集地点", "状态", "用户名", "IP", "日志类型" };
    String[] tranArray = { "物流ID", "采集时间", "目的地", "状态", "经手人", "收货人",
        "物流类型" };
    return sign == 1 ? logArray[column] : tranArray[column];
  }
// 菜单项，注册监听
miShow.addActionListener(new ShowDataListener());
// 工具栏项 注册监听
btnShow.addActionListener(new ShowDataListener());

LogRecService类中增加方法readLogResult()

//获取数据库中的所有匹配的日志信息，返回一个ResultSet
  public ResultSet readLogResult() {  
          //获取匹配日志表中的所有数据，返回ResultSet 
         //创建语句时使用：
      //Statement st = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
  }

TransportService 类中增加方法readTransResult()

//获取数据库中的所有匹配的物流信息，返回一个ResultSet
  public ResultSet readTransResult() {  
          //获取匹配物流表中的所有数据，返回ResultSet 
//Statement st = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
  }

程序设计

package com.qst.dms.entity;
import javax.swing.table.AbstractTableModel;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
public class MatchedTableModel extends AbstractTableModel {
    // 使用ResultSet来创建TableModel
    private ResultSet rs;
    private ResultSetMetaData rsmd;
    // 标志位，区分日志和物流：1，日志；0，物流
    private int sign;
    public MatchedTableModel(ResultSet rs, int sign) {
        this.rs = rs;
        this.sign = sign;
        try {
            rsmd = rs.getMetaData();
        } catch (Exception e) {
            rsmd = null;
        }
    }
    // 获取表格的行数
    public int getRowCount() {
        try {
            rs.last();
            // System.out.println(count);
            return rs.getRow();
        } catch (Exception e) {
            return 0;
        }
    }
    // 获取表格的列数
    public int getColumnCount() {
        try {
            // System.out.println(rsmd.getColumnCount());
            return rsmd.getColumnCount();
        } catch (Exception e) {
            return 0;
        }
    }
    // 获取指定位置的值
    public Object getValueAt(int rowIndex, int columnIndex) {
        try {
            rs.absolute(rowIndex + 1);
            return rs.getObject(columnIndex + 1);
        } catch (Exception e) {
            return null;
        }
    }
    // 获取表头信息
    public String getColumnName(int column) {
        String[] logArray = { "日志ID", "采集时间", "采集地点", "状态", "用户名", "IP", "日志类型" };
        String[] tranArray = { "物流ID", "采集时间", "目的地", "状态", "经手人", "收货人",
                "物流类型" };
        return sign == 1 ? logArray[column] : tranArray[column];
    }
}
public static ResultSet readLogResult() {
    ResultSet matchedLogsResult = null;
    //获取匹配日志表中的所有数据，返回ResultSet
    //创建语句时使用：
    DBUtil db = new DBUtil();
    Connection conn = null;
    try {
        conn = db.getConnection();
        Statement st = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
        // 查询匹配的日志
        String querySqlMatchedLogs = "SELECT * FROM matchlogs";
        matchedLogsResult = db.executeQuery(querySqlMatchedLogs,null);
    } catch (Exception e) {
        e.printStackTrace();
    }
    return matchedLogsResult;
}
public ResultSet readTransResult() {
    //获取匹配物流表中的所有数据，返回ResultSet
    ResultSet matchedTransResult = null;
    //获取匹配日志表中的所有数据，返回ResultSet
    //创建语句时使用：
    DBUtil db = new DBUtil();
    Connection conn = null;
    ArrayList<MatchedTransport> matchedTrans = new ArrayList<>();
    try {
        conn = db.getConnection();
        Statement st = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
        // 查询匹配的日志
        String querySqlMatchedLogs = "SELECT * FROM matchtransports";
        matchedTransResult = st.executeQuery(querySqlMatchedLogs);
    } catch (Exception e) {
        e.printStackTrace();
    }
    return matchedTransResult;
}

服务端

客户端

【技能实训】DMS数据挖掘项目-Day14

任务16

【任务16.1】数据的请求和响应

【任务16.2】创建JTable的数据适配器类MatchedTableModel，直接从数据库获取数据。

热门文章

最新文章

相关课程

相关电子书

相关实验场景