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