当前位置:   article > 正文

【Spring】对持久层技术的整合

spring持久层技术

一、持久层技术

  1. Spring 中自带的 JdbcTemplate
  2. Hibernate
  3. Mybatis

二、JdbcTemplate

开发步骤:

1. 导入相关的jar包
  1. <!-- https://mvnrepository.com/artifact/org.springframework/spring-jdbc -->
  2. <dependency>
  3. <groupId>org.springframework</groupId>
  4. <artifactId>spring-jdbc</artifactId>
  5. <version>5.1.5.RELEASE</version>
  6. </dependency>
  7. <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
  8. <dependency>
  9. <groupId>mysql</groupId>
  10. <artifactId>mysql-connector-java</artifactId>
  11. <version>8.0.13</version>
  12. </dependency>
2. 配置连接池(数据源)

  创建一个数据库test

  • Spring默认的连接池:
  1. <!-- 配置Spring默认的连接池 -->
  2. <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
  3. <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  4. <property name="url" value="jdbc:mysql://localhost:3306/test"/>
  5. <property name="username" value="root"/>
  6. <property name="password" value="123"/>
  7. </bean>
  • DBCP连接池:

  引入Maven 坐标:

  1. <!-- https://mvnrepository.com/artifact/commons-dbcp/commons-dbcp -->
  2. <dependency>
  3. <groupId>commons-dbcp</groupId>
  4. <artifactId>commons-dbcp</artifactId>
  5. <version>1.4</version>
  6. </dependency>

  配置信息:

  1. <!-- 配置DBCP连接池 -->
  2. <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
  3. <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  4. <property name="url" value="jdbc:mysql:///test"/>
  5. <property name="username" value="root"/>
  6. <property name="password" value="123"/>
  7. </bean>
  • C3P0连接池:

  引入Maven 坐标:

  1. <!-- https://mvnrepository.com/artifact/c3p0/c3p0 -->
  2. <dependency>
  3. <groupId>c3p0</groupId>
  4. <artifactId>c3p0</artifactId>
  5. <version>0.9.1.2</version>
  6. </dependency>

  配置信息:

  1. <!-- 配置c3p0连接池 -->
  2. <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  3. <property name="driverClass" value="com.mysql.jdbc.Driver"/>
  4. <property name="jdbcUrl" value="jdbc:mysql:///test"/>
  5. <property name="user" value="root"/>
  6. <property name="password" value="123"/>
  7. </bean>
将参数设置到属性文件中:

属性文件jdbc.properties

  1. jdbc.driver = com.mysql.jdbc.Driver
  2. jdbc.url = jdbc:mysql:///test
  3. jdbc.user = root
  4. jdbc.password = 123

需要在applicationContext.xml 中使用属性文件配置的内容.

  • 第一种写法:
  1. <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
  2. <property name="location" value="classpath:jdbc.properties"></property>
  3. </bean>
  • 第二种写法:

  需要引入context的命名空间:

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:context="http://www.springframework.org/schema/context"
  5. xsi:schemaLocation="
  6. http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
  7. http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

  配置如下:

<context:property-placeholder location="classpath:jdbc.properties"/>

  上面数据源的配置,属性的值就可以用${}来取出properties配置文件中的值

  1. <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  2. <property name="driverClass" value="${jdbc.driver}"/>
  3. <property name="jdbcUrl" value="${jdbc.url}"/>
  4. <property name="user" value="${jdbc.user}"/>
  5. <property name="password" value="${jdbc.password}"/>
  6. </bean>
3. 创建表

这里要注意的是创建的表名不能用users,

  1. CREATE TABLE `member` (
  2. `id` int(11) NOT NULL AUTO_INCREMENT,
  3. `name` varchar(20) DEFAULT NULL,
  4. `age` int(11) DEFAULT NULL,
  5. PRIMARY KEY (`id`)
  6. ) ENGINE=InnoDB
4. 编写实体类
  1. public class Member {
  2. private Integer id;
  3. private String name;
  4. private Integer age;
  5. public Integer getId() {
  6. return id;
  7. }
  8. public void setId(Integer id) {
  9. this.id = id;
  10. }
  11. public String getName() {
  12. return name;
  13. }
  14. public void setName(String name) {
  15. this.name = name;
  16. }
  17. public Integer getAge() {
  18. return age;
  19. }
  20. public void setAge(Integer age) {
  21. this.age = age;
  22. }
  23. @Override
  24. public String toString() {
  25. return "Member [id=" + id + ", name=" + name + ", age=" + age + "]";
  26. }
  27. }
5. Dao层实现
5.1 继承JdbcDaoSupport

Spring框架中提供了对持久层技术支持的类: JdbcDaoSupport,这个类中依赖了JdbcTemplte模版而且自己实现了setter方法

  编写DAO的时候要继承该类,如下:

  1. import java.sql.ResultSet;
  2. import java.sql.SQLException;
  3. import java.util.List;
  4. import org.springframework.jdbc.core.RowMapper;
  5. import org.springframework.jdbc.core.support.JdbcDaoSupport;
  6. import com.hao.entity.Member;
  7. public class MemberDao extends JdbcDaoSupport {
  8. /**
  9. * 添加用户
  10. *
  11. * @param member
  12. */
  13. public void add(Member member) {
  14. String sql = "insert into member values(null,?,?)";
  15. this.getJdbcTemplate().update(sql, member.getName(), member.getAge());
  16. }
  17. /**
  18. * 根据id更新用户名
  19. *
  20. * @param member
  21. */
  22. public void updateById(Member member) {
  23. String sql = "update member set name = ? where id =?";
  24. this.getJdbcTemplate().update(sql, member.getName(), member.getId());
  25. }
  26. /**
  27. * 根据id删除用户
  28. *
  29. * @param member
  30. */
  31. public void deleteById(Member member) {
  32. String sql = "delete from member where id = ? ";
  33. this.getJdbcTemplate().update(sql, member.getId());
  34. }
  35. /**
  36. * 查询用户总数
  37. *
  38. * @return
  39. */
  40. public int findCount() {
  41. String sql = "select count(*) from member";
  42. // spring 3.2之后的版本不在支持queryInt(sql);
  43. return this.getJdbcTemplate().queryForObject(sql, int.class);
  44. }
  45. /**
  46. * 通过id查询用户名
  47. *
  48. * @param id
  49. * @return
  50. */
  51. public String findNameById(int id) {
  52. String sql = "select name from member where id = ?";
  53. return this.getJdbcTemplate().queryForObject(sql, String.class, id);
  54. }
  55. /**
  56. * 根据id查询用户
  57. *
  58. * @param id
  59. * @return
  60. */
  61. public Member findById(int id) {
  62. String sql = "select * from member where id = ?";
  63. Member member = this.getJdbcTemplate().queryForObject(sql, new UserRowMapper(), id);
  64. return member;
  65. }
  66. /**
  67. * 查询所有用户
  68. *
  69. * @return
  70. */
  71. public List<Member> findAll() {
  72. String sql = "select * from member";
  73. return this.getJdbcTemplate().query(sql, new UserRowMapper());
  74. }
  75. class UserRowMapper implements RowMapper<Member> {
  76. /**
  77. * rs:结果集. rowNum:行号
  78. */
  79. public Member mapRow(ResultSet rs, int rowNum) throws SQLException {
  80. Member member = new Member();
  81. member.setId(rs.getInt("id"));
  82. member.setName(rs.getString("name"));
  83. return member;
  84. }
  85. }
  86. }

  在XML中的配置,此种方式不需要再XML中声明jdbcTemplate ,只需要在Dao层注入数据源即可如下:

  1. <context:property-placeholder location="classpath:jdbc.properties"/>
  2. <!-- 配置c3p0连接池 -->
  3. <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  4. <property name="driverClass" value="${jdbc.driver}"/>
  5. <property name="jdbcUrl" value="${jdbc.url}"/>
  6. <property name="user" value="${jdbc.user}"/>
  7. <property name="password" value="${jdbc.password}"/>
  8. </bean>
  9. <!-- 此处直接注入数据源,因为Dao层中继承了JdbcDaoSupport这个类 -->
  10. <bean id="memberDao" class="com.hao.dao.MemberDao">
  11. <property name="dataSource" ref="dataSource"></property>
  12. </bean>
