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

分类：Python作者：编程之家用户

在做项目的时候，技术选型很重要，在底层的方法直接影响了我们对大数据访问以及修改的速度，在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,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加批量的方法,'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,?)"; 
    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(); 
     
  } 
}

您可能感兴趣的文章:

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

Python中的函数（二）
Python中的函数（二） 在上一篇文章中提到了Python中函数的定义和使用，在这篇文章里我们来讨论下关于函数的一些更深的话题。在学习C语言函数的时候，遇到的问题主要有形参实参的区别、参数的传递和改变、变量的作用域。同样在Python中，关于对函数的理解和使用也存在这些问题。下面来逐一讲解。一.函
Python中的字符串
Python中的字符串 可能大多数人在学习C语言的时候，最先接触的数据类型就是字符串，因为大多教程都是以&quot;Hello world&quot;这个程序作为入门程序，这个程序中要打印的&quot;Hello world&quot;就是字符串。如果你做过自然语言处理方面的研究，并且用Python
Python 面向对象编程（一）
Python 面向对象编程（一） 虽然Python是解释性语言，但是它是面向对象的，能够进行对象编程。下面就来了解一下如何在Python中进行对象编程。一.如何定义一个类 在进行python面向对象编程之前，先来了解几个术语：类，类对象，实例对象，属性，函数和方法。 类是对现实世界中一些事物的封装，
Python面向对象编程（二）
Python面向对象编程（二） 在前面一篇文章中谈到了类的基本定义和使用方法，这只体现了面向对象编程的三大特点之一：封装。下面就来了解一下另外两大特征：继承和多态。 在Python中，如果需要的话，可以让一个类去继承一个类，被继承的类称为父类或者超类、也可以称作基类，继承的类称为子类。并且Pytho
Python中的函数（一）
Python中的函数（一） 接触过C语言的朋友对函数这个词肯定非常熟悉，无论在哪门编程语言当中，函数（当然在某些语言里称作方法，意义是相同的）都扮演着至关重要的角色。今天就来了解一下Python中的函数用法。一.函数的定义 在某些编程语言当中，函数声明和函数定义是区分开的（在这些编程语言当中函数声明
在windows下如何快速搭建web.py开发框架
在windows下如何快速搭建web.py开发框架 用Python进行web开发的话有很多框架供选择，比如最出名的Django，tornado等，除了这些框架之外，有一个轻量级的框架使用起来也是非常方便和顺手，就是web.py。它由一名黑客所创建，但是不幸的是这位创建者于2013年自杀了。据说现在由
将Sublime Text 2搭建成一个好用的IDE
将Sublime Text 2搭建成一个好用的IDE 说起编辑器，可能大部分人要推荐的是Vim和Emacs，本人用过Vim，功能确实强大，但是不是很习惯，之前一直有朋友推荐SUblime Text 2这款编辑器，然后这段时间就试了一下，就深深地喜欢上这款编辑器了...
Python中的模块
Python中的模块 有过C语言编程经验的朋友都知道在C语言中如果要引用sqrt这个函数，必须用语句&quot;#include&lt;math.h&gt;&quot;引入math.h这个头文件，否则是无法正常进行调用的。那么在Python中，如果要引用一些内置的函数，该怎么处理呢？在Python中
Python的基础语法
Python的基础语法 在对Python有了基础的认识之后，下面来了解一下Python的基础语法，看看它和C语言、java之间的基础语法差异。一.变量、表达式和语句 Python中的语句也称作命令，比如print &quot;hello python&quot;这就是一条语句。 表达式，顾名思义，是
Eclipse+PyDev+Django+Mysql搭建Python web开发环境
Eclipse+PyDevʽjango+Mysql搭建Python web开发环境 Python的web框架有很多，目前主流的有Django、Tornado、Web.py等，最流行的要属Django了，也是被大家最看好的框架之一。下面就来讲讲如何搭建Django的开发环境。一.准备工作 需要下载的
在windows下安装配置Ulipad
在windows下安装配置Ulipad 今天推荐一款轻便的文本编辑器Ulipad，用来写一些小的Python脚本非常方便。 Ulipad下载地址： https://github.com/limodou/ulipad http://files.cnblogs.com/dolphin0520/u...
Python中的函数（三）
Python中的函数（三） 在前面两篇文章中已经探讨了函数的一些相关用法，下面一起来了解一下函数参数类型的问题。在C语言中，调用函数时必须依照函数定义时的参数个数以及类型来传递参数，否则将会发生错误，这个是严格进行规定的。然而在Python中函数参数定义和传递的方式相比而言就灵活多了。一.函数参数的
在Notepad++中搭配Python开发环境
在Notepad++中搭配Python开发环境 Python在最近几年一度成为最流行的语言之一，不仅仅是因为它简洁明了，更在于它的功能之强大。它不仅能够完成一般脚本语言所能做的事情，还能很方便快捷地进行大规模的项目开发。在学习Python之前我们来看一下Python的历史由来，&quot;Pytho
Python中的条件选择和循环语句
Python中的条件选择和循环语句 同C语言、Java一样，Python中也存在条件选择和循环语句，其风格和C语言、java的很类似，但是在写法和用法上还是有一些区别。今天就让我们一起来了解一下。一.条件选择语句 Python中条件选择语句的关键字为：if 、elif 、else这三个。其基本形式如
关于raw_input()和sys.stdin.readline()的区别
关于raw_input( )和sys.stdin.readline( )的区别 之前一直认为用raw_input( )和sys.stdin.readline( )来获取输入的效果完全相同，但是最近在写程序时有类似这样一段代码：import sysline = sys.stdin.readline()
初识Python
初识Python 跟学习所有的编程语言一样，首先得了解这门语言的编程风格和最基础的语法。下面就让我们一起来了解一下Python的编程风格。1.逻辑行与物理行 在Python中有逻辑行和物理行这个概念，物理行是指在编辑器中实际看到的一行，逻辑行是指一条Python语句。在Python中提倡一个物理行只
retry重试常见场景及实现
当我们的代码是有访问网络相关的操作时,比如http请求或者访问远程数据库，经常可能会发生一些错误，有些错误可能重新去发送请求就会成功，本文分析常见可能需要重试的场景，并最后给出python代码实现。
python迭代器和生成器
1.经典迭代器 2.将Sentence中的__iter__改成生成器函数 改成生成器后用法不变，但更加简洁。 3.惰性实现 当列表比较大，占内存较大时，我们可以采用惰性实现，每次只读取一个元素到内存。 或者使用更简洁的生成器表达式 4.yield from itertools模块含有大量生成器函数可
python-kafka源码解析之socketpair
本文介绍简单介绍socket的常用函数,并以python-kafka中的源码socketpair为例，来讲解python socket的运用
彻底弄懂python编码
python实践中经常出现编码相关的异常，大多网上找资料而没有理解原理，导致一次次重复错误。本文对常用Unicode、UTF-8、GB2312编码的原理进行介绍，接着介绍了python字符类型unicode和str以及常见编解码错误UnicodeEncodeError和UnicodeDEcodeEr
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot