Spring JDBC入门

Posted 幸遥

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Spring JDBC入门相关的知识,希望对你有一定的参考价值。

1. Spring JDBC 模板

Spring 是EE的一站式开发框架,对持久层同样提供了支持:ORM模块和JDBC模板

Spring 提供了很多模板简化了开发

  • spring中提供了一个可以操作数据库的对象,对象封装了jdbc技术。
  • 与DBUtils中QueryRunner非常相似

2. JDBC模板的使用

基本使用方法
  1. 创建数据库

    mysql> show create table account;
    
    | Table   | Create Table| account | 
    CREATE TABLE `account` (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `name` char(10) DEFAULT NULL,
      `money` double DEFAULT NULL,
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8
    
  2. public class JDBCTemplateTest {
    	@Test
    	public void testadd(){
    		// 创建连接池
    		DriverManagerDataSource dataSource = new DriverManagerDataSource();
    		dataSource.setDriverClassName("com.mysql.jdbc.Driver");
    		dataSource.setUrl("jdbc:mysql://localhost:3306/spring");
    		dataSource.setUsername("cyp");
    		dataSource.setPassword("cyp");
    		
    		// 创建JDBC 模板
    		JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
    		jdbcTemplate.update("insert into account values(null,?,?)", "陈亚平",2000);
    		
    	}
    	
    }
    
  3. mysql> select *from account;
    +----+-----------+-------+
    | id | name      | money |
    +----+-----------+-------+
    |  1 | 陈亚平    |  2000 |
    +----+-----------+-------+
    1 row in set (0.00 sec)
    
整合Spring(spring管理dataSource和JdbcTemplate)
  1. Spring 配置文件配置

    <bean name="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    			<property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
    			<property name="url" value="jdbc:mysql://localhost:3306/spring"></property>
    			<property name="username" value="cyp"></property>
    			<property name="password" value="cyp"></property>
    </bean>
    <bean name="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    
  2. 测试类

    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration("classpath:applicationContext.xml")
    public class JDBCTemplateTestWithSpring {
    	@Resource(name="jdbcTemplate")
    	private JdbcTemplate jdbcTemplate;
    	
    	@Test
    	public void test1(){
    		jdbcTemplate.update("insert into account values(null,?,?)", "王红琳",2000);
    	}
    }
    
    
c3p0 连接池的使用
  1. 导入包

    c3p0.jar

  2. Spring中配置连接池

    <bean name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    			<property name="driverClass" value="com.mysql.jdbc.Driver"></property>
    			<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/spring"></property>
    			<property name="user" value="cyp"></property>
    			<property name="password" value="cyp"></property>
    		</bean>
    
  3. 显示结果

使用属性文件配置连接池
  1. 创建属性文件jdbc.properteis

    jdbc.driver=com.mysql.jdbc.Driver
    jdbc.url=jdbc:mysql://localhost:3306/spring
    jdbc.user=cyp
    jdbc.password=cyp
    
  2. 配置文件中配置属性文件

    <!-- 配置属性文件 -->
    <!-- 第一种方式:配置一个bean  ,较少使用 -->
    <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location" value="classpath:jdbc.properteis"/>		
     </bean> 
    <!-- 第二种方式  使用context 标签-->
    <context:property-placeholder location="classpath:jdbc.properteis"/><!-- 配置属性文件 -->
    
    
  3. 使用配置

    <!-- 使用c3p0 连接池-->
    <bean name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc.driver}"></property>
        <property name="jdbcUrl" value="${jdbc.url}"></property>
        <property name="user" value="${jdbc.user}"></property>
        <property name="password" value="${jdbc.password}"></property>
    </bean>
    

