设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

JDBC项目实践

2017-2-7 13:41| 发布者: zhangjf| 查看: 471| 评论: 0

摘要: 原文 http://www.cnblogs.com/fengdashen/p/5078190.html 这几天学习了JDBC的接口，从简单的连接，到不断地对JDBC的代码进行优化，最后到实体类，DAO类的设计，现在对这几天所学做一个总结： 首先是软件的系统组 ...

原文 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的源代码：

  1. package utils;
  2. import java.sql.Connection;
  3. import java.sql.SQLException;
  4. import java.util.Properties;
  6. import org.apache.commons.dbcp2.BasicDataSource;
  8. public class DBUtils {
  9. private static String driver = null;
  10. private static String url = null;
  11. private static String user = null;
  12. private static String password = null;
  14. private static BasicDataSource ds = null;
  15. //静态块
  16. static{
  17. Properties props = new Properties();
  18. try {
  19. //路径使用包路径
  20. String path = "utils/db.properties";
  21. props.load(
  22. DBUtils.class.getClassLoader()
  23. .getResourceAsStream(path));
  25. driver = props.getProperty("driver");
  26. url = props.getProperty("url");
  27. user = props.getProperty("user");
  28. password = props.getProperty("password");
  29. //ds中已经有了几个创建好的连接
  30. ds = new BasicDataSource();//创建连接池
  31. ds.setDriverClassName(driver);
  32. ds.setUrl(url);
  33. ds.setUsername(user);
  34. ds.setPassword(password);
  35. ds.setInitialSize(
  36. Integer.parseInt(props.getProperty("intialSize")));
  39. } catch (Exception e) {
  40. e.printStackTrace();
  41. }
  42. }
  44. /*创建连接*/
  45. public static Connection getConnection()
  46. throws ClassNotFoundException, SQLException{
  47. Connection conn = null;
  48. if(ds!=null){
  49. conn = ds.getConnection();
  50. }
  51. return conn;
  52. }
  54. /*关闭连接*/
  55. public static void closeConnection(Connection conn) throws SQLException{
  56. if(conn!=null)
  57. conn.close();
  58. }
  60. }
  62. View Code
复制代码

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

db.properties的源代码：

  1. #key = value
  2. driver = oracle.jdbc.OracleDriver
  3. url = jdbc:oracle:thin:@localhost:1521:xe
  4. user = fengweijie
  5. password= 1070937053
  7. #driver = com.mysql.jdbc.Driver
  8. #url = jdbc:mysql:localhost:3306/test?useUni
  10. intialSize = 10
  12. 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函数为例，实现部门表的查找，每次都需要进行连接，查询，关闭，代码如下：

  1. public void find(){
  2. Connection conn = null;
  3. PreparedStatement pstmt = null;
  4. ResultSet rs = null;
  6. try {
  8. conn = DBUtils.getConnection();
  9. //事务开始
  10. conn.setAutoCommit(false);
  11. //业务逻辑
  16. conn.commit();
  18. } catch (Exception e) {
  19. try {
  20. conn.rollback();
  21. } catch (SQLException sqkex) {
  22. // TODO Auto-generated catch block
  23. sqkex.printStackTrace();
  24. }
  25. e.printStackTrace();
  26. }finally {
  27. try {
  28. conn.setAutoCommit(true);
  29. if(conn !=null) conn.close();
  30. } catch (SQLException e) {
  31. // TODO Auto-generated catch block
  32. e.printStackTrace();
  33. }
  35. }
  37. }
复制代码

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

BaseDAO的源代码：

  1. package DAO;
  3. import java.sql.Connection;
  4. import java.sql.PreparedStatement;
  5. import java.sql.ResultSet;
  6. import java.util.ArrayList;
  7. import java.util.List;
  8. import utils.DBUtils;
  10. public abstract class BaseDAO<T> {
  11. /*
  12. * 所有find方法的三大差别
  13. * 1:SQL语句不通
  14. * 2:？参数有几个不确定，类型不确定
  15. * 解决方法：类型不确定用：用object接住
  16. * 个数不确定用数组解决
  17. * Object[] params能接住所有的
  18. * 3:返回值对象不确定，解决 泛型类 */
  19. protected List<T> find(String sql,Object[] params)throws Exception{
  21. List<T> l = new ArrayList<T>();
  23. Connection conn = null;
  24. PreparedStatement pstmt = null;
  25. ResultSet rs = null;
  27. try {
  28. conn = DBUtils.getConnection();
  29. pstmt = conn.prepareStatement(sql);
  31. //问题1：不知道set什么，set几次
  32. //有Object[]params
  33. if(params!=null)
  34. for (int i = 0; i < params.length; i++) {
  35. pstmt.setObject(i+1, params[i]);
  36. }
  37. rs = pstmt.executeQuery();
  38. while(rs.next()){
  39. l.add(toEntity(rs));
  41. }
  43. return l;
  44. } catch (Exception ex) {
  45. throw ex;
  47. }finally {
  48. if(rs!= null) rs.close();
  49. if(pstmt != null) pstmt.close();
  51. DBUtils.closeConnection(conn);
  53. }
  54. }
  56. /*
  57. * 因为while中的对象属性差异无法统一
  58. * 完全交给子类自行完成
  59. * */
  60. public abstract T toEntity(ResultSet rs) throws Exception;
  62. }
  64. View Code
复制代码

在BaseDAO 中，面临的问题有三：

1：SQL语句的不同，

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

3：返回的对象不能确定

解决的方法分别是：

1：SQL语句不同，定义String sql变量

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

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

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

find 函数中的经典代码：

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

  1. //问题1：不知道set什么，set几次
  2. //有Object[]params
  3. if(params!=null)
  4. for (int i = 0; i < params.length; i++) {
  5. pstmt.setObject(i+1, params[i]);
  6. }
复制代码

2：返回结果：

  1. while(rs.next()){
  2. l.add(toEntity(rs));
  3. }
复制代码

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

public abstract T toEntity(ResultSet rs) throws Exception;

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

收藏 邀请
上一篇：方便操作Properties的Java类库：props4j下一篇：Java应用性能管理工具 Pinpoint

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-7-9 07:07

Copyright 2015-2025 djqfx

返回顶部