从来没想到我们会扒拉nohup文件去找我们想要的数据,然后往数据库中添加。。。...

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: 从来没想到我们会扒拉nohup文件去找我们想要的数据,然后往数据库中添加。。。...


前言

现在是:2022年4月20日13:33:23

以前是怎么都没想到,我需要在服务器的nohup文件中找记录,然后往数据库里面更新。具体因为啥不提了,说多了都是愧啊~今天主要是分享一个java解析nohup文件提取关注的信息,然后添加到数据库中。

实现思路

刚开始我是直接将nohup文件中的信息手动复制出来,然后写了个insertsql语句,一条一条的往里面添加,结果发现有上千条,这么干不睡觉都加不进去多少,于是想到了找小杨和小于帮帮忙,无奈有点复杂,光给他两讲怎么加讲了半天,还不能保证他两会了,数据能加对。。。。。

后来想了个办法,将nohup文件先转换成txt文件,然后解析txt文件,根据关键字提取关键信息,拿到之后截取成固定字符串,通过jdbc的方式添加在数据库中。

  1. nohup文件的后缀改成txt
  2. 观察自己关注的数据的规律,尤其是前后有什么可以标识的,看了看,可以根据Parameters这个来解析。

  1. 因为很不规律,所以有单独查找了下(Timestamp),截取成一个字符串
  2. 本来想着按照逗号来将这个字符串中所有需要的信息截取到,依次添加到数据库中,结果发现有个字段是介绍,里面的值也有逗号,有中文的逗号,也有因为的逗号,这种方法看来行不通。
  3. 想办法查找(Stirng),全文替换成~,然后按照~查找,最后在截取,终于可行了。

实现代码

1.按照Parameters解析txt文件:

package com.ruoyi.web.controller.util;
 import com.ruoyi.system.domain.EquipmentRZ;
 import java.io.File;
 import java.io.FileNotFoundException;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.Scanner;
 /**
  * @author: muxiongxiong
  * @date: 2022年04月19日 上午 11:05
  * 公众号:雄雄的小课堂
  * 博客:https://blog.csdn.net/qq_34137397
  * 个人站:http://www.穆雄雄.com
  * 个人站:http://www.muxiongxiong.cn
  * @Description: 解析txt文件获取里面的数据
  * 最初解析的是nohup文件,现在改为解析txt文件
  * 将txt文件里面的内容,解析成对象,添加到认证器材表里去
  */
 public class ParseTXTFileUtils {
     public void parseTxt(){
         File file = new File("D:\\test3.txt");
         SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
         if (!file.exists()) {
             System.out.println("节点基本信息文件未找到");
         }
         Scanner s = null;
         try {
             s = new Scanner(file);
         } catch (FileNotFoundException e) {
             e.printStackTrace();
         }
         while (true) {
             //文档中的内容
             String danci = s.next();
             if ("Parameters:".equals(danci)) {
                 //开始留存需要的数据.
                 String jixu = "";
                 int count = 0;
                 while (true) {
                     EquipmentRZ equipmentRZ = new EquipmentRZ();
                     String danci2 = s.next();
                     jixu += danci2;
                     if (danci2.indexOf("Timestamp") != -1) {
                         String sheng = s.next();
                         String shi = s.next();
                         String qu = s.next();
                         String renzheng = s.next();
                         String tupian = s.next();
                         String jieshuriqi = s.next();
                         jixu += sheng + shi + qu + renzheng + tupian + jieshuriqi;
                         //System.out.println("jixu========"+jixu);
                         //按照逗号分割
                         String[] split = jixu.split("~,");
                         //获取到的数据
                         try {
                             equipmentRZ.setId(Integer.parseInt(split[0]));
                             equipmentRZ.setName(split[1]);
                             equipmentRZ.setXinghao(split[2]);
                             equipmentRZ.setJianjie(split[3]);
                             equipmentRZ.setZhuangtai(split[4]);
                             equipmentRZ.setGongsi1(split[5]);
                             equipmentRZ.setGongsi2(split[6]);
                             equipmentRZ.setRealName(split[7]);
                             equipmentRZ.setLeixing(split[8]);
                             equipmentRZ.setGongsi3(split[9]);
                             //2016-11-3011:35:08.0(Timestamp),天津市
                             String shijian = split[10];
                             //按照逗号分割
                             String[] split1 = shijian.split(",");
                             //截取最后的(Timestamp)
                             int index = split1[0].lastIndexOf("(");
                             String kaishishijian = split1[0].substring(0, index);
                             //第9位后面加上空格
                             StringBuffer sb = new StringBuffer(kaishishijian);
                             sb.insert(10, " ");
                             equipmentRZ.setBeginDate(simpleDateFormat.parse(sb.toString()));
                             equipmentRZ.setSheng(split1[1]);
                             equipmentRZ.setShi(split[11]);
                             equipmentRZ.setJiedao(split[12]);
                             equipmentRZ.setRenzheng(split[13]);
                             equipmentRZ.setTupian(split[14]);
                             String jieshu = split[15] + " 00:00:00";
                             equipmentRZ.setEndDate(simpleDateFormat.parse(jieshu));
                             //System.out.println(equipmentRZ);
                         } catch (ParseException e) {
                             e.printStackTrace();
                         }
                         //调佣添加的方法 将数据添加到数据库
                         //已经执行完毕 2022年4月19日11:08:54
                        /* ZhiXingMysql zhiXingMysql = new ZhiXingMysql();
                         zhiXingMysql.saveEquipmentRZ(equipmentRZ);*/
                         break;
                     }
                 }
             }
         }
     }
}

2.由于字段太多了,所以封装了个实体类,字段如下:

