JDBC项目实践

这几天学习了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