[update] 添加删除实时表

wj-databus/src/main/java/net/wanji/databus/dao/mapper/GreenwaveRealtimeMapper.java

@@ -15,4 +15,6 @@ public interface GreenwaveRealtimeMapper {
     GreenwaveRealtimePO selectById(Integer id);
 
     int insertBatch(@Param("list") List<GreenwaveRealtimePO> list);
+
+    int deleteOne(@Param("greenId") Integer greenId);
 }

wj-databus/src/main/resources/mapper/GreenwaveRealtimeMapper.xml

@@ -47,4 +47,13 @@
         </foreach>
     </insert>
 
+    <delete id="deleteOne">
+        delete from t_greenwave_realtime
+        <where>
+            <if test="greenId != null and greenId != ''">
+                green_id = #{greenId}
+            </if>
+        </where>
+    </delete>
+
 </mapper>