message_bus / message_bus_service · 提交

转到一个项目

作者 王勇
提交 e5bb99e343fa4e6825288fa6ec866429fd930599 1 个父辈 b37228f1

账户信息绑定配置表,添加字段（虚拟主机ID，交换机ID，队列ID，路由键ID）

内嵌 并排对比
正在显示 5 个修改的文件 包含 254 行增加 和 164 行删除
... ... @@ -3,50 +3,74 @@ package com.sunyo.wlpt.message.bus.service.domain;
import java.io.Serializable;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @author 子诚
* Description：账户消息绑定配置表
* 时间：2020/6/29 17:37
* Description：账户信息绑定配置表
* 时间：2020/7/13 14:24
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class UserMessageBinding implements Serializable {
private static final long serialVersionUID = 1L;
private static final long serialVersionUID = -7983498309821536414L;
/**
* 账户消息绑定配置表的ID
* 账户信息绑定配置表的ID
*/
private String id;
/**
* 用户的ID
*/
private String userId;
/**
* 所属用户登陆名称
*/
private String username;
/**
* 所属虚拟主机的ID
*/
private String virtualHostId;
/**
* 所属虚拟主机名称
*/
private String virtualHostName;
/**
* 所属交换机的ID
*/
private String exchangeId;
/**
* 所属交换机名称
*/
private String exchangeName;
/**
* 所属队列的ID
*/
private String queueId;
/**
* 所属队列名称
*/
private String queueName;
/**
* 所属routing_key的名称
* 所属路由键的ID
*/
private String routingKeyId;
/**
* 所属路由键的名称
*/
private String routingKeyName;
... ... @@ -58,13 +82,10 @@ public class UserMessageBinding implements Serializable {
/**
* 创建时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private Date gmtCreate;
/**
* 修改时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private Date gmtModified;
}
}
\ No newline at end of file
... ...
package com.sunyo.wlpt.message.bus.service.mapper;
import com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
import org.apache.ibatis.annotations.Mapper;import org.apache.ibatis.annotations.Param;import java.util.List;
/**
* @author 子诚
* Description：
* 时间：2020/6/29 17:37
* 时间：2020/7/13 14:24
*/
@Mapper
public interface UserMessageBindingMapper {
/**
* 根据主键删除
* delete by primary key
*
* @param id primaryKey
* @return deleteCount
... ... @@ -21,7 +19,7 @@ public interface UserMessageBindingMapper {
int deleteByPrimaryKey(String id);
/**
* 新增
* insert record to table
*
* @param record the record
* @return insert count
... ... @@ -29,7 +27,7 @@ public interface UserMessageBindingMapper {
int insert(UserMessageBinding record);
/**
* 选择性增加
* insert record to table selective
*
* @param record the record
* @return insert count
... ... @@ -37,7 +35,7 @@ public interface UserMessageBindingMapper {
int insertSelective(UserMessageBinding record);
/**
* 根据主键查询
* select by primary key
*
* @param id primary key
* @return object by primary key
... ... @@ -45,7 +43,7 @@ public interface UserMessageBindingMapper {
UserMessageBinding selectByPrimaryKey(String id);
/**
* 选择性更新，根据主键
* update record selective
*
* @param record the updated record
* @return update count
... ... @@ -53,13 +51,14 @@ public interface UserMessageBindingMapper {
int updateByPrimaryKeySelective(UserMessageBinding record);
/**
* 根据主键更新
* update record
*
* @param record the updated record
* @return update count
*/
int updateByPrimaryKey(UserMessageBinding record);
/**
* 分页查询，获取账户信息绑定配置列表
*
... ... @@ -67,4 +66,4 @@ public interface UserMessageBindingMapper {
* @return List<UserMessageBinding>
*/
List<UserMessageBinding> selectUserMessageBindingList(UserMessageBinding userMessageBinding);
}
}
\ No newline at end of file
... ...
package com.sunyo.wlpt.message.bus.service.service;
import com.github.pagehelper.PageInfo;
import com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding;
import com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding;import java.util.List;
/**
* @author 子诚
... ... @@ -66,4 +66,7 @@ public interface UserMessageBindingService {
* @return PageInfo
*/
PageInfo selectUserMessageBindingList(UserMessageBinding userMessageBinding, Integer pageNum, Integer pageSize);
}
... ...
... ... @@ -2,7 +2,6 @@ package com.sunyo.wlpt.message.bus.service.service.impl;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.sunyo.wlpt.message.bus.service.domain.BusQueue;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
... ... @@ -90,3 +89,5 @@ public class UserMessageBindingServiceImpl implements UserMessageBindingService
}
}
... ...
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.sunyo.wlpt.message.bus.service.mapper.UserMessageBindingMapper">
<resultMap id="BaseResultMap" type="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
<!--@Table user_message_binding-->
<id column="id" jdbcType="VARCHAR" property="id"/>
<result column="username" jdbcType="VARCHAR" property="username"/>
<result column="virtual_host_name" jdbcType="VARCHAR" property="virtualHostName"/>
<result column="exchange_name" jdbcType="VARCHAR" property="exchangeName"/>
<result column="queue_name" jdbcType="VARCHAR" property="queueName"/>
<result column="routing_key_name" jdbcType="VARCHAR" property="routingKeyName"/>
<result column="subscriber" jdbcType="VARCHAR" property="subscriber"/>
<result column="gmt_create" jdbcType="TIMESTAMP" property="gmtCreate"/>
<result column="gmt_modified" jdbcType="TIMESTAMP" property="gmtModified"/>
</resultMap>
<sql id="Base_Column_List">
<!--@mbg.generated-->
id, username, virtual_host_name, exchange_name, queue_name, routing_key_name, subscriber, gmt_create,
gmt_modified
</sql>
<select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
<!--@mbg.generated-->
select
<include refid="Base_Column_List"/>
from user_message_binding
where id = #{id,jdbcType=VARCHAR}
</select>
<resultMap id="BaseResultMap" type="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
<!--@Table user_message_binding-->
<id column="id" jdbcType="VARCHAR" property="id" />
<result column="user_id" jdbcType="VARCHAR" property="userId" />
<result column="username" jdbcType="VARCHAR" property="username" />
<result column="virtual_host_id" jdbcType="VARCHAR" property="virtualHostId" />
<result column="virtual_host_name" jdbcType="VARCHAR" property="virtualHostName" />
<result column="exchange_id" jdbcType="VARCHAR" property="exchangeId" />
<result column="exchange_name" jdbcType="VARCHAR" property="exchangeName" />
<result column="queue_id" jdbcType="VARCHAR" property="queueId" />
<result column="queue_name" jdbcType="VARCHAR" property="queueName" />
<result column="routing_key_id" jdbcType="VARCHAR" property="routingKeyId" />
<result column="routing_key_name" jdbcType="VARCHAR" property="routingKeyName" />
<result column="subscriber" jdbcType="VARCHAR" property="subscriber" />
<result column="gmt_create" jdbcType="TIMESTAMP" property="gmtCreate" />
<result column="gmt_modified" jdbcType="TIMESTAMP" property="gmtModified" />
</resultMap>
<sql id="Base_Column_List">
<!--@mbg.generated-->
id, user_id, username, virtual_host_id, virtual_host_name, exchange_id, exchange_name,
queue_id, queue_name, routing_key_id, routing_key_name, subscriber, gmt_create, gmt_modified
</sql>
<select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
<!--@mbg.generated-->
select
<include refid="Base_Column_List" />
from user_message_binding
where id = #{id,jdbcType=VARCHAR}
</select>
<delete id="deleteByPrimaryKey" parameterType="java.lang.String">
<!--@mbg.generated-->
delete from user_message_binding
where id = #{id,jdbcType=VARCHAR}
</delete>
<insert id="insert" parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
insert into user_message_binding (id, user_id, username,
virtual_host_id, virtual_host_name, exchange_id,
exchange_name, queue_id, queue_name,
routing_key_id, routing_key_name, subscriber,
gmt_create, gmt_modified)
values (#{id,jdbcType=VARCHAR}, #{userId,jdbcType=VARCHAR}, #{username,jdbcType=VARCHAR},
#{virtualHostId,jdbcType=VARCHAR}, #{virtualHostName,jdbcType=VARCHAR}, #{exchangeId,jdbcType=VARCHAR},
#{exchangeName,jdbcType=VARCHAR}, #{queueId,jdbcType=VARCHAR}, #{queueName,jdbcType=VARCHAR},
#{routingKeyId,jdbcType=VARCHAR}, #{routingKeyName,jdbcType=VARCHAR}, #{subscriber,jdbcType=VARCHAR},
#{gmtCreate,jdbcType=TIMESTAMP}, #{gmtModified,jdbcType=TIMESTAMP})
</insert>
<insert id="insertSelective" parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
insert into user_message_binding
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
id,
</if>
<if test="userId != null">
user_id,
</if>
<if test="username != null">
username,
</if>
<if test="virtualHostId != null">
virtual_host_id,
</if>
<if test="virtualHostName != null">
virtual_host_name,
</if>
<if test="exchangeId != null">
exchange_id,
</if>
<if test="exchangeName != null">
exchange_name,
</if>
<if test="queueId != null">
queue_id,
</if>
<if test="queueName != null">
queue_name,
</if>
<if test="routingKeyId != null">
routing_key_id,
</if>
<if test="routingKeyName != null">
routing_key_name,
</if>
<if test="subscriber != null">
subscriber,
</if>
<if test="gmtCreate != null">
gmt_create,
</if>
<if test="gmtModified != null">
gmt_modified,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="id != null">
#{id,jdbcType=VARCHAR},
</if>
<if test="userId != null">
#{userId,jdbcType=VARCHAR},
</if>
<if test="username != null">
#{username,jdbcType=VARCHAR},
</if>
<if test="virtualHostId != null">
#{virtualHostId,jdbcType=VARCHAR},
</if>
<if test="virtualHostName != null">
#{virtualHostName,jdbcType=VARCHAR},
</if>
<if test="exchangeId != null">
#{exchangeId,jdbcType=VARCHAR},
</if>
<if test="exchangeName != null">
#{exchangeName,jdbcType=VARCHAR},
</if>
<if test="queueId != null">
#{queueId,jdbcType=VARCHAR},
</if>
<if test="queueName != null">
#{queueName,jdbcType=VARCHAR},
</if>
<if test="routingKeyId != null">
#{routingKeyId,jdbcType=VARCHAR},
</if>
<if test="routingKeyName != null">
#{routingKeyName,jdbcType=VARCHAR},
</if>
<if test="subscriber != null">
#{subscriber,jdbcType=VARCHAR},
</if>
<if test="gmtCreate != null">
#{gmtCreate,jdbcType=TIMESTAMP},
</if>
<if test="gmtModified != null">
#{gmtModified,jdbcType=TIMESTAMP},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
update user_message_binding
<set>
<if test="userId != null">
user_id = #{userId,jdbcType=VARCHAR},
</if>
<if test="username != null">
username = #{username,jdbcType=VARCHAR},
</if>
<if test="virtualHostId != null">
virtual_host_id = #{virtualHostId,jdbcType=VARCHAR},
</if>
<if test="virtualHostName != null">
virtual_host_name = #{virtualHostName,jdbcType=VARCHAR},
</if>
<if test="exchangeId != null">
exchange_id = #{exchangeId,jdbcType=VARCHAR},
</if>
<if test="exchangeName != null">
exchange_name = #{exchangeName,jdbcType=VARCHAR},
</if>
<if test="queueId != null">
queue_id = #{queueId,jdbcType=VARCHAR},
</if>
<if test="queueName != null">
queue_name = #{queueName,jdbcType=VARCHAR},
</if>
<if test="routingKeyId != null">
routing_key_id = #{routingKeyId,jdbcType=VARCHAR},
</if>
<if test="routingKeyName != null">
routing_key_name = #{routingKeyName,jdbcType=VARCHAR},
</if>
<if test="subscriber != null">
subscriber = #{subscriber,jdbcType=VARCHAR},
</if>
<if test="gmtCreate != null">
gmt_create = #{gmtCreate,jdbcType=TIMESTAMP},
</if>
<if test="gmtModified != null">
gmt_modified = #{gmtModified,jdbcType=TIMESTAMP},
</if>
</set>
where id = #{id,jdbcType=VARCHAR}
</update>
<update id="updateByPrimaryKey" parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
update user_message_binding
set user_id = #{userId,jdbcType=VARCHAR},
username = #{username,jdbcType=VARCHAR},
virtual_host_id = #{virtualHostId,jdbcType=VARCHAR},
virtual_host_name = #{virtualHostName,jdbcType=VARCHAR},
exchange_id = #{exchangeId,jdbcType=VARCHAR},
exchange_name = #{exchangeName,jdbcType=VARCHAR},
queue_id = #{queueId,jdbcType=VARCHAR},
queue_name = #{queueName,jdbcType=VARCHAR},
routing_key_id = #{routingKeyId,jdbcType=VARCHAR},
routing_key_name = #{routingKeyName,jdbcType=VARCHAR},
subscriber = #{subscriber,jdbcType=VARCHAR},
gmt_create = #{gmtCreate,jdbcType=TIMESTAMP},
gmt_modified = #{gmtModified,jdbcType=TIMESTAMP}
where id = #{id,jdbcType=VARCHAR}
</update>
<!-- 查询列表，选择性 -->
<select id="selectUserMessageBindingList"
parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding" resultMap="BaseResultMap">
<select id="selectUserMessageBindingList" parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding" resultMap="BaseResultMap">
select
<include refid="Base_Column_List"/>
<include refid="Base_Column_List" />
from user_message_binding
<where>
<!-- 所属用户登陆名称 -->
... ... @@ -60,116 +238,4 @@
</where>
</select>
<delete id="deleteByPrimaryKey" parameterType="java.lang.String">
<!--@mbg.generated-->
delete from user_message_binding
where id = #{id,jdbcType=VARCHAR}
</delete>
<insert id="insert" parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
insert into user_message_binding (id, username, virtual_host_name,
exchange_name, routing_key_name, subscriber,
gmt_create, gmt_modified)
values (#{id,jdbcType=VARCHAR}, #{username,jdbcType=VARCHAR}, #{virtualHostName,jdbcType=VARCHAR},
#{exchangeName,jdbcType=VARCHAR}, #{routingKeyName,jdbcType=VARCHAR}, #{subscriber,jdbcType=VARCHAR},
#{gmtCreate,jdbcType=TIMESTAMP}, #{gmtModified,jdbcType=TIMESTAMP})
</insert>
<insert id="insertSelective" parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
insert into user_message_binding
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
id,
</if>
<if test="username != null">
username,
</if>
<if test="virtualHostName != null">
virtual_host_name,
</if>
<if test="exchangeName != null">
exchange_name,
</if>
<if test="routingKeyName != null">
routing_key_name,
</if>
<if test="subscriber != null">
subscriber,
</if>
<if test="gmtCreate != null">
gmt_create,
</if>
<if test="gmtModified != null">
gmt_modified,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="id != null">
#{id,jdbcType=VARCHAR},
</if>
<if test="username != null">
#{username,jdbcType=VARCHAR},
</if>
<if test="virtualHostName != null">
#{virtualHostName,jdbcType=VARCHAR},
</if>
<if test="exchangeName != null">
#{exchangeName,jdbcType=VARCHAR},
</if>
<if test="routingKeyName != null">
#{routingKeyName,jdbcType=VARCHAR},
</if>
<if test="subscriber != null">
#{subscriber,jdbcType=VARCHAR},
</if>
<if test="gmtCreate != null">
#{gmtCreate,jdbcType=TIMESTAMP},
</if>
<if test="gmtModified != null">
#{gmtModified,jdbcType=TIMESTAMP},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective"
parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
update user_message_binding
<set>
<if test="username != null">
username = #{username,jdbcType=VARCHAR},
</if>
<if test="virtualHostName != null">
virtual_host_name = #{virtualHostName,jdbcType=VARCHAR},
</if>
<if test="exchangeName != null">
exchange_name = #{exchangeName,jdbcType=VARCHAR},
</if>
<if test="routingKeyName != null">
routing_key_name = #{routingKeyName,jdbcType=VARCHAR},
</if>
<if test="subscriber != null">
subscriber = #{subscriber,jdbcType=VARCHAR},
</if>
<if test="gmtCreate != null">
gmt_create = #{gmtCreate,jdbcType=TIMESTAMP},
</if>
<if test="gmtModified != null">
gmt_modified = #{gmtModified,jdbcType=TIMESTAMP},
</if>
</set>
where id = #{id,jdbcType=VARCHAR}
</update>
<update id="updateByPrimaryKey" parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
update user_message_binding
set username = #{username,jdbcType=VARCHAR},
virtual_host_name = #{virtualHostName,jdbcType=VARCHAR},
exchange_name = #{exchangeName,jdbcType=VARCHAR},
routing_key_name = #{routingKeyName,jdbcType=VARCHAR},
subscriber = #{subscriber,jdbcType=VARCHAR},
gmt_create = #{gmtCreate,jdbcType=TIMESTAMP},
gmt_modified = #{gmtModified,jdbcType=TIMESTAMP}
where id = #{id,jdbcType=VARCHAR}
</update>
</mapper>
</mapper>
\ No newline at end of file
... ...