MySQL数据库学习笔记(十一)—-DAO设计方式完结数据库的增删改查(进一步封装JDBC工具类)

【声明】 

迎接转发,但请保留文章原来出处→_→ 

生命壹号:http://www.cnblogs.com/smyhvae/

小说来源:http://www.cnblogs.com/smyhvae/p/4059514.html

 

【正文】

一 、DAO形式简介

DAO即Data Access
Object,数据访问接口。数据访问:故名思义就是与数据库打交道。夹在作业逻辑与数据库财富中间。

DAO情势实际上是七个方式的构成,即Data Accessor (数据访问者)形式和 Active
Domain Object(领域对象)形式。Data Accessor
形式实现了数据访问和工作逻辑的诀别;Active Domain Object
方式完成了作业数据的对象化封装。

须求留意的是,DAO设计模式是Java EE中的设计格局,而非Java
SE中的23种设计情势。

 

二、实现DAO模式

三个独立的DAO落成有下列多少个零部件:

  • 一个DAO接口;
  • 三个落实DAO接口的切实可行类; 
  • 多少传递对象(DTO):有个别时候叫做值对象(VO)或世界模型(domain)

那种达成格局就是一个套路,记熟就好了。不过在那在此以前,如果有不精晓的地点,依旧要温故知新一下事先几篇博文中的知识:PreparedStatement接口重构增删改查、封装JDBC工具类。好了,上边直接上代码。

 

叁 、代码实现

咱俩一上边包车型客车那张数据表为例:

Java 1

新建Java工程文件DaoTest01,最终的工程文件结构如下:

Java 2

  • DBUtils:起先封装的JDBC工具类;
  • Java,db-config.properties:属性文件,方便修改配置消息;
  • Person类正是圈子模型,表示是对它(数据库表)实行增加和删除改查。
  • PersonDao接口:专门对Person类举行操作(例如增加和删除改查)的接口。注:那里不直接写操作类,是因为接口利于维护,能够在此处写上共用的代码。贰个领域模型对应一个Dao接口。
  • PeronDaoImpl类:实现地方的PeronDao接口

手续如下:

注:第(1)、(2)步操作和上一篇博文是一模一样的,那里只是为了确定保证本篇小说的完整性,所以重复写一下。

(1)先新建1个DBUtils工具类:(package
com.util.db)

 1 package com.util.db;
 2 
 3 import java.sql.Connection;
 4 import java.sql.DriverManager;
 5 import java.sql.ResultSet;
 6 import java.sql.SQLException;
 7 import java.sql.Statement;
 8 import java.util.ResourceBundle;
 9 
10 /**
11  * 数据库操作工具类
12  * @author lamp
13  *
14  */
15 public class DBUtils {
16     
17     //数据库连接地址
18     public static String URL;
19     //用户名
20     public static String USERNAME;
21     //密码
22     public static String PASSWORD;
23     //mysql的驱动类
24     public static String DRIVER;
25     
26     private static ResourceBundle rb = ResourceBundle.getBundle("com.util.db.db-config");
27     
28     private DBUtils(){}
29     
30     //使用静态块加载驱动程序
31     static{
32         URL = rb.getString("jdbc.url");
33         USERNAME = rb.getString("jdbc.username");
34         PASSWORD = rb.getString("jdbc.password");
35         DRIVER = rb.getString("jdbc.driver");
36         try {
37             Class.forName(DRIVER);
38         } catch (ClassNotFoundException e) {
39             e.printStackTrace();
40         }
41     }
42     //定义一个获取数据库连接的方法
43     public static Connection getConnection(){
44         Connection conn = null;
45         try {
46             conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
47         } catch (SQLException e) {
48             e.printStackTrace();
49             System.out.println("获取连接失败");
50         }
51         return conn;
52     }
53     
54     /**
55      * 关闭数据库连接
56      * @param rs
57      * @param stat
58      * @param conn
59      */
60     public static void close(ResultSet rs,Statement stat,Connection conn){
61             try {
62                 if(rs!=null)rs.close();
63                 if(stat!=null)stat.close();
64                 if(conn!=null)conn.close();
65             } catch (SQLException e) {
66                 e.printStackTrace();
67             }
68     }
69     
70 }

注意:26行中,小心获取属性文件的包名是不是正确。稍后会定义那个脾性文件。

28行:既然是工具类,一般不要实例化,此时得以采纳单例设计形式,恐怕将构造方法私有化。

26行:很明显能够看出,大家是将一而再数据库的U大切诺基L、用户名,密码等消息编写在贰特性能文件(jdbc.properties)中,稍后再来定义这几个性子文件。

31行:为防止双重代码,使用静态代码块:只会在类加载的时候实施3回。

42行:定义一个到手数据库连接的格局

60行:关闭数据库连接

(2)接下去新建2个性质文件,new–>file,命名为:db-config.properties,代码如下:

jdbc.url=jdbc:mysql://localhost:3306/jdbcdb
jdbc.username=root
jdbc.password=smyh
jdbc.driver=com.mysql.jdbc.Driver

其后只要供给修改配置音信,只须求在此地改就行了。注意在上头的DBUtils类中是怎么来调用那一个布局音信的。

接着新建文件,定义好Person类:(package com.vae.domain)

 1 package com.vae.domain;
 2 
 3 public class Person {
 4     private int id;
 5     private String name;
 6     private int age;
 7     private String description;
 8     public int getId() {
 9         return id;
10     }
11     public void setId(int id) {
12         this.id = id;
13     }
14     public String getName() {
15         return name;
16     }
17     public void setName(String name) {
18         this.name = name;
19     }
20     public int getAge() {
21         return age;
22     }
23     public void setAge(int age) {
24         this.age = age;
25     }
26     public String getDescription() {
27         return description;
28     }
29     public void setDescription(String description) {
30         this.description = description;
31     }
32     public Person(int id, String name, int age, String description) {
33         super();
34         this.id = id;
35         this.name = name;
36         this.age = age;
37         this.description = description;
38     }
39     public Person(String name, int age, String description) {
40         super();
41         this.name = name;
42         this.age = age;
43         this.description = description;
44     }
45     public Person() {
46         super();
47         // TODO Auto-generated constructor stub
48     }
49     @Override
50     public String toString() {
51         return "Person [id=" + id + ", name=" + name + ", age=" + age
52                 + ", description=" + description + "]";
53     }
54     
55     
56 }

本条Person类便是小圈子模型,表示是对它进行增删改查。

(3)定义PersonDao接口:专门对Person类实行操作(例如增加和删除改查)的接口(package
com.vae.dao)

package com.vae.dao;

import java.sql.SQLException;
import java.util.List;

import com.vae.domain.Person;

public interface PersonDao {
    //添加方法
    public void add(Person p)throws SQLException;

    //更新方法
    public void update(Person p)throws SQLException;

    //删除方法
    public void delete(int id)throws SQLException;

    //查找方法
    public Person findById(int id)throws SQLException;

    //查找所有
    public List<Person> findAll()throws SQLException;

} 