3. 模板的 CRUD操作

  1. 编写bean

    public class Account {
    	private int id;
    	private String name;
    	private double money;
    	public int getId() {
    		return id;
    	}
    	public void setId(int id) {
    		this.id = id;
    	}
    	public String getName() {
    		return name;
    	}
    	public void setName(String name) {
    		this.name = name;
    	}
    	public double getMoney() {
    		return money;
    	}
    	public void setMoney(double money) {
    		this.money = money;
    	}
    	@Override
    	public String toString() {
    		return "Account [id=" + id + ", name=" + name + ", money=" + money + "]";
    	}
    	
    	
    }
    
  2. 编写AccountDaoImpl实现类,实现基本操作

    public class AccountDaoImpl implements AccountDao{
    	
    	private JdbcTemplate jdbcTemplate;
    
    	public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
    		this.jdbcTemplate = jdbcTemplate;
    	}
    
    	@Override
    	public void add(Account account) {
    		
    		String sql = "insert into account values(null,?,?)";
    		jdbcTemplate.update(sql, account.getName(),account.getMoney());
    	}
    
    	@Override
    	public void delete(Integer id) {
    		
    		String sql = "delete from account where id = ?";
    		jdbcTemplate.update(sql, id);
    	}
    
    	@Override
    	public void update(Account account) {
    		String sql = "update account set name=? ,money=? where id=?";
    		jdbcTemplate.update(sql, account.getName(),account.getMoney(),account.getId());
    		
    	}
    
    	@Override
    	public Account find(Integer id) {
    		String sql = "select * from account where id = ?";
    		return jdbcTemplate.queryForObject(sql, new RowMapper<Account>(){
    			@Override
    			public Account mapRow(ResultSet rs, int arg1) throws SQLException {
    				Account account = new Account();
    				account.setId(rs.getInt("id"));
    				account.setName(rs.getString("name"));
    				account.setMoney(rs.getDouble("money"));
    				return account;
    			}
    		}, id);
    		
    	}
    
    	@Override
    	public int getTotalCount() {
    		String sql="select count(*) from account";
            Integer count = jdbcTemplate.queryForObject(sql, Integer.class);
            return count;
    		
    	}
    
    }
    
    
  3. 配置文件

    <context:property-placeholder location="classpath:jdbc.properteis"/>
    <!-- 使用c3p0 连接池-->
    <bean name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc.driver}"></property>
        <property name="jdbcUrl" value="${jdbc.url}"></property>
        <property name="user" value="${jdbc.user}"></property>
        <property name="password" value="${jdbc.password}"></property>
    </bean>
    
    <!-- 配置JdbcTemplate -->
    <bean name="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    
    <!-- 配置UserDao -->
    <bean name="accountDao" class="com.ranger.spring.jdbc.dao.impl.AccountDaoImpl">
        <property name="jdbcTemplate" ref="jdbcTemplate"></property>
    </bean>
    
  4. 编写测试类和测试方法

    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration("classpath:applicationContext.xml")
    public class AccountDaoTest {
    	@Resource(name="accountDao")
    	private AccountDao accountDao;
    	@Test
    	public void add(){
    		Account account = new Account();
    		account.setName("小风");
    		account.setMoney(2000);
    		accountDao.add(account);
    	} 
    	
    	@Test
    	public void delete(){
    		
    		accountDao.delete(2);
    	} 
    	
    	@Test
    	public void update(){
    		Account account = new Account();
    		account.setId(4);
    		account.setName("小王");
    		account.setMoney(2000);
    		accountDao.update(account);
    	}
    	
    	@Test
    	public void find(){
    		
    		Account account = accountDao.find(1);
    		System.out.println(account);
    	}
    	
    	@Test
    	public void getTotal(){
    		
    		int count = accountDao.getTotalCount();
    		System.out.println(count);
    	}
    }
    
    

以上是关于Spring JDBC入门的主要内容,如果未能解决你的问题,请参考以下文章

Spring Boot入门系列七(SpringBoot 使用JDBC连接Mysql数据库)

Spring入门— AOP注解jdbc模板事务

day39-Spring 12-Spring的JDBC模板:快速入门

mybatis快速入门-spring-mybatis整合

使用 JDBC 和 Spring 访问关系数据

Spring 事务入门