5.2 直接注入JdbcTmplate
  1. public class MemberDaoForNoExtend {
  2. //利用setter的方法注入jdbcTmplate
  3. private JdbcTemplate jdbcTemplate;
  4. public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
  5. this.jdbcTemplate = jdbcTemplate;
  6. }
  7. /**
  8. * 添加用户
  9. *
  10. * @param member
  11. */
  12. public void add(Member member) {
  13. String sql = "insert into member values(null,?,?)";
  14. jdbcTemplate.update(sql, member.getName(), member.getAge());
  15. }
  16. // 后面的代码省略...
  17. }

  在XML中的配置,此种方式要在Dao层注入jdbcTemplate

  1. <!-- 定义jdbctemplate 需要注入数据源 -->
  2. <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
  3. <property name="dataSource" ref="dataSource"/>
  4. </bean>
  5. <!-- 定义Dao层类 需要注入jdbcTemplate-->
  6. <bean id="memberDao" class="com.hao.dao.MemberDao">
  7. <property name="jdbcTemplate" ref="jdbcTemplate"></property>
  8. </bean>
6. 测试

  测试1 --> 5.1中的方式测试

  1. import org.junit.Test;
  2. import org.junit.runner.RunWith;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.beans.factory.annotation.Qualifier;
  5. import org.springframework.test.context.ContextConfiguration;
  6. import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
  7. import com.hao.dao.MemberDao;
  8. import com.hao.entity.Member;
  9. @RunWith(SpringJUnit4ClassRunner.class)
  10. @ContextConfiguration("classpath:applicationContext1.xml")
  11. public class JDBCTest1 {
  12. @Autowired
  13. @Qualifier("memberDao")
  14. private MemberDao memberDao;
  15. @Test
  16. public void test1() {
  17. Member member = new Member();
  18. member.setName("小涛");
  19. member.setAge(23);
  20. memberDao.add(member);
  21. }
  22. @Test
  23. public void test2() {
  24. int findCount = memberDao.findCount();
  25. System.out.println(findCount);
  26. }
  27. @Test
  28. public void test3() {
  29. Member member = new Member();
  30. member.setId(12);
  31. memberDao.deleteById(member);
  32. }
  33. }

  测试2 --> 5.2中的方式测试

  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. @ContextConfiguration("classpath:applicationContext2.xml")
  3. public class JDBCTest2 {
  4. @Autowired
  5. @Qualifier("memberDaoForNoExtend")
  6. private MemberDaoForNoExtend memberDaoForNoExtend;
  7. @Test
  8. public void test1() {
  9. Member member = new Member();
  10. member.setName("小明");
  11. member.setAge(23);
  12. memberDaoForNoExtend.add(member);
  13. }
  14. }

JdbcTemplate 的CRUD(待整理)

  • 保存:update(String sql,Object... args)
  • 修改:update(String sql,Object... args)
  • 删除:update(String sql,Object... args)
  • 查询:
    • 简单查询:
      • queryForObject(String sql,Class clazz,Object... args);
    • 复杂查询:(返回对象,和对象集合)
      • queryForObjectString sql,RowMapper<T> rowMapper,Object... args);
      • query(String sql,RowMapper<T> rowMapper,Object... args);

三、Hibernate

org.springframework.orm.hibernate3.support.HibernateDaoSupport

四、MyBatis

org.springframework.orm.ibatis.support.SqlMapClientDaoSupport

转载于:https://www.cnblogs.com/haoworld/p/spring-dui-chi-jiu-ceng-ji-shu-de-zheng-he.html

声明:本文内容由网友自发贡献,转载请注明出处:【wpsshop】
推荐阅读
相关标签
  

闽ICP备14008679号