Java实现Dbhelper支持大数据增删改

在做项目的时候，技术选型很重要，在底层的方法直接影响了我们对大数据访问以及修改的速度，在Java中有很多优秀的ORM框架，比如说：JPA，Hibernate 等等，正如我们所说的，框架有框架的好处，当然也存在一些可以改进的地方，这个时候，就需要我们针对于不同的业务不同的需求，不同的访问量，对底层的架构重新封装，来支持大数据增删改。

代码：

import java.io.*;
import java.sql.*;
import java.util.*;
import java.util.logging.Level;
import java.util.logging.Logger; 

import javax.servlet.jsp.jstl.sql.*; 

/**
 * DbHelper
 * @author qmx
 *
 */
public class Dbhelper { 

private String sql;  //要传入的sql语句
public void setSql(String sql) {
  this.sql = sql;
} 

private List sqlValues; //sql语句的参数
public void setSqlValues(List sqlValues) {
  this.sqlValues = sqlValues;
} 

private List<List> sqlValue; //sql语句的参数
public void setSqlValue(List<List> sqlValues) {
  this.sqlValue = sqlValues;
} 

private Connection con; //连接对象
  public void setCon(Connection con) {
  this.con = con;
} 

  public Dbhelper(){
    this.con=getConnection(); //给Connection的对象赋初值
  } 

  /**
   * 获取数据库连接
   * @return
   */
  private Connection getConnection(){  

    String driver_class=null;
    String driver_url=null;
    String database_user=null;
    String database_password=null;
    try {
      InputStream fis=this.getClass().getResourceAsStream("/db.properties"); //加载数据库配置文件到内存中
      Properties p=new Properties();
      p.load(fis); 

      driver_class=p.getProperty("driver_class");   //获取数据库配置文件
      driver_url=p.getProperty("driver_url");
      database_user=p.getProperty("database_user");
      database_password=p.getProperty("database_password"); 

      Class.forName(driver_class);
      con=DriverManager.getConnection(driver_url,database_user,database_password); 

    } catch (ClassNotFoundException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    } catch (SQLException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    } catch (FileNotFoundException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    } catch (IOException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
    return con;
  } 

  /**
   * 关闭数据库
   * @param con
   * @param pst
   * @param rst
   */
  private void closeAll(Connection con,PreparedStatement pst,ResultSet rst){
    if(rst!=null){
      try {
        rst.close();
      } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    } 

    if(pst!=null){
      try {
        pst.close();
      } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    } 

    if(con!=null){
      try {
        con.close();
      } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    } 

  } 

  /**
   * 关闭数据库
   * @param con
   * @param pst
   * @param rst
   */
  private void closeAll(Connection con,Statement pst,ResultSet rst){
    if(rst!=null){
      try {
        rst.close();
      } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    } 

    if(pst!=null){
      try {
        pst.close();
      } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    } 

    if(con!=null){
      try {
        con.close();
      } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    } 

  } 

  /**
   * 查找
   * @param sql
   * @param sqlValues
   * @return
   */
  public Result executeQuery(){
    Result result=null;
    ResultSet rst=null;
    PreparedStatement pst=null;
    try { 

      pst=con.prepareStatement(sql);
      if(sqlValues!=null&&sqlValues.size()>0){ //当sql语句中存在占位符时
        setSqlValues(pst,sqlValues);
      }
    rst=pst.executeQuery();
    result=ResultSupport.toResult(rst); //一定要在关闭数据库之前完成转换 

    } catch (SQLException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }finally{
      this.closeAll(con, pst, rst);
    } 

    return result;
  } 

  /**
   * 增删改
   * @return
   */
  public int executeUpdate(){
    int result=-1;
    PreparedStatement pst=null;
    try {
      pst=con.prepareStatement(sql);
      if(sqlValues!=null&&sqlValues.size()>0){ //当sql语句中存在占位符时
        setSqlValues(pst,sqlValues);
      }
    result=pst.executeUpdate();
    } catch (SQLException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }finally{
      this.closeAll(con, pst, null);
    }
    return result;
  } 

  /**
   * 使用PreparedStatement加批量的方法
   * @return
   */
  public int[] executeUpdateMore(){
    int[] result=null;
    try{
      PreparedStatement prest =con.prepareStatement(sql,ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
       for(List sqlValueString : sqlValue){
         for(int i=0;i<sqlValueString.size();i++){
          try {
            prest.setObject(i+1,sqlValueString.get(i));
          } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
          }
        }
        prest.addBatch();
       }
       prest.executeBatch();
     /*  con.commit();*/
       this.closeAll(con, prest, null);
    } catch (SQLException ex){
     Logger.getLogger(Dbhelper.class.getName()).log(Level.SEVERE, null,ex);
    }
    return result; 

  }  

  /**
   * 使用PreparedStatement加批量的方法,strvalue:
   * "INSERT INTOadlogs(ip,website,yyyymmdd,hour,object_id) VALUES('192.168.1.3','localhost','20081009',8,'23123')"
   * @return
   * @throws SQLException
   */
  public int[] executeUpdateMoreNotAuto() throws SQLException{
    int[] result =null;
    con.setAutoCommit(false);
    Statement stmt =con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                      ResultSet.CONCUR_READ_ONLY);
    String[] SqlString= null;
    for(String strvalue : SqlString){
      stmt.execute(strvalue);
    }
    con.commit();
    return result;
  } 