/**
 * @author: muxiongxiong
 * @date: 2022年04月19日 0:25
 * 公众号:雄雄的小课堂
 * 博客:https://blog.csdn.net/qq_34137397
 * 个人站:http://www.穆雄雄.com
 * 个人站:http://www.muxiongxiong.cn
 * @Description: 类的描述
 */
public class EquipmentRZ {
    private Integer id;
    private String name;
    private String xinghao;
    private String jianjie;
    private String zhuangtai;
    private String gongsi1;
    private String gongsi2;
    private String gongsi3;
    private String realName;
    private String leixing;
    private Date beginDate;
    private String sheng;
    private String shi;
    private String jiedao;
    private String tupian;
    private String renzheng;
    private Date endDate;
  }

3.jdbc添加到数据库中的方法:

public void saveEquipmentRZ(EquipmentRZ equipmentRZ) {
        int success = 0,err=0;
        String sql = "INSERT INTO sys_rzequipment ( equipment_id,equipment_name, equipment_model, equipment_introduction,equipment_status, production_name, maintenance_name, installation_company_name,maintenance_people, equipment_type,  installation_date, installation_province, installation_city, installation_address,  equipment_img_url, create_time,date_come_from ) \n" +
                "VALUES(?,?,?,?,?,?,?, ?,?,?,?,?,?,?,?,?,?)";
        Connection connection = null;
        PreparedStatement pStatement = null;
        try {
            connection = getConnection();
            pStatement = connection.prepareStatement(sql);
            pStatement.setInt(1, equipmentRZ.getId());
            pStatement.setString(2, equipmentRZ.getName());
            pStatement.setString(3, equipmentRZ.getXinghao());
            pStatement.setString(4, equipmentRZ.getJianjie());
            pStatement.setString(5, equipmentRZ.getZhuangtai());
            pStatement.setString(6, equipmentRZ.getGongsi1());
            pStatement.setString(7, equipmentRZ.getGongsi2());
            pStatement.setString(8, equipmentRZ.getGongsi3());
            pStatement.setString(9, equipmentRZ.getRealName());
            pStatement.setString(10, equipmentRZ.getLeixing());
            pStatement.setObject(11, equipmentRZ.getBeginDate());
            pStatement.setString(12, equipmentRZ.getSheng());
            pStatement.setString(13, equipmentRZ.getShi());
            pStatement.setString(14, equipmentRZ.getJiedao());
            pStatement.setString(15, equipmentRZ.getTupian());
            pStatement.setObject(16, equipmentRZ.getEndDate());
            pStatement.setString(17, equipmentRZ.getRenzheng());
            int count = pStatement.executeUpdate();
            if(count>0){
                success++;
                System.out.println("成功:"+success+"==="+equipmentRZ.getId());
            }else{
                err++;
                System.out.println("失败:"+err+"===="+equipmentRZ.getId());
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            closePreparedStatement(pStatement);
            closeConnection(connection);
        }
    }

最后运行main方法就可以了。、

注意事项

  • 为了保险起见,刚开始测试的时候测试添加的数据尽量的少点儿,也就是将txt重新复制出来一份,只留几条记录,执行一遍main方法,观察一下数据库中的数据是否正确。
  • 执行的过程中可能会遇到错误,因为Parameters可能在登录操作的时候也会出现,所以遇到不是添加的sql的话,也会报错的,只需要将原来执行过的删掉,不规则的Parameters数据在txt文件中删掉继续执行即可。
  • 数据库一定要备份!!!
目录
相关文章
|
1天前
|
SQL 资源调度 关系型数据库
实时计算 Flink版产品使用合集之源表的数据被删除后,目标数据库在重启服务后没有进行相应的删除操作,是什么原因
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStreamAPI、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
1天前
|
SQL Oracle 关系型数据库
实时计算 Flink版产品使用合集之从Oracle数据库同步数据时,checkpoint恢复后无法捕获到任务暂停期间的变更日志,如何处理
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStreamAPI、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
1天前
|
SQL Oracle 关系型数据库
实时计算 Flink版产品使用合集之如何SQL同步数据到Oracle数据库中
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStreamAPI、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
1天前
|
消息中间件 关系型数据库 Kafka
实时计算 Flink版产品使用合集之使用DTS从RDSMySQL数据库同步数据到云Kafka,增量同步数据延迟时间超过1秒。如何诊断问题并降低延迟
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStreamAPI、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
5天前
|
存储 监控 前端开发
关系型数据库数据输入验证
【5月更文挑战第12天】
38 5
|
5天前
|
存储 关系型数据库 数据库
关系型数据库的数据完整性约束
【5月更文挑战第12天】关系型数据库的数据完整性约束
17 2
|
5天前
|
数据库 数据库管理
理解数据库的ACID原则:确保数据完整性与一致性的基石
【5月更文挑战第20天】ACID原则是数据库事务处理的核心,包括原子性、一致性、隔离性和持久性。原子性保证事务操作全完成或全不完成,保持数据完整;一致性确保事务前后数据库保持一致性状态,不破坏完整性约束;隔离性防止并发事务相互影响,通过锁等技术实现;持久性则保证事务提交后的修改永久保存,即使系统故障也能恢复。这些原则确保了数据的可靠性和安全性。
|
7天前
|
关系型数据库 MySQL API
实时计算 Flink版产品使用合集之可以通过mysql-cdc动态监听MySQL数据库的数据变动吗
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
84 0
|
10天前
|
关系型数据库 MySQL 数据库
docker MySQL删除数据库时的错误(errno: 39)
docker MySQL删除数据库时的错误(errno: 39)
67 0
|
2天前
|
存储 SQL 关系型数据库
【MySQL】数据库基础 -- 详解
【MySQL】数据库基础 -- 详解