首页 > 数据库技术 > 详细

Java拼接批量新增SQL语句

时间:2016-03-16 20:59:07      阅读:432      评论:0      收藏:0      [点我收藏+]
StringBuffer addSql = new StringBuffer(1000);
            int batchSize = 50;
            int executeTime = 0;
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            for (int i=0; i<trackIds.size(); i++) {
                if(i/batchSize > executeTime) {//50轮执行一次SQL(拷贝数据量太大)
                    String sql = addSql.substring(0, addSql.length() - 1);
                    baseJdbcDao.exceute(sql, null);
                    executeTime++;//执行次数++
                }
                if(i%batchSize == 0) {//50轮重新拼接SQL(防止SQL过长)
                    addSql = addSql.delete(0, addSql.length());
                    addSql.append("insert into " + DatabaseConstants.BASE + ".yk_behavior_monitor (TRACK_ID, PROGRAM_ID, " +
                            "BEHAVIOR_ID, ACTION_TOTAL, ACTION_COMPLETED, CREATED_BY, CREATED_DATE, LAST_UPDATED_BY, LAST_UPDATED_DATE, REMOVE_FLAG) values");
                }
                for (Integer behaviorId : behaviorIds) {
                    addSql.append("(");
                    addSql.append(trackIds.get(i) + ",");
                    addSql.append(programId + ",");
                    addSql.append(behaviorId + ",");
                    addSql.append("0,0,");
                    addSql.append(user.getUserId() + ",");
                    addSql.append("‘" + sdf.format(new Date()) + "‘,");
                    addSql.append(user.getUserId() + ",");
                    addSql.append("‘" + sdf.format(new Date()) + "‘,");
                    addSql.append("0),");
                }
            }
            String sql = addSql.substring(0, addSql.length() - 1);
            baseJdbcDao.exceute(sql, null);

 

Java拼接批量新增SQL语句

原文:http://www.cnblogs.com/cocoat/p/5284946.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!