MyBatis批量插入数据_mybaits 插入生成语句多一个括号-程序员宅基地

技术标签: java  

1.普通for循环插入数据

controller层

package com.stylefeng.guns.modular.business.controller;

import com.etone.common.util.MyJdbcUtil;
import com.stylefeng.guns.entity.MerchantConnectData;
import com.stylefeng.guns.entity.PaymentsBatch;
import com.stylefeng.guns.modular.business.service.O2oImportOrderPaymentsService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 导入历史订单支付(支付单号sdb_ectolls_payments)明细数据
 */
@Controller
@RequestMapping("/import")
public class O2oImportOrderPaymentsController {

    @Autowired
    private O2oImportOrderPaymentsService o2oImportOrderPaymentsService;

    private static Logger logger = LoggerFactory.getLogger(O2oImportOrderPaymentsController.class);

    @RequestMapping("/payments_history")
    public void importData(){
        logger.info("导入数据开始>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
        //开始时间
        long startTime = System.currentTimeMillis();
        //查询所有的连接商户库信息
        List<MerchantConnectData> connectDataList = o2oImportOrderPaymentsService.queryConnectMerchantKu();
        //如果数据不为空
        if(connectDataList != null && connectDataList.size()>0){
            //遍历所有的商户链接信息取出对应的数据
            for (int i = 0; i < connectDataList.size(); i++) {
                //获取信息
                String yklBn = connectDataList.get(i).getYklBn();  //商户号   订单号+商户号 组成新的订单号防止重复
                String mHost = connectDataList.get(i).getmHost();  //主数据库地址
                String mUserName = connectDataList.get(i).getmUserName();  //主数据库用户名
                String mUserPassword = connectDataList.get(i).getmUserPassword();  //主数据库密码
                String mDbName = connectDataList.get(i).getmDbName();  //主数据库的名字 和商户对应 一个商户一个库
                String sourceName = o2oImportOrderPaymentsService.querySourceName(yklBn); //商圈名
                logger.info("开始连接数据库【"+mDbName+"】>>>>>>>>>>");
                Connection connection = null;
                PreparedStatement preparedStatement1 = null;
                try {
                    //创建StringBuffer  最终结果是:jdbc:mysql://127.0.0.1:3306/etoneo2o
                    StringBuffer sbf = new StringBuffer();
                    sbf.append("jdbc:mysql://");
                    sbf.append(mHost);
                    sbf.append(":");
                    sbf.append("3306"); //端口都是3306
                    sbf.append("/");
                    sbf.append(mDbName);
                    sbf.append("?useUnicode=true&characterEncoding=utf-8&useSSL=true&autoReconnect=true");
                    //1.加载 驱动程序,获取数据库连接
                    MyJdbcUtil.setJdbcParam("com.mysql.jdbc.Driver",sbf.toString(),mUserName,mUserPassword);
                    //2.通过数据库连接操作数据库,实现增删改查
                    connection =MyJdbcUtil.connect();
                    //因为本次导出历史数据是首次所以不用考虑是否重复直接查询然后插入到数据库中即可
                    String SdbEctoolsPaymentsSql = "select sep.payment_id,sep.money,sep.pay_app_id,sep.t_confirm,seob.rel_id from sdb_ectools_payments as sep,sdb_ectools_order_bills as seob where seob.bill_id = sep.payment_id;";
                    preparedStatement1 = connection.prepareStatement(SdbEctoolsPaymentsSql);
                    ResultSet resultSet = preparedStatement1.executeQuery();
                    List<PaymentsBatch> pbList = new ArrayList<PaymentsBatch>();
                    //遍历数据 set集合无序 不可重复
                    while (resultSet.next()){
                        PaymentsBatch paymentsBatch = new PaymentsBatch();
                        //获取数据
                        String payment_id = resultSet.getString("payment_id");
                        String money = resultSet.getString("money");
                        String pay_app_id = resultSet.getString("pay_app_id");
                        String t_confirm = resultSet.getString("t_confirm");
                        String rel_id = resultSet.getString("rel_id");  //原生的订单id
                        //对rel_id做处理,前面拼接商户号防止重复
                        String order_id = yklBn + rel_id;  //处理后的orderId
                        paymentsBatch.setPaymentId(payment_id);
                        paymentsBatch.setMoney(money);
                        paymentsBatch.setPayAppId(pay_app_id);
                        paymentsBatch.setTconfirm(t_confirm);
                        paymentsBatch.setOrderId(order_id);
                        pbList.add(paymentsBatch);
                        o2oImportOrderPaymentsService.insertEctoolsPayments(payment_id,money,pay_app_id,t_confirm,order_id,sourceName,yklBn);
                    }
//                    o2oImportOrderPaymentsService.batchInsertEctoolsPayments(pbList);
                    long endTime = System.currentTimeMillis();
                    logger.info("插入数据成功总记用时【"+(startTime-endTime)+"】毫秒");
                } catch (Exception e) {
                    logger.info("连接数据库异常" + e.getMessage() + "!");
                    e.printStackTrace();
                }finally{
                    //关闭资源
                    if(preparedStatement1 != null){
                        try {
                            preparedStatement1.close();
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
                    if(connection != null){
                        try {
                            connection.close();
                        } catch (SQLException e) {

                        }
                    }
                }

            }
        }else{
            logger.info("没有对应的数据可以处理!");
        }
    }


}

service层

package com.stylefeng.guns.modular.business.service;

import com.stylefeng.guns.entity.MerchantConnectData;
import com.stylefeng.guns.entity.PaymentsBatch;

import java.util.List;

public interface O2oImportOrderPaymentsService {
    List<MerchantConnectData> queryConnectMerchantKu();

    String querySourceName(String yklBn);

    void insertEctoolsPayments(String payment_id, String money, String pay_app_id, String t_confirm, String order_id, String sourceName, String yklBn);

    void batchInsertEctoolsPayments(List<PaymentsBatch> pbList);
}

实现层


    @Override
    public void insertEctoolsPayments(String payment_id, String money, String pay_app_id, String t_confirm, String order_id, String sourceName, String yklBn) {
        o2oImportOrderPaymentsMapper.insertEctoolsPayments(payment_id,money,pay_app_id,t_confirm,order_id,sourceName,yklBn);
    }

mapper

void insertEctoolsPayments(@Param("payment_id") String payment_id, @Param("money") String money, @Param("pay_app_id") String pay_app_id, @Param("t_confirm") String t_confirm, @Param("order_id") String order_id, @Param("sourceName") String sourceName, @Param("yklBn") String yklBn);

mapper.xml

<!--插入数据-->
    <insert id="insertEctoolsPayments"  parameterType="java.lang.String">
        insert into sdb_ectools_payments (payment_id,money,pay_app_id,t_confirm,order_id,source_name,merchant_bn) values(#{payment_id},#{money},#{pay_app_id},#{t_confirm},#{order_id},#{sourceName},#{yklBn})
    </insert>

用时

2.批量插入

controller层

package com.stylefeng.guns.modular.business.controller;

import com.etone.common.util.MyJdbcUtil;
import com.stylefeng.guns.entity.MerchantConnectData;
import com.stylefeng.guns.entity.PaymentsBatch;
import com.stylefeng.guns.modular.business.service.O2oImportOrderPaymentsService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 导入历史订单支付(支付单号sdb_ectolls_payments)明细数据
 */
@Controller
@RequestMapping("/import")
public class O2oImportOrderPaymentsController {

    @Autowired
    private O2oImportOrderPaymentsService o2oImportOrderPaymentsService;

    private static Logger logger = LoggerFactory.getLogger(O2oImportOrderPaymentsController.class);

    @RequestMapping("/payments_history")
    public void importData(){
        logger.info("导入数据开始>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
        //开始时间
        long startTime = System.currentTimeMillis();
        //查询所有的连接商户库信息
        List<MerchantConnectData> connectDataList = o2oImportOrderPaymentsService.queryConnectMerchantKu();
        //如果数据不为空
        if(connectDataList != null && connectDataList.size()>0){
            //遍历所有的商户链接信息取出对应的数据
            for (int i = 0; i < connectDataList.size(); i++) {
                //获取信息
                String yklBn = connectDataList.get(i).getYklBn();  //商户号   订单号+商户号 组成新的订单号防止重复
                String mHost = connectDataList.get(i).getmHost();  //主数据库地址
                String mUserName = connectDataList.get(i).getmUserName();  //主数据库用户名
                String mUserPassword = connectDataList.get(i).getmUserPassword();  //主数据库密码
                String mDbName = connectDataList.get(i).getmDbName();  //主数据库的名字 和商户对应 一个商户一个库
                String sourceName = o2oImportOrderPaymentsService.querySourceName(yklBn); //商圈名
                logger.info("开始连接数据库【"+mDbName+"】>>>>>>>>>>");
                Connection connection = null;
                PreparedStatement preparedStatement1 = null;
                try {
                    //创建StringBuffer  最终结果是:jdbc:mysql://127.0.0.1:3306/etoneo2o
                    StringBuffer sbf = new StringBuffer();
                    sbf.append("jdbc:mysql://");
                    sbf.append(mHost);
                    sbf.append(":");
                    sbf.append("3306"); //端口都是3306
                    sbf.append("/");
                    sbf.append(mDbName);
                    sbf.append("?useUnicode=true&characterEncoding=utf-8&useSSL=true&autoReconnect=true");
                    //1.加载 驱动程序,获取数据库连接
                    MyJdbcUtil.setJdbcParam("com.mysql.jdbc.Driver",sbf.toString(),mUserName,mUserPassword);
                    //2.通过数据库连接操作数据库,实现增删改查
                    connection =MyJdbcUtil.connect();
                    //因为本次导出历史数据是首次所以不用考虑是否重复直接查询然后插入到数据库中即可
                    String SdbEctoolsPaymentsSql = "select sep.payment_id,sep.money,sep.pay_app_id,sep.t_confirm,seob.rel_id from sdb_ectools_payments as sep,sdb_ectools_order_bills as seob where seob.bill_id = sep.payment_id;";
                    preparedStatement1 = connection.prepareStatement(SdbEctoolsPaymentsSql);
                    ResultSet resultSet = preparedStatement1.executeQuery();
                    List<PaymentsBatch> pbList = new ArrayList<PaymentsBatch>();
                    //遍历数据 set集合无序 不可重复
                    while (resultSet.next()){
                        PaymentsBatch paymentsBatch = new PaymentsBatch();
                        //获取数据
                        String payment_id = resultSet.getString("payment_id");
                        String money = resultSet.getString("money");
                        String pay_app_id = resultSet.getString("pay_app_id");
                        String t_confirm = resultSet.getString("t_confirm");
                        String rel_id = resultSet.getString("rel_id");  //原生的订单id
                        //对rel_id做处理,前面拼接商户号防止重复
                        String order_id = yklBn + rel_id;  //处理后的orderId
                        paymentsBatch.setPaymentId(payment_id);
                        paymentsBatch.setMoney(money);
                        paymentsBatch.setPayAppId(pay_app_id);
                        paymentsBatch.setTconfirm(t_confirm);
                        paymentsBatch.setOrderId(order_id);
                        pbList.add(paymentsBatch);
                        //o2oImportOrderPaymentsService.insertEctoolsPayments(payment_id,money,pay_app_id,t_confirm,order_id,sourceName,yklBn);
                    }
                    o2oImportOrderPaymentsService.batchInsertEctoolsPayments(pbList);
                    long endTime = System.currentTimeMillis();
                    logger.info("插入数据成功总记用时【"+(startTime-endTime)+"】毫秒");
                } catch (Exception e) {
                    logger.info("连接数据库异常" + e.getMessage() + "!");
                    e.printStackTrace();
                }finally{
                    //关闭资源
                    if(preparedStatement1 != null){
                        try {
                            preparedStatement1.close();
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
                    if(connection != null){
                        try {
                            connection.close();
                        } catch (SQLException e) {

                        }
                    }
                }

            }
        }else{
            logger.info("没有对应的数据可以处理!");
        }
    }


}

service层

 void batchInsertEctoolsPayments(List<PaymentsBatch> pbList);

implement层

@Override
    public void batchInsertEctoolsPayments(List<PaymentsBatch> pbList) {
        o2oImportOrderPaymentsMapper.batchInsertEctoolsPayments(pbList);
    }

mapper层

void batchInsertEctoolsPayments(@Param("pbList") List<PaymentsBatch> pbList);

xml

<!--批量插入数据-->
    <insert id="batchInsertEctoolsPayments" parameterType="java.util.List">
        insert into sdb_ectools_payments (payment_id,money,pay_app_id,t_confirm,order_id,source_name,merchant_bn) values
        <foreach collection="pbList" item="item" index="index" separator=",">
            (
                #{item.paymentId,jdbcType=VARCHAR},
                #{item.money,jdbcType=VARCHAR},
                #{item.payAppId,jdbcType=VARCHAR},
                #{item.tconfirm,jdbcType=VARCHAR},
                #{item.orderId,jdbcType=VARCHAR},
                #{item.sourceName,jdbcType=VARCHAR},
                #{item.merchantBn,jdbcType=VARCHAR}
            )
        </foreach>
    </insert>

结果

注意:foreach循环的时候括号写在内部,不可以用open(  close ) 的方式否则会报错

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/LuckFairyLuckBaby/article/details/88390917

智能推荐

【KMP】 模板:next数组、封装kmp_next数组模板-程序员宅基地

文章浏览阅读255次。代码:int T[N],S[N];int nextt[N];int len1,len2; //定义全局变量,void set_next() //next数组;{ int i,k=0; nextt[0]=0; for(i=1; i

正向shell和反弹shell-程序员宅基地

文章浏览阅读8.6k次,点赞7次,收藏40次。正向shell反弹shell的利用场景以及使用技巧_正向shell

Mybatis第五篇| 这个sql,它会动!-程序员宅基地

文章浏览阅读268次。点击上方“JAVAandPython君”,选择“星标”公众号重磅干货,第一时间送达原创| kuls首发: JAVAandPython君目录1.Mybatis第一篇|我的第一个Mybati..._mybatis可以将resultype设置成动态的吗

多态与非多态类型区别_多态和非多态-程序员宅基地

文章浏览阅读1k次。多态类型:含有虚函数的类型,就可称为多态。(同 含有纯虚函数就可称为抽象类)多态体现为:基类指针对基函数调用时,实现的是派生类的函数实现多态类型适合被继承,非多态类型不适合被继承,原因:对基态虚函数可实现覆盖是继承的最大优势和特征。非多态类型被继承后,通过基类指针只能实现基类函数的特性,失去了继承原本的意义,且组合类同样可以实现对于基类指针调用析构函数时,非多态类的派生类析构函数无法实..._多态和非多态

JDK动态代理及spring生成的代理类 $Proxy0_spring 打印出class类名$proxy129什么意思-程序员宅基地

文章浏览阅读965次。一个类: Proxy 提供了一些静态方法用于创建动态代理类的Class对象或者是动态代理对象, 也是所有动态代理类的父类. public static Object newProxyInstance(ClassLoader loader, Class<?>[] interfaces, ..._spring 打印出class类名$proxy129什么意思

浮动与定位_行内元素的子元素添加了浮动-程序员宅基地

文章浏览阅读263次。为什么用浮动?解决了多个块状元素在同一行显示的布局问题用在哪?用在页面布局怎么用? float:left/right浮动最早是用来控制图片,以便达到其他元素(特别是文字)实现“环绕”图片的效果。浮动的特征浮动脱离标准流,不占位置,会影响标准流。浮动只有左右浮动。浮动首先创建包含块的概念。就是说,浮动的元素总是找离它最近的父级元素对齐。但是不会超出内边距的范围。1.一个父盒子里面的子盒子,如果其中一个子级有浮动的,则其他子级都需要浮动。这样才能一行对齐显示。2.元素添加浮动._行内元素的子元素添加了浮动

随便推点

要在HTML标记符中直接嵌入样式,HTML期末复习试题及参考答案.doc-程序员宅基地

文章浏览阅读997次。HTML期末复习试题及参考答案.doc制作人正元设计 个人作品网站 HTML期末复习题(含答案)第1题 判断正误(1)HTML标记符的属性一般不区分大小写。(对)(2)网站就是一个链接的页面集合。(对)(3)将网页上传到Internet时通常采用FTP方式。(对)(4)所有的HTML标记符都包括开始标记符和结束标记符。(错)(5)用H1标记符修饰的文字通常比用H6标记符修饰的要小(错)。(6)B标..._html标记符的属性一般不区分大小写

MVEL表达式 报错:org.mvel2.PropertyAccessException: [Error: unresolvable property or identifier: tp_code]-程序员宅基地

文章浏览阅读1.2k次。分析错误:org.mvel2.PropertyAccessException: [Error: unresolvable property or identifier: tp_code]//假设这里已经准备了数据。解决方案:resultMap中初始化参数tp_code,有数据填充数据,没有数据设置空,但是字段要有。由这里可以知道,是在解析表达式的时候出错了,因为在resultMap中没有找到参数tp_code。firstExpression://准备解析的表达式。_unresolvable property or identifier

ONES 课堂:敏捷开发和迭代-程序员宅基地

文章浏览阅读603次。ONES研发管理工具已获得多项行业大奖及业内认可,并荣幸成为中国通信标准化协会云计算标准和开源推进委员会会员单位,以及中国《研发运营一体化(DevOps)能力成熟度模型》编写单位。为了能..._ones中迭代任务 进入未开始

【Altium Designer】AD解决元件倾斜放置导致器件重叠报错的办法_altium designer元件外框重叠-程序员宅基地

文章浏览阅读9.3k次,点赞7次,收藏17次。首先,我不是专业的PCB设计人员,因此给出的方法只能解燃眉之急,不符合常规设计规范,切记!在此以Altium Designer 17为例:设计电路板时,经常需要旋转器件45度才可以最大化利用电路板两侧空间。但是,靠的太近有时就会遇到这种事:为什么冒出绿光(出现违反规则)?明明器件没有重合!全选中看看原来AD是这样理解器件的空间的……如果我们对电路板DRC,就知道..._altium designer元件外框重叠

创建LVM报错:Can't initialize physical volume "/dev/sdb1" of volume group "myvg" without -ff_can't initialize physical volume "/dev/sdc1" of vo-程序员宅基地

文章浏览阅读1.7w次。问题:在使用fdisk /dev/sdb 删除原有LVM分区,在接着创建LVM新分区/dev/sdb1。完毕保存之后。执行pvcreate /dev/sdb1出现报错Can't initialize physical volume "/dev/sdb1" of volume group "myvg" without -ff问题解决:这是由于没有卸载原有逻辑卷,逻辑卷组,物理_can't initialize physical volume "/dev/sdc1" of volume group "vg0" without -

Tinkpad T480设置U盘启动_t480bios设置启动顺序-程序员宅基地

文章浏览阅读2.9w次,点赞6次,收藏16次。将thinkpad t480设置U盘启动的过程记录下来,自己时间久了备用,方便路人。1,开机出现lenovo标的时候按F1进入bios,切到security标签,选择service boot进入2,将secure boot 置为disable3,切换主标签到startup,将UEFI/Legacy Bootz置为【UEFI Only】,将CSM Support置为【Yes】..._t480bios设置启动顺序

推荐文章

热门文章

相关标签