服务器之家

服务器之家 > 正文

Java的Spring框架中DAO数据访问对象的使用示例

时间:2020-04-07 11:50     来源/作者:leizhimin

Spring DAO之JDBC
 
Spring提供的DAO(数据访问对象)支持主要的目的是便于以标准的方式使用不同的数据访问技术, 如JDBC,Hibernate或者JDO等。它不仅可以让你方便地在这些持久化技术间切换, 而且让你在编码的时候不用考虑处理各种技术中特定的异常。
为了便于以一种一致的方式使用各种数据访问技术,如JDBC、JDO和Hibernate, Spring提供了一套抽象DAO类供你扩展。这些抽象类提供了一些方法,通过它们你可以 获得与你当前使用的数据访问技术相关的数据源和其他配置信息。
Dao支持类:
JdbcDaoSupport - JDBC数据访问对象的基类。 需要一个DataSource,同时为子类提供 JdbcTemplate。
HibernateDaoSupport - Hibernate数据访问对象的基类。 需要一个SessionFactory,同时为子类提供 HibernateTemplate。也可以选择直接通过 提供一个HibernateTemplate来初始化, 这样就可以重用后者的设置,例如SessionFactory, flush模式,异常翻译器(exception translator)等等。
JdoDaoSupport - JDO数据访问对象的基类。 需要设置一个PersistenceManagerFactory, 同时为子类提供JdoTemplate。 
JpaDaoSupport - JPA数据访问对象的基类。 需要一个EntityManagerFactory,同时 为子类提供JpaTemplate。 
本节主要讨论Sping对JdbcDaoSupport的支持。
下面是个例子:

?
1
2
3
4
5
6
7
8
9
10
11
12
drop table if exists user;
 
/*==============================================================*/
/* Table: user                         */
/*==============================================================*/
create table user
(
  id          bigint AUTO_INCREMENT not null,
  name         varchar(24),
  age         int,
  primary key (id)
);

 

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
public class User {
  private Integer id;
  private String name;
  private Integer age;
 
  public Integer getId() {
    return id;
  }
 
  public void setId(Integer id) {
    this.id = id;
  }
 
  public String getName() {
    return name;
  }
 
  public void setName(String name) {
    this.name = name;
  }
 
  public Integer getAge() {
    return age;
  }
 
  public void setAge(Integer age) {
    this.age = age;
  }
}

 

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
/**
* Created by IntelliJ IDEA.<br>
* <b>User</b>: leizhimin<br>
* <b>Date</b>: 2008-4-22 15:34:36<br>
* <b>Note</b>: DAO接口
*/
public interface IUserDAO {
  public void insert(User user);
 
  public User find(Integer id);
}
 
 
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
 
/**
* Created by IntelliJ IDEA.<br>
* <b>Note</b>: 基类DAO,提供了数据源注入
*/
public class BaseDAO {
  private DataSource dataSource;
 
  public DataSource getDataSource() {
    return dataSource;
  }
 
  public void setDataSource(DataSource dataSource) {
    this.dataSource = dataSource;
  }
 
  public Connection getConnection() {
    Connection conn = null;
    try {
      conn = dataSource.getConnection();
    } catch (SQLException e) {
      e.printStackTrace();
    }
    return conn;
  }
}
 
 
/**
* Created by IntelliJ IDEA.<br>
* <b>User</b>: leizhimin<br>
* <b>Date</b>: 2008-4-22 15:36:04<br>
* <b>Note</b>: DAO实现
*/
public class UserDAO extends BaseDAO implements IUserDAO {
 
  public JdbcTemplate getJdbcTemplate(){
    return new JdbcTemplate(getDataSource());
  }
  public void insert(User user) {
    String name = user.getName();
    int age = user.getAge().intValue();
 
//    jdbcTemplate.update("INSERT INTO user (name,age) "
//        + "VALUES('" + name + "'," + age + ")");
 
    String sql = "insert into user(name,age) values(?,?)";
    getJdbcTemplate().update(sql,new Object[]{name,age});
  }
 
