解析含有多个对象的并使用mybatis存数据库

淡淡的烟草味﹌ 2023-01-07 10:13 20阅读 0赞

### 解析含有多个对象的并使用mybatis存数据库 ###

{
        "status": 0,
        "message": "ok",
        "payload": {
            "heartBeatLeader": [
                {
                    "host": "dbus-n1",
                    "pid": "8413\n",
                    "state": "ok"
                },
                {
                    "host": "dbus-n2",
                    "pid": "12911\n",
                    "state": "ok"
                }
            ],
            "nimbuses": [
                {
                    "port": 6627,
                    "host": "dbus-n1",
                    "nimbusLogLink": "http://dbus-n1:8000/daemonlog?file=nimbus.log",
                    "nimbusUpTime": "30d 16h 27m 19s",
                    "nimbusUpTimeSeconds": 2651239,
                    "version": "1.0.2",
                    "status": "Not a Leader"
                },
                {
                    "port": 6627,
                    "host": "dbus-n2",
                    "nimbusLogLink": "http://dbus-n2:8000/daemonlog?file=nimbus.log",
                    "nimbusUpTime": "33d 14h 57m 47s",
                    "nimbusUpTimeSeconds": 2905067,
                    "version": "1.0.2",
                    "status": "Leader"
                }
            ],
            "zkStats": [
                {
                    "port": "2181",
                    "host": "dbus-n1",
                    "state": "ok"
                },
                {
                    "port": "2181",
                    "host": "dbus-n2",
                    "state": "ok"
                },
                {
                    "port": "2181",
                    "host": "dbus-n3",
                    "state": "ok"
                }
            ],
            "kafkaBrokers": [
                {
                    "port": "9092",
                    "host": "dbus-n1",
                    "state": "ok"
                },
                {
                    "port": "9092",
                    "host": "dbus-n2",
                    "state": "ok"
                },
                {
                    "port": "9092",
                    "host": "dbus-n3",
                    "state": "ok"
                }
            ],
            "grafanaUrl": "ok",
            "supervisors": [
                {
                    "totalCpu": 400.0,
                    "logLink": "http://dbus-n1:8000/daemonlog?file=supervisor.log",
                    "totalMem": 3072.0,
                    "host": "dbus-n1",
                    "id": "c61fa406-476d-421f-8dab-e0f24971a9bd",
                    "usedMem": 8448.0,
                    "slotsTotal": 5,
                    "slotsUsed": 4,
                    "version": "1.0.2",
                    "uptimeSeconds": 2653063,
                    "uptime": "30d 16h 57m 43s",
                    "usedCpu": 0.0
                },
                {
                    "totalCpu": 400.0,
                    "logLink": "http://dbus-n3:8000/daemonlog?file=supervisor.log",
                    "totalMem": 3072.0,
                    "host": "dbus-n3",
                    "id": "65bd2aed-920e-468e-b1c4-753079944a69",
                    "usedMem": 6336.0,
                    "slotsTotal": 5,
                    "slotsUsed": 3,
                    "version": "1.0.2",
                    "uptimeSeconds": 2905028,
                    "uptime": "33d 14h 57m 8s",
                    "usedCpu": 0.0
                },
                {
                    "totalCpu": 400.0,
                    "logLink": "http://dbus-n2:8000/daemonlog?file=supervisor.log",
                    "totalMem": 3072.0,
                    "host": "dbus-n2",
                    "id": "2a311159-bcbe-4098-b906-9c1bd02bbfcc",
                    "usedMem": 6336.0,
                    "slotsTotal": 5,
                    "slotsUsed": 3,
                    "version": "1.0.2",
                    "uptimeSeconds": 2905053,
                    "uptime": "33d 14h 57m 33s",
                    "usedCpu": 0.0
                }
            ],
            "influxdbUrl": "ok"
        }
    }

整个结构类似这个样子

{
        "status":0,
        "message":"ok",
        "payload":{
            "heartBeatLeader":Array[2],
            "nimbuses":Array[2],
            "zkStats":Array[3],
            "kafkaBrokers":Array[3],
            "grafanaUrl":"ok",
            "supervisors":Array[3],
            "influxdbUrl":"ok"
        }
    }