(4)定义PeronDaoImpl实现类
,达成地点的PeronDao接口(package com.vae.dao.impl)

  1 package com.vae.dao.impl;
  2 
  3 import java.sql.Connection;
  4 import java.sql.PreparedStatement;
  5 import java.sql.ResultSet;
  6 import java.sql.SQLException;
  7 import java.util.ArrayList;
  8 import java.util.List;
  9 
 10 import com.util.db.DBUtils;
 11 import com.vae.dao.PersonDao;
 12 import com.vae.domain.Person;
 13 
 14 /**
 15  * PersonDao的具体实现类
 16  * @author lamp
 17  *
 18  */
 19 public class PersonDaoImpl implements PersonDao{
 20 
 21     /**
 22      * 实现添加方法
 23      */
 24     @Override
 25     public void add(Person p) throws SQLException {
 26         Connection conn = null;
 27         PreparedStatement ps = null;
 28         String sql = "insert into person(name,age,description)values(?,?,?)";
 29         try{
 30             conn = DBUtils.getConnection();
 31             ps = conn.prepareStatement(sql);
 32             ps.setString(1, p.getName());
 33             ps.setInt(2, p.getAge());
 34             ps.setString(3, p.getDescription());
 35             ps.executeUpdate();
 36         }catch(SQLException e){
 37             e.printStackTrace();
 38             throw new SQLException("添加数据失败");
 39         }finally{
 40             DBUtils.close(null, ps, conn);
 41         }
 42     }
 43 
 44     /**
 45      * 更新方法
 46      */
 47     @Override
 48     public void update(Person p) throws SQLException {
 49         Connection conn = null;
 50         PreparedStatement ps = null;
 51         String sql = "update person set name=?,age=?,description=? where id=?";
 52         try{
 53             conn = DBUtils.getConnection();
 54             ps = conn.prepareStatement(sql);
 55             ps.setString(1, p.getName());
 56             ps.setInt(2, p.getAge());
 57             ps.setString(3, p.getDescription());
 58             ps.setInt(4, p.getId());
 59             ps.executeUpdate();
 60         }catch(SQLException e){
 61             e.printStackTrace();
 62             throw new SQLException("更新数据失败");
 63         }finally{
 64             DBUtils.close(null, ps, conn);
 65         }        
 66     }
 67 
 68     /**
 69      * 删除方法
 70      */
 71     @Override
 72     public void delete(int id) throws SQLException {
 73         Connection conn = null;
 74         PreparedStatement ps = null;
 75         String sql = "delete from person where id=?";
 76         try{
 77             conn = DBUtils.getConnection();
 78             ps = conn.prepareStatement(sql);
 79             ps.setInt(1,id);
 80             ps.executeUpdate();
 81         }catch(SQLException e){
 82             e.printStackTrace();
 83             throw new SQLException(" 删除数据失败");
 84         }finally{
 85             DBUtils.close(null, ps, conn);
 86         }        
 87     }
 88 
 89     /**
 90      * 根据ID查询一个对象
 91      */
 92     @Override
 93     public Person findById(int id) throws SQLException {
 94         Connection conn = null;
 95         PreparedStatement ps = null;
 96         ResultSet rs = null;
 97         Person p = null;
 98         String sql = "select name,age,description from person where id=?";
 99         try{
100             conn = DBUtils.getConnection();
101             ps = conn.prepareStatement(sql);
102             ps.setInt(1, id);
103             rs = ps.executeQuery();
104             if(rs.next()){
105                 p = new Person();
106                 p.setId(id);
107                 p.setName(rs.getString(1));
108                 p.setAge(rs.getInt(2));
109                 p.setDescription(rs.getString(3));
110             }
111         }catch(SQLException e){
112             e.printStackTrace();
113             throw new SQLException("根据ID查询数据失败");
114         }finally{
115             DBUtils.close(rs, ps, conn);
116         }
117         return p;
118     }
119 
120     /**
121      * 查询所有数据
122      */
123     @Override
124     public List<Person> findAll() throws SQLException {
125         Connection conn = null;
126         PreparedStatement ps = null;
127         ResultSet rs = null;
128         Person p = null;
129         List<Person> persons = new ArrayList<Person>();
130         String sql = "select id,name,age,description from person";
131         try{
132             conn = DBUtils.getConnection();
133             ps = conn.prepareStatement(sql);
134             rs = ps.executeQuery();
135             while(rs.next()){
136                 p = new Person();
137                 p.setId(rs.getInt(1));
138                 p.setName(rs.getString(2));
139                 p.setAge(rs.getInt(3));
140                 p.setDescription(rs.getString(4));
141                 persons.add(p);
142             }
143         }catch(SQLException e){
144             e.printStackTrace();
145             throw new SQLException("查询所有数据失败");
146         }finally{
147             DBUtils.close(rs, ps, conn);
148         }
149         return persons;
150     }
151 
152 }

咱俩在各自的增加和删除改查里都抛出了万分,要是出现万分,就会抛出相应的错误音信。

计算:那样的话,大家就封装好了JDBC的工具类。今后只要要用的话,能够直接在主方法里调用那个类就行了。

【工程文件】

链接:http://pan.baidu.com/s/1qW6tew8

密码:t98s

相关文章