Java拼接批量新增SQL語句


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);

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM