JDBC项目实践

jopen 4年前

原文  http://www.cnblogs.com/fengdashen/p/5078190.html

这几天学习了JDBC的接口,从简单的连接,到不断地对JDBC的代码进行优化,最后到实体类,DAO类的设计,现在对这几天所学做一个总结:

首先是软件的系统组成:

数据库中有很多的表:Customer,Department,Order,Account等等,为了访问每个表,在java中建立相关的DAO,这些DAO构成数据访问层。java通过调用DAO,达到访问数据库的目的

下面是工程的创建步骤:

1:导入工具包以及配置文件

1.1:导入访问JDBC的驱动包:commons-dbcp2-2.1.1.jar,commons-logging-1.2.jar,commons-pool2-2.42.jar,ojdbc6.jar并对不同的包buildpath;

1.2: 创建Utils包,导入工具类DBUtils.java和配置文件db.properties,这两个工具类是JDBC的核心包,里面有连接数据库,断开连接的方法

DBUTils.java的源代码:

package utils;  import java.sql.Connection;  import java.sql.SQLException;  import java.util.Properties;    import org.apache.commons.dbcp2.BasicDataSource;    public class DBUtils {      private static String driver = null;      private static String url = null;      private static String user = null;      private static String password = null;            private static BasicDataSource ds = null;      //静态块      static{          Properties props = new Properties();          try {              //路径使用包路径              String path = "utils/db.properties";              props.load(                         DBUtils.class.getClassLoader()                         .getResourceAsStream(path));                            driver  = props.getProperty("driver");              url  = props.getProperty("url");              user  = props.getProperty("user");              password  = props.getProperty("password");              //ds中已经有了几个创建好的连接              ds = new BasicDataSource();//创建连接池              ds.setDriverClassName(driver);              ds.setUrl(url);              ds.setUsername(user);              ds.setPassword(password);              ds.setInitialSize(                      Integer.parseInt(props.getProperty("intialSize")));                                  } catch (Exception e) {              e.printStackTrace();          }      }            /*创建连接*/      public static Connection getConnection()         throws ClassNotFoundException, SQLException{          Connection conn = null;          if(ds!=null){               conn = ds.getConnection();          }          return conn;      }            /*关闭连接*/      public static void closeConnection(Connection conn) throws SQLException{          if(conn!=null)              conn.close();      }        }    View Code

读取的配置文件db.properties,里面放了Oracle的驱动,url,用户user密码 格式是key = value

db.properties的源代码:

#key = value  driver =   oracle.jdbc.OracleDriver  url =   jdbc:oracle:thin:@localhost:1521:xe  user =   fengweijie  password=   1070937053    #driver = com.mysql.jdbc.Driver  #url = jdbc:mysql:localhost:3306/test?useUni    intialSize = 10    View Code

完成之后项目截图:

2:创建实体包entity:里面存放的是数据库里面的表,例如部门表Dept,员工表Emp,根据表的数据类型创建Dept.java和Emp.java,并在Dept.java和Emp.java中添加get(),set()方法,以及tostring()方法;完成之后项目如图;

3:创建iDAO包:里面存放的是访问数据库的接口,以员工表和部门表为例,对应的是IEmp.java,Idept.java

4:创建DAO包:里面是实现IDAO的数据访问层,对应EmpDAO.java,Dept.java,用来实现访问数据库中对用的表

由于2,3,4步骤是体力活,所以一步到位,项目截图如图所示:

下面概述一下项目框架中的技巧:

由于在DAO中,每一个方法都需要获得连接数据库,以find函数为例,实现部门表的查找,每次都需要进行连接,查询,关闭,代码如下:

public void find(){          Connection conn = null;          PreparedStatement pstmt = null;          ResultSet rs = null;                    try {                            conn = DBUtils.getConnection();              //事务开始              conn.setAutoCommit(false);              //业务逻辑                                                                      conn.commit();                        } catch (Exception e) {              try {                  conn.rollback();              } catch (SQLException sqkex) {                  // TODO Auto-generated catch block                  sqkex.printStackTrace();              }              e.printStackTrace();          }finally {              try {                  conn.setAutoCommit(true);                  if(conn !=null)  conn.close();                  } catch (SQLException e) {                      // TODO Auto-generated catch block                      e.printStackTrace();                  }                        }                }

不同函数之间,例如按照部门编号查找,按照部门所处位置查找,等等,只是代码中的业务逻辑不同,其他的部分一致,而除了部门表以外,其他比如员工表也需要进行查询,也是业务逻辑不同,为了解决这个问题,需要写一个总的find方法,放在BaseDAO中

BaseDAO的源代码:

package DAO;    import java.sql.Connection;  import java.sql.PreparedStatement;  import java.sql.ResultSet;  import java.util.ArrayList;  import java.util.List;  import utils.DBUtils;    public abstract class BaseDAO<T> {      /*       * 所有find方法的三大差别       * 1:SQL语句不通       * 2:?参数有几个不确定,类型不确定       * 解决方法:类型不确定用:用object接住       *       个数不确定用数组解决       * Object[] params能接住所有的       * 3:返回值对象不确定,解决 泛型类 */      protected List<T> find(String sql,Object[] params)throws Exception{                    List<T> l = new ArrayList<T>();                    Connection conn = null;          PreparedStatement pstmt = null;          ResultSet rs = null;                    try {              conn = DBUtils.getConnection();              pstmt = conn.prepareStatement(sql);                            //问题1:不知道set什么,set几次              //有Object[]params              if(params!=null)                  for (int i = 0; i < params.length; i++) {                      pstmt.setObject(i+1, params[i]);                  }              rs = pstmt.executeQuery();              while(rs.next()){                  l.add(toEntity(rs));                            }                            return l;          } catch (Exception ex) {              throw ex;                        }finally {              if(rs!= null) rs.close();              if(pstmt != null) pstmt.close();                            DBUtils.closeConnection(conn);                        }          }            /*       * 因为while中的对象属性差异无法统一       * 完全交给子类自行完成       * */      public abstract T toEntity(ResultSet rs) throws Exception;        }    View Code

在BaseDAO 中,面临的问题有三:

1:SQL语句的不同,

2:SQL语句中的参数类型不能确定

3:返回的对象不能确定

解决的方法分别是:

1:SQL语句不同,定义String sql变量

2:SQL语句中的参数类型不确定,使用Object[]params接住所有的参数

3:返回值对象不确定,使用泛型,当其他的DAO继承BaseDAOI时候,将T改写为对应的类型即可;

因此find的生命定义为:protected List<T> find(String sql,Object[] params)throws Exception{}

find 函数中的经典代码:

1:在业务逻辑中填入参数:

//问题1:不知道set什么,set几次  //有Object[]params  if(params!=null)       for (int i = 0; i < params.length; i++) {               pstmt.setObject(i+1, params[i]);     }

2:返回结果:

while(rs.next()){          l.add(toEntity(rs));  }

因为在while中的数据类型差异太大,无法统一,完全交给子类处理,定义抽象方法:

public abstract T toEntity(ResultSet rs) throws Exception;

项目源代码下载地址: http://download.csdn.net/detail/generoius/9378231