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.*; 
 
 
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 sqlValue; //sql语句的参数 
public void setSqlValue(List sqlValues) { 
  this.sqlValue = sqlValues; 
} 
 
private Connection con; //连接对象 
  public void setCon(Connection con) { 
  this.con = con; 
} 
 
  public Dbhelper(){ 
    this.con=getConnection(); //给Connection的对象赋初值 
  } 
   
   
  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; 
  } 
   
  
   
 
   
  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(); 
      } 
    } 
     
     
  } 
   
 
   
  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(); 
      } 
    } 
     
     
  } 
   
   
  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; 
  } 
   
   
   
  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; 
  } 
   
   
   
  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

我们的在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(?,?)"; 
    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(); 
     
  } 
}