20151208--批处理

package com.hanqi;

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.hanqi.common.DBHelper;

/**
 * Servlet implementation class EditUser
 */
public class EditUser extends HttpServlet {
    private static final long serialVersionUID = 1L;
       
    /**
     * @see HttpServlet#HttpServlet()
     */
    public EditUser() {
        super();
        // TODO Auto-generated constructor stub
    }

    /**
     * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
     */
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        
        request.setCharacterEncoding("UTF-8");    
        response.setContentType("text/html;charset=UTF-8");
        response.setCharacterEncoding("UTF-8");    
        
        //接受相关参数
        String userID = request.getParameter("userid");
        String userName = request.getParameter("username");
        String pw = request.getParameter("password");
        //判断输入的内容
                if(userID == null || userID.trim().length() == 0)
                {
                    //输出内容
                    response.getWriter().append("用户代码不能为空");
                }
                else if(userName == null || userName.trim().length() == 0)
                {
                    response.getWriter().append("用户姓名不能为空");
                }
                else
                {
                    try 
                    {
                        Connection conn = DBHelper.getConnection();    //
                        if(conn != null)
                        {
                            //操纵数据库        select sysdate from dual;
                            String sql = "update t_user set user_name = ?, password = ? where user_id = ?";
                            
                            //另外一种方法：
                            //String sql = "insert into t_user (user_id,user_name,password) values ('" + userID + "')";
                            
                            //执行sql语句的类
                            PreparedStatement pps = conn.prepareStatement(sql);
                            
                            //转码
                            userName = new String(userName.getBytes("ISO-8859-1"),"UTF-8");      
                            //post 提交方式不用转码  get方式需要转码
                            
                            
                            //将操纵数据库中数据类名编下顺序便于输入
                            pps.setString(3, userID);
                            pps.setString(1, userName);
                            pps.setString(2, pw);
                            
                            
                            int row = pps.executeUpdate();     //执行sql语句并返回所影响的行数
                            
                            //关闭  释放资源
                            
                            pps.close();
                            
                            conn.close();
                            
                            response.sendRedirect("FindUserList");    //返回  FindUserList
                            /*
                            if(row > 0)
                            {
                                response.getWriter().append("保存"+ row +"条数据成功");
                            }
                            else
                            {
                                response.getWriter().append("保存数据失败");
                            }
                            
                            
                            */
                            
                            
                        }
                        else
                        {
                            
                        }
                        
                    }
                    catch (Exception e)        //仅捕获一类特定异常 
                    {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                        response.getWriter().append(e.getMessage());
                    }
                }
    }

    /**
     * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
     */
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // TODO Auto-generated method stub
        doGet(request, response);
    }

}

package com.hanqi;

import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.hanqi.common.DBHelper;

import java.sql.*;
import java.util.*;
/**
 * Servlet implementation class BatchAddUser
 */
public class BatchAddUser extends HttpServlet {
    private static final long serialVersionUID = 1L;
       
    /**
     * @see HttpServlet#HttpServlet()
     */
    public BatchAddUser() {
        super();
        // TODO Auto-generated constructor stub
    }

    /**
     * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
     */
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        request.setCharacterEncoding("UTF-8");    
        response.setContentType("text/html;charset=UTF-8");
        response.setCharacterEncoding("UTF-8");    
        
        try 
        {
            PreparedStatement pse = null;
            
            Connection conn = DBHelper.getConnection();
            if(conn != null)
            {
                try{
                //批量处理
                //批量插入
                String sql = "insert into T_USER values (?,?,?, sysdate)";
                
                pse = conn.prepareStatement(sql);    //执行语句
                
                Random rd = new Random();        //生成随机数
                
                for(int i = 0 ; i < 10 ; i++)
                {
                    int m = rd.nextInt(1000);
                    
                    pse.setString(1,""+ m);
                    
                    pse.setString(2, "abc"+i);
                    
                    pse.setString(3, "123");
                    
                    pse.addBatch();//放入到批处理中
                }
            int[] jg = pse.executeBatch();  //批处理提交
            
            //遍历它的结果
            for(int i = 0;i < jg.length;i++)
            {
                response.getWriter().append(jg[i]+"<br>");
            }
                }
                catch(Exception e){}
                finally
                {    try{
                    pse.close();
                    conn.close();
                }catch(Exception a){
                    }
                }
            }
            else
            {
                response.getWriter().append("dfdfd");
            }
            
        } 
        catch (Exception e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        
        
    }

    /**
     * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
     */
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // TODO Auto-generated method stub
        doGet(request, response);
    }

}