  /**
   * 使用PreparedStatement加批量的方法,strvalue:
   * "INSERT INTOadlogs(ip,website,yyyymmdd,hour,object_id) VALUES('192.168.1.3','localhost','20081009',8,'23123')"
   * @return
   * @throws SQLException
   */
  public int[] executeMoreNotAuto() throws SQLException{
    //保存当前自动提交模式
    Boolean booleanautoCommit=false;
    String[] SqlString= null;
    int[] result= null;
     try
     {
      booleanautoCommit=con.getAutoCommit();
       //关闭自动提交
      con.setAutoCommit(false);
      Statement stmt =con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
          ResultSet.CONCUR_READ_ONLY);
      //使用Statement同时收集多条sql语句
      /*stmt.addBatch(insert_sql1);
      stmt.addBatch(insert_sql2);
      stmt.addBatch(update_sql3);*/
      for(String strvalue : SqlString){
        stmt.addBatch(strvalue);
      }  

       //同时提交所有的sql语句
       stmt.executeBatch();
       //提交修改
       con.commit();
       con.setAutoCommit(booleanautoCommit);
       this.closeAll(con, stmt, null);
     }
     catch(Exception e)
     {
      e.printStackTrace();
      con.rollback();  //设定setAutoCommit(false)没有在catch中进行Connection的rollBack操作，操作的表就会被锁住，造成数据库死锁
     }
     return result;
  } 

  /**
   * 给sql语句中的占位符赋值
   * @param pst
   * @param sqlValues
   */
  private void setSqlValues(PreparedStatement pst,List sqlValues){
    for(int i=0;i<sqlValues.size();i++){
      try {
        pst.setObject(i+1,sqlValues.get(i));
      } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    }
  } 

} 

我们的在db.properties中写入访问数据库的信息：

driver_class=com.mysql.jdbc.Driver
driver_url=jdbc:mysql://192.168.22.246:3306/importexceltest
database_user=basic
database_password=basic

测试：

import java.util.*; 

public class ImportExcelTest {
  public static void main(String[] args){ 

    /*Dbhelper db = new Dbhelper();
    String sql = "insert into tb_coursetype(id,courseTypeName) values('2012003','qmx3')";
    db.setSql(sql);
    db.executeUpdate();*/ 

    /*Dbhelper db1 = new Dbhelper();
    String sql1 = "insert into tb_coursetype(id,courseTypeName) values(?,?)";
    List sqlValues = new ArrayList();
    sqlValues.add("2012004");
    sqlValues.add("qmx4");
    db1.setSqlValues(sqlValues);
    db1.setSql(sql1);
    db1.executeUpdate();*/ 

    Dbhelper db = new Dbhelper();
    String sql = "insert into tb_coursetype(id,courseTypeName) values(?,?)";
    List<List> sqlValues = new ArrayList();
    List sqlValueString =new ArrayList();
    sqlValueString.add("2012010");
    sqlValueString.add("qmx10");
    sqlValues.add(sqlValueString);
    List sqlValueString1 =new ArrayList();
    sqlValueString1.add("2012011");
    sqlValueString1.add("qmx11");
    sqlValues.add(sqlValueString1);
    List sqlValueString2 =new ArrayList();
    sqlValueString2.add("2012012");
    sqlValueString2.add("qmx12");
    sqlValues.add(sqlValueString2);
    List sqlValueString3 =new ArrayList();
    sqlValueString3.add("2012013");
    sqlValueString3.add("qmx13");
    sqlValues.add(sqlValueString3);
    db.setSqlValue(sqlValues);
    db.setSql(sql);
    db.executeUpdateMore(); 

  }
}