定义对象:

Payload.java
    
    public class Payload { 
    
        public List<HeartBeatLeader> heartBeatLeader;
    
        public List<Nimbus> nimbuses;
    
        public List<ZkStat> zkStats;
    
        public List<KafkaBroker> kafkaBrokers;
    
        public String grafanaUrl;
    
        public List<Supervisor> supervisors;
    
        public String influxdbUrl;
    
        public String datetime;     datetime用于标记数据库插入时间
        
        
    HeartBeatLeader.java    
     public class HeartBeatLeader { 
        public String host;
    
        public String pid;
    
        public String state;
        }
        
        
      Nimbus.java  
        public class Nimbus { 
        public int port;
    
        public String host;
    
        public String nimbusLogLink;
    
        public String nimbusUpTime;
    
        public int nimbusUpTimeSeconds;
    
        private String version;
    
        public String status;
        }
        
        
        
        ZkStat.java
        
        public class ZkStat { 
        public String port;
    
        public String host;
    
        public String state;
    }
    
    KafkaBroker.java
    public class KafkaBroker { 
    
        public String port;
    
        public String host;
    
        public String state;
        }
        
        
        
     Supervisor.java
        
        public class Supervisor{ 
        public double totalCpu;
    
        public String logLink;
    
        public double totalMem;
    
        public String host;
    
        public String id;
    
        public double usedMem;
    
        public int slotsTotal;
    
        public int slotsUsed;
    
        public String version;
    
        public int uptimeSeconds;
    
        public String uptime;
    
        public double usedCpu;
    }

`mapper.xml`

MySql默认是不支持这种骚操作的，但是并不代表不能实现，只需要在jdbc的配置文件中稍做配置：

spring.datasource.url: jdbc:mysql://mysql:3306/realtime?useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true

其中，**allowMultiQueries=true**这个配置是关键，必须写

<insert id="checkEnvironment" parameterType="com.dclife.realtime.entity.Payload" useGeneratedKeys="false">
            insert into checkenvironment
            (hearthost,heartpid,heartstate,datetime)
            values
            <foreach collection="heartBeatLeader" item="heartBeat" separator=",">
                (
                #{heartBeat.host},
                #{heartBeat.pid},
                #{heartBeat.state},
                #{datetime}
                )
            </foreach>
    
            ;insert into checkenvironment
            (nimbuses_port,nimbuses_host,nimbus_log_link,nimbus_up_time,nimbus_up_time_seconds,version,status,datetime
            )
            values
            <foreach collection="nimbuses" item="nimbu" separator=",">
                (
                #{nimbu.port},
                #{nimbu.host},
                #{nimbu.nimbusLogLink},
                #{nimbu.nimbusUpTime},
                #{nimbu.nimbusUpTimeSeconds},
                #{nimbu.version},
                #{nimbu.status},
                #{datetime}
                )
            </foreach>
    
            ;insert into checkenvironment(kafkaport,kafkahost,kafkastate,datetime)
            values
            <foreach collection="kafkaBrokers" item="kafka" separator=",">
                (
                #{kafka.port},
                #{kafka.host},
                #{kafka.state},
                #{datetime}
                )
            </foreach>
    
            ;insert into checkenvironment(zkport,zkhost,zkstate,datetime)
            values
            <foreach collection="zkStats" item="zk" separator=",">
                (
                #{zk.port},
                #{zk.host},
                #{zk.state},
                #{datetime}
                )
            </foreach>
    
            ;insert into checkenvironment(grafana_url,influxdb_url,datetime)
            values
                (
                #{grafanaUrl},
                #{influxdbUrl},
                #{datetime}
            )
        </insert>

存入mysql的结构如下  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1ODg1NDg4_size_16_color_FFFFFF_t_70_pic_center]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1ODg1NDg4_size_16_color_FFFFFF_t_70_pic_center]: /images/20221119/106ee5e90fd141a8acd448312392d2ea.png