java(功能篇) java(mysql)数据库 实现数据批量插入

package com.emc.database;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

import com.emc.model.DyLun;
import com.emc.service.DyLunService;

public class Demo {
	public static final String DBDRIVER = "com.mysql.jdbc.Driver";
	    public static final String DBURL = "jdbc:mysql://192.168.0.32:3306/iiiis";
	    public static final String DBUSER = "root";
	    public static final String DBPASS = "Vixuan724";
	    //java 除法取整函数
	    public static int getMyInt(int a,int b) {
	    	return(((double)a/(double)b)>(a/b)?a/b+1:a/b);
	    	}
	    //批处理处理信息量
	    private static final int processing=50;
	/**
	 * @param args
	 */
	public static void main(String[] args) throws Exception {
		
		// TODO Auto-generated method stub
		Connection conn=null;
		        PreparedStatement ps=null;
		        String sql="insert into TB_DY_LUN (device_Id,VOLUME_ID_IN_ARRAY,VOLUME_NAME,VOLUME_TYPE,UPDATE_FLAG,NUMBER_OF_BLOCK,BLOCK_SIZE,RAID_LEVEL,HEALTH_STATE,VOLUME_ID_IN_HOST,update_time) values(?,?,?,?,?,?,?,?,?,?,?)";
		        Class.forName(DBDRIVER);
		        conn=DriverManager.getConnection(DBURL, DBUSER, DBPASS);
		         ps=conn.prepareStatement(sql);
		         
		         DyLunService service = new DyLunService();
		     	List<DyLun> list = service
		     			.getdylun("C:\\data\\emc\\Symm_StorageVolume.xml");
		     	//批处理循环次数
		         int k=getMyInt(list.size(),processing);
		         for(int j=0;j<k;j++){
		        	 //批处理数量
		        		for(int i = 0; i < 50; i++){
		        			int result=j*50+i;
		        			System.out.println("结果数："+result);
		        			if(result<list.size()){
		        				DyLun lun = list.get(result);
					    		String s="select * from TB_DY_LUN where VOLUME_ID_IN_ARRAY='"+lun.getVolumeIdInArray()+"'";
					    		ResultSet set=DataBase.select(s);
					    		if (set.next()){
					    			//存在同名主键不做处理
					    		}else{
					    			ps.setString(1 ,lun.getDeviceId() );
					    			ps.setString(2, lun.getVolumeIdInArray());
					    			ps.setString(3,lun.getVolumeName() );
					    			ps.setString(4, lun.getVolumeType());
					    			ps.setString(5, lun.getUpdateFlag());
					    			ps.setInt(6, lun.getNumberOfBlock());
					    			ps.setInt(7, lun.getBlockSize());
					    			ps.setString(8, lun.getRaidLevel());
					    			ps.setString(9, lun.getHealthState());
					    			ps.setString(10, lun.getVolumeIdInHost());
					    			Date date = new Date();
					    			SimpleDateFormat dateFormat = new SimpleDateFormat(
					    					"yyyy/MM/dd HH:mm:ss");
					    			ps.setString(11, dateFormat.format(date.getTime()).toString());
					    			ps.addBatch();
					    		}
		        				
		        			}
				    	
				    		
				    	}
		        		 int trmp[]=ps.executeBatch();
				         System.out.println("更新了"+trmp.length+"条数据。。");
		        	 
		         }
		     
		        
		        ps.close();
		        conn.close();
	}

}