update...

潘钊
1 parent 208d4b01
Showing 1 changed file with 7 additions and 34 deletions
src/main/java/com/bsth/server_rs/thread/RfidCardInfoPersistenceThread.java
@@ -7,7 +7,6 @@ import com.bsth.server_rs.base_info.person.buffer.PersonBufferData;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.jdbc.core.BatchPreparedStatementSetter;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.jdbc.datasource.DataSourceTransactionManager;
 import org.springframework.stereotype.Component;
@@ -15,8 +14,6 @@ import org.springframework.transaction.TransactionDefinition;
 import org.springframework.transaction.TransactionStatus;
 import org.springframework.transaction.support.DefaultTransactionDefinition;
-import java.sql.PreparedStatement;
-import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.List;
@@ -59,7 +56,7 @@ public class RfidCardInfoPersistenceThread extends Thread{
         if(list.size() == 0)
             return;
-        final List<Personnel> finalList = list;
+        //final List<Personnel> finalList = list;
         //编程式事务
         DataSourceTransactionManager tran = new DataSourceTransactionManager(jdbcTemplate.getDataSource());
@@ -68,20 +65,9 @@ public class RfidCardInfoPersistenceThread extends Thread{
         TransactionStatus status = tran.getTransaction(def);
         try{
-            jdbcTemplate.update("update bsth_c_personnel set id_rfid=?, tag_rfid=? where job_code=?", new BatchPreparedStatementSetter() {
-                @Override
-                public void setValues(PreparedStatement ps, int i) throws SQLException {
-                    Personnel p = finalList.get(i);
-                    ps.setString(1, p.getIdRfid());
-                    ps.setString(2, p.getTagRfid());
-                    ps.setString(3, p.getJobCode());
-                }
-
-                @Override
-                public int getBatchSize() {
-                    return finalList.size();
-                }
-            });
+            for(Personnel personnel : list){
+                jdbcTemplate.update("update bsth_c_personnel set id_rfid=?, tag_rfid=? where job_code=?", personnel.getIdRfid(), personnel.getTagRfid(), personnel.getJobCode());
+            }
             tran.commit(status);
         }catch (Exception e){
@@ -106,7 +92,6 @@ public class RfidCardInfoPersistenceThread extends Thread{
         if(list.size() == 0)
             return;
-        final List<Car> finalList = list;
         //编程式事务
         DataSourceTransactionManager tran = new DataSourceTransactionManager(jdbcTemplate.getDataSource());
@@ -114,21 +99,9 @@ public class RfidCardInfoPersistenceThread extends Thread{
         def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
         TransactionStatus status = tran.getTransaction(def);
         try{
-
-            jdbcTemplate.update("update bsth_c_cars set id_rfid=?, tag_rfid=? where nbbm=?", new BatchPreparedStatementSetter() {
-                @Override
-                public void setValues(PreparedStatement ps, int i) throws SQLException {
-                    Car c = finalList.get(i);
-                    ps.setString(1, c.getIdRfid());
-                    ps.setString(2, c.getTagRfid());
-                    ps.setString(3, c.getNbbm());
-                }
-
-                @Override
-                public int getBatchSize() {
-                    return finalList.size();
-                }
-            });
+            for(Car car : list){
+                jdbcTemplate.update("update bsth_c_cars set id_rfid=?, tag_rfid=? where inside_code=?", car.getIdRfid(),car.getTagRfid(),car.getNbbm());
+            }
             tran.commit(status);
         }catch (Exception e){