1
public void thirdBackMonery() { 2 3 4 MySqlHepler2.getInstance().batchUpdateStringBuffer.setLength(0); 5 6 try { 7 MySqlHepler2.getInstance().batchUpdateStringBuffer.append("update userSheet SET "); 8 9 int batchInsertCount= AAAAYulebaoShareSingleton.getInstance().thirdBackList.size(); 10 String a=" score = CASE id ",b=" xiajiReturnScore = CASE id " 11 ,c=" messageCount = CASE id ",d=" oneClassMonery = CASE id ", 12 e=" twoClassMonery = CASE id ",f=" threeClassMonery = CASE id ", 13 h=" WHERE id IN(",oneClassMonery=null 14 ,twoClassMonery=null 15 ,threeClassMonery=null 16 ,score=null 17 ,id=null 18 ,messageCount=null,xiajiReturnScore=null; 19 for(int i=0;i<batchInsertCount;i++) 20 { 21 try 22 { 23 parameterObject=AAAAYulebaoShareSingleton.getInstance().thirdBackList.get(0) ; 24 25 26 27 oneClassMonery=parameterObject.getString("oneClassMonery"); 28 twoClassMonery=parameterObject.getString("twoClassMonery"); 29 threeClassMonery=parameterObject.getString("threeClassMonery"); 30 xiajiReturnScore=parameterObject.getString("xiajiReturnScore"); 31 score=parameterObject.getString("score"); 32 id=parameterObject.getString("id"); 33 34 messageCount="1"; 35 36 if(i==batchInsertCount-1 ) 37 { 38 a=a+"WHEN "+id+ " THEN score+"+score+" END, "; 39 b=b+"WHEN "+id+ " THEN xiajiReturnScore+"+xiajiReturnScore+" END, "; 40 c=c+"WHEN "+id+ " THEN messageCount+"+messageCount+" END, "; 41 d=d+"WHEN "+id+ " THEN oneClassMonery+"+oneClassMonery+" END, "; 42 e=e+"WHEN "+id+ " THEN twoClassMonery+"+twoClassMonery+" END, "; 43 f=f+"WHEN "+id+ " THEN threeClassMonery+"+threeClassMonery+" END "; 44 h=h+id+");"; 45 } 46 else 47 { 48 a=a+" WHEN "+id +" THEN score+"+score+" "; 49 b=b+" WHEN "+id +" THEN xiajiReturnScore+"+xiajiReturnScore+" "; 50 c=c+" WHEN "+id +" THEN messageCount+"+messageCount+" "; 51 d=d+" WHEN "+id +" THEN oneClassMonery+"+oneClassMonery+" "; 52 e=e+" WHEN "+id +" THEN twoClassMonery+"+twoClassMonery+" "; 53 f=f+" WHEN "+id +" THEN threeClassMonery+"+threeClassMonery+" "; 54 55 56 57 h=h+id+","; 58 } 59 60 AAAAYulebaoShareSingleton.getInstance().thirdBackList.remove(0); 61 oneClassMonery=null; 62 twoClassMonery=null; 63 threeClassMonery=null; 64 score=null; 65 id=null; 66 messageCount=null; 67 68 } 69 catch(Exception ex) 70 { 71 oneClassMonery=null; 72 twoClassMonery=null; 73 threeClassMonery=null; 74 score=null; 75 id=null; 76 messageCount=null; 77 78 AAAAYulebaoShareSingleton.getInstance().thirdBackList.remove(0); 79 80 continue; 81 } 82 83 } 84 85 86 87 MySqlHepler2.getInstance().batchUpdateStringBuffer.append(a); 88 MySqlHepler2.getInstance().batchUpdateStringBuffer.append(b); 89 MySqlHepler2.getInstance().batchUpdateStringBuffer.append(c); 90 MySqlHepler2.getInstance().batchUpdateStringBuffer.append(d); 91 MySqlHepler2.getInstance().batchUpdateStringBuffer.append(e); 92 MySqlHepler2.getInstance().batchUpdateStringBuffer.append(f); 93 MySqlHepler2.getInstance().batchUpdateStringBuffer.append(h); 94 95 96 97 98 String gourpStrin=MySqlHepler2.getInstance().batchUpdateStringBuffer.toString(); 99 int updateReuslt= executeUpdate(gourpStrin, null); 100 101 102 103 104 105 MySqlHepler2.getInstance().batchUpdateStringBuffer.setLength(0); 106 107 } catch (Exception e1) { 108 109 110 111 } 112 113 114 115 } 116 117 118 119 120 //试玩平台任务消息批量插入 121 public void invistXiajiReturnInfoSheet() { 122 initConnection(); 123 MySqlHepler2.getInstance().invistXiajiReturnStringBuffer.setLength(0); 124 125 try { 126 MySqlHepler2.getInstance().invistXiajiReturnStringBuffer.append("insert into infoSheet(title,content,datatime,account,infoType,qudao,firendId,rewardTotalMonery,rewardType) values"); 127 isOrNoException=0; 128 int batchInsertCount= AAAAYulebaoShareSingleton.getInstance(). shareXiaJiReturnMoneryInfoArray.size(); 129 for(int i=0;i<batchInsertCount;i++) 130 { 131 try 132 { 133 tempArr=AAAAYulebaoShareSingleton.getInstance().shareXiaJiReturnMoneryInfoArray.get(0) ; 134 title=varchar+tempArr[0].toString()+varchar; 135 content=varchar+tempArr[1].toString()+varchar; 136 datatime=varchar+tempArr[2].toString()+varchar; 137 account=varchar+tempArr[3].toString()+varchar; 138 infoType=varchar+tempArr[4].toString()+varchar; 139 qudao=varchar+tempArr[5].toString()+varchar; 140 firendId=varchar+tempArr[6].toString()+varchar; 141 rewardTotalMonery=varchar+tempArr[7].toString()+varchar; 142 rewardType=varchar+tempArr[8].toString()+varchar; 143 AAAAYulebaoShareSingleton.getInstance(). shareXiaJiReturnMoneryInfoArray.remove(0); 144 145 146 if(i==batchInsertCount-1 ) 147 { 148 MySqlHepler2.getInstance().invistXiajiReturnStringBuffer.append("("+title+","+content+","+datatime+","+account+","+infoType+","+qudao+","+firendId+","+rewardTotalMonery+","+rewardType+")"); 149 150 } 151 else 152 { 153 154 MySqlHepler2.getInstance().invistXiajiReturnStringBuffer.append("("+title+","+content+","+datatime+","+account+","+infoType+","+qudao+","+firendId+","+rewardTotalMonery+","+rewardType+"),"); 155 } 156 } 157 catch(Exception e) 158 { 159 AAAAYulebaoShareSingleton.getInstance(). shareXiaJiReturnMoneryInfoArray.remove(0); 160 isOrNoException+=1; 161 continue; 162 } 163 164 165 } 166 167 168 if(isOrNoException>0) 169 { 170 tranceslateInsertData=MySqlHepler2.getInstance().invistXiajiReturnStringBuffer.toString(); 171 172 if(tranceslateInsertData.substring(tranceslateInsertData.length()-1, 1).equals(",")) 173 { 174 tranceslateInsertData= tranceslateInsertData.substring(1, tranceslateInsertData.length()-1); 175 } 176 } 177 178 179 psStatement =(PreparedStatement) connection.prepareStatement("");//准备执行语句 180 if(isOrNoException>0) 181 { 182 psStatement.addBatch(tranceslateInsertData); 183 } 184 else 185 { 186 tranceslateInsertData=MySqlHepler2.getInstance().invistXiajiReturnStringBuffer.toString(); 187 psStatement.addBatch( tranceslateInsertData); 188 } 189 190 psStatement.executeBatch(); 191 connection.commit();//事务批量提交 拼接的 字符串 192 psStatement.close(); 193 connection.close(); 194 tranceslateInsertData=null; 195 MySqlHepler2.getInstance().invistXiajiReturnStringBuffer.setLength(0); 196 197 } catch (Exception e1) { 198 try { 199 psStatement.close(); 200 connection.close(); 201 tranceslateInsertData=null; 202 AAAAYulebaoShareSingleton.getInstance(). shareXiaJiReturnMoneryInfoArray.remove(0); 203 MySqlHepler2.getInstance().invistXiajiReturnStringBuffer.setLength(0); 204 205 } catch (SQLException e) { 206 207 } 208 209 210 211 } 212 213 tranceslateInsertData=null; 214 }