  public User find(Integer id) {
    List rows = getJdbcTemplate().queryForList(
        "SELECT * FROM user WHERE id=" + id.intValue());
 
    Iterator it = rows.iterator();
    if (it.hasNext()) {
      Map userMap = (Map) it.next();
      Integer i = new Integer(userMap.get("id").toString());
      String name = userMap.get("name").toString();
      Integer age = new Integer(userMap.get("age").toString());
 
      User user = new User();
 
      user.setId(i);
      user.setName(name);
      user.setAge(age);
 
      return user;
    }
    return null;
  }
}

 

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING/DTD BEAN/EN"
    "http://www.springframework.org/dtd/spring-beans.dtd">
 
<beans>
  <bean id="dataSource"
     class="org.apache.commons.dbcp.BasicDataSource" singleton="true">
    <property name="driverClassName">
      <value>com.mysql.jdbc.Driver</value>
    </property>
    <property name="url">
      <value>jdbc:mysql://localhost:3306/springdb</value>
    </property>
    <property name="username">
      <value>root</value>
    </property>
    <property name="password">
      <value>leizhimin</value>
    </property>
  </bean>
 
  <bean id="baseDAO" class="com.lavasoft.springnote.ch05_jdbc03_temp.BaseDAO" abstract="true">
    <property name="dataSource">
      <ref bean="dataSource"/>
    </property>
  </bean>
 
  <bean id="userDAO"
     class="com.lavasoft.springnote.ch05_jdbc03_temp.UserDAO" parent="baseDAO">
  </bean>
 
</beans>

 

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;
 
/**
* Created by IntelliJ IDEA.<br>
* <b>User</b>: leizhimin<br>
* <b>Date</b>: 2008-4-22 15:59:18<br>
* <b>Note</b>: 测试类,客户端
*/
public class SpringDAODemo {
  public static void main(String[] args) {
    ApplicationContext context = new FileSystemXmlApplicationContext("D:\\_spring\\src\\com\\lavasoft\\springnote\\ch05_jdbc03_temp\\bean-jdbc-temp.xml");
    User user = new User();
    user.setName("hahhahah");
    user.setAge(new Integer(22));
    IUserDAO userDAO = (IUserDAO) context.getBean("userDAO");
    userDAO.insert(user);
    user = userDAO.find(new Integer(1));
    System.out.println("name: " + user.getName());
  }
}

 
运行结果:

?
1
2
3
4
5
log4j:WARN No appenders could be found for logger (org.springframework.core.CollectionFactory).
log4j:WARN Please initialize the log4j system properly.
name: jdbctemplate
 
Process finished with exit code 0

 

Spring DAO之Hibernate
 
HibernateDaoSupport - Hibernate数据访问对象的基类。 需要一个SessionFactory,同时为子类提供 HibernateTemplate。也可以选择直接通过 提供一个HibernateTemplate来初始化, 这样就可以重用后者的设置,例如SessionFactory, flush模式,异常翻译器(exception translator)等等。

本节主要讨论Sping对HibernateTemplate的支持。

下面是个例子:
 

?
1
2
3
4
5
6
7
8
9
10
11
12
drop table if exists user;
 
/*==============================================================*/
/* Table: user                         */
/*==============================================================*/
create table user
(
  id          bigint AUTO_INCREMENT not null,
  name         varchar(24),
  age         int,
  primary key (id)
);

 

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
/**
* Created by IntelliJ IDEA.<br>
* <b>Note</b>: Hiberante实体类
*/
public class User {
  private Integer id;
  private String name;
  private Integer age;
 
  public Integer getId() {
    return id;
  }
 
  public void setId(Integer id) {
    this.id = id;
  }
 
  public String getName() {
    return name;
  }
 
  public void setName(String name) {
    this.name = name;
  }
 
  public Integer getAge() {
    return age;
  }
 
  public void setAge(Integer age) {
    this.age = age;
  }
}

 

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-mapping
  PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
  "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
 
<hibernate-mapping>
 
  <class name="com.lavasoft.springnote.ch06_hbm_02deTx.User"
      table="user">
 
    <id name="id" column="id">
      <generator class="native"/>
    </id>
 
    <property name="name" column="name"/>
 
    <property name="age" column="age"/>
 
  </class>
 
</hibernate-mapping>

 

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
/**
* Created by IntelliJ IDEA.<br>
* <b>User</b>: leizhimin<br>
* <b>Date</b>: 2008-4-23 15:37:43<br>
* <b>Note</b>: DAO接口
*/
public interface IUserDAO {
  public void insert(User user);
  public User find(Integer id);
}
 
import org.hibernate.SessionFactory;
import org.springframework.orm.hibernate3.HibernateTemplate;
 
/**
* Created by IntelliJ IDEA.<br>
* <b>User</b>: leizhimin<br>
* <b>Date</b>: 2008-4-23 15:15:55<br>
* <b>Note</b>: DAO实现
*/
public class UserDAO implements IUserDAO {
  private HibernateTemplate hibernateTemplate;
 
  public void setSessionFactory(SessionFactory sessionFactory) {
    this.hibernateTemplate =new HibernateTemplate(sessionFactory);
  }
 
  public void insert(User user) {
    hibernateTemplate.save(user);
    System.out.println("所保存的User对象的ID:"+user.getId());
  }
 
  public User find(Integer id) {
    User user =(User) hibernateTemplate.get(User.class, id);
    return user;
  }
}

 

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING/DTD BEAN/EN"
"http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
  <bean id="dataSource"
     class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName">
      <value>com.mysql.jdbc.Driver</value>
    </property>
    <property name="url">
      <value>jdbc:mysql://localhost:3306/springdb</value>
    </property>
    <property name="username">
      <value>root</value>
    </property>
    <property name="password">
      <value>leizhimin</value>
    </property>
  </bean>
 
  <bean id="sessionFactory"
     class="org.springframework.orm.hibernate3.LocalSessionFactoryBean"
     destroy-method="close">
    <property name="dataSource">
      <ref bean="dataSource"/>
    </property>
    <property name="mappingResources">
      <list>
        <value>com/lavasoft/springnote/ch06_hbm_02proTx/User.hbm.xml</value>
      </list>
    </property>
    <property name="hibernateProperties">
      <props>
        <prop key="hibernate.dialect">
          org.hibernate.dialect.MySQLDialect
        </prop>
      </props>
    </property>
  </bean>
 
 
  <bean id="userDAO" class="com.lavasoft.springnote.ch06_hbm_02proTx.UserDAO">
    <property name="sessionFactory">
      <ref bean="sessionFactory"/>
    </property>
  </bean>
</beans>

 

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;
 
/**
* Created by IntelliJ IDEA.<br>
* <b>Note</b>: 测试类、客户端
*/
public class SpringHibernateDemo {
  public static void main(String[] args) {
    ApplicationContext context =new FileSystemXmlApplicationContext("D:\\_spring\\src\\com\\lavasoft\\springnote\\ch06_hbm_02proTx\\bean-hbm_tx.xml");
 
    // 建立DAO物件
    IUserDAO userDAO = (IUserDAO) context.getBean("userDAO");
 
    User user = new User();
    user.setName("caterpillar");
    user.setAge(new Integer(30));
 
    userDAO.insert(user);
 
    user = userDAO.find(new Integer(1));
 
    System.out.println("name: " + user.getName());
  }
}

 
运行结果:

?
1
2
3
4
5
6
log4j:WARN No appenders could be found for logger (org.springframework.core.CollectionFactory).
log4j:WARN Please initialize the log4j system properly.
所保存的User对象的ID:18
name: jdbctemplate
 
Process finished with exit code 0

 

标签:

相关文章

热门资讯

沙雕群名称大全2019精选 今年最火的微信群名沙雕有创意
沙雕群名称大全2019精选 今年最火的微信群名沙雕有创意 2019-07-07
玄元剑仙肉身有什么用 玄元剑仙肉身境界等级划分
玄元剑仙肉身有什么用 玄元剑仙肉身境界等级划分 2019-06-21
男生常说24816是什么意思?女生说13579是什么意思?
男生常说24816是什么意思?女生说13579是什么意思? 2019-09-17
超A是什么意思 你好a表达的是什么
超A是什么意思 你好a表达的是什么 2019-06-06
华为nova5pro和p30pro哪个好 华为nova5pro和华为p30pro对比详情
华为nova5pro和p30pro哪个好 华为nova5pro和华为p30pro对比详情 2019-06-22
返回顶部