mysql存储过程

mapper里原始sql

select
        tss.channel_id as channelId,
        tssr.risk_id as riskId,
        count(tssr.risk_id) as riskCount
        from  ${riskTableName} tssr
        right JOIN ${salesmanTableName} tss
        on tssr.salesman_id = tss.salesman_id
WHERE
				tss.organization_id like CONCAT('',#{organCode,jdbcType=VARCHAR},'%')
        <if test="channelId != null and channelId !='' ">
        and tss.channel_id=#{channelId,jdbcType=VARCHAR}
        </if>
        group by tss.channel_id,tssr.risk_id
        order by tss.channel_id,count(tssr.risk_id) DESC

写成存储过程后

CREATE PROCEDURE pieProcedure(	IN organizationId VARCHAR(200),IN riskTableName VARCHAR(200),IN channelId VARCHAR(200)
)
BEGIN
	set @sqlStr=concat(
	'select
         tssr.channel_code as channelId,
        tssr.risk_id as riskId,
        count(tssr.risk_id) as riskCount
        from  ',riskTableName,' tssr
       
				WHERE
				instr(organization_code,',organizationId,')
				 ',channelId,'
        group by tssr.channel_code,tssr.risk_id

        order by tssr.channel_code,count(tssr.risk_id) DESC'
);
PREPARE stmt from @sqlStr;
EXECUTE stmt; 
end;

mapper.xml中改成

<select id="getFiveRiskByDay" resultType="com.sinosig.app.project.entity.TSlaqSalesmanRisk" parameterType="java.lang.String">
    call pieProcedure(#{organCode,jdbcType=VARCHAR},#{riskTableName},#{channelId})
    </select>

service中对mapper的调用改成

• 点赞
• 收藏
• 分享
• • 文章举报

wei_aiwan 发布了60 篇原创文章 · 获赞 121 · 访问量 10万+ 私信 关注

标签：存储,risk,channelId,tssr,tss,mysql,过程,id,channel
来源： https://blog.csdn.net/han_xiaoxue/article/details/103972933