Spring 中的 JDBC

桃扇骨 2022-11-30 12:42 155阅读 0赞

## 1.1 简介 ##

JDBC(Java Data Base Connectivity)是一种用于执行 SQL 语句的 Java APl，可以为多种关系型数据库提供统一访问，它是由一组用 Java 语言编写的类和接口组成的。JDBC 提供了一种基准，据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序。但是，在 Java 企业级应用中，使用底层的 JDBC API 来编写程序还是显得过于烦琐，如需要编写很多的样板代码来打开和关闭数据库连接，需要处理很多的异常等。  
  针对上述问题，Spring JDBC 框架对底层的 JDBC API 进行了封装，负责所有的底层细节，包括如何开始打开连接、准备和执行 SQL 语句、处理异常、处理事务、最后关闭连接等。所以使用 Spring JDBC 框架，开发人员需要做的仅是定义连接参数、指定要执行的 SQL 语句，从而可以从烦琐的 JDBC API 中解放出来，专注于自己的业务。Spring 还为我们提供了 JdbcTemplate 模板用于操作关系型数据库。

## 1.2 JdbcTemplate ##

### 1.2.1 自己创建 JdbcTemplate 对象 ###

#### ☞ 相关依赖 ####

<dependency>
    	<groupId>mysql</groupId>
    	<artifactId>mysql-connector-java</artifactId>
    	<version>5.1.32</version>
    </dependency>
    
    <dependency>
    	<groupId>c3p0</groupId>
    	<artifactId>c3p0</artifactId>
    	<version>0.9.1.2</version>
    </dependency>
    <dependency>
    	<groupId>com.alibaba</groupId>
    	<artifactId>druid</artifactId>
    	<version>1.1.10</version>
    </dependency>
    
    <dependency>
    	<groupId>org.springframework</groupId>
    	<artifactId>spring-jdbc</artifactId>
    	<version>5.0.5.RELEASE</version>
    </dependency>

#### ☞ 使用 JdbcTemplate ####

@Test
    public void test() throws Exception { 
        // 创建数据源对象
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        dataSource.setDriverClass("com.mysql.jdbc.Driver");
        dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/test");
        dataSource.setUser("root");
        dataSource.setPassword("root");
    
        JdbcTemplate jdbcTemplate = new JdbcTemplate();
        // 设置数据源对象
        jdbcTemplate.setDataSource(dataSource);
        // 执行操作
        int row = jdbcTemplate.update("insert into account values(?,?)", "tom", 5000);
        System.out.println(row);
    }

### 1.2.2 Spring 创建 JdbcTemplate 对象 ###

#### ☞ 配置文件 ####

<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    	<property name="driverClass" value="com.mysql.jdbc.Driver"></property>
    	<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test"></property>
    	<property name="user" value="root"></property>
    	<property name="password" value="root"></property>
    </bean>
    
    
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    	<property name="dataSource" ref="dataSource"/>
    </bean>

#### ☞ 抽取数据库信息 ####

# 注意不要省略前缀直接写 username，可能会与系统名称冲突导致参数不正确
    jdbc.driver=com.mysql.jdbc.Driver
    jdbc.url=jdbc:mysql://localhost:3306/test
    jdbc.username=root
    jdbc.password=root

<context:property-placeholder location="classpath:jdbc.properties"/>
    
    
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc.driver}"/>
        <property name="jdbcUrl" value="${jdbc.url}"/>
        <property name="user" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>
    </bean>

#### ☞ 使用 JdbcTemplate ####

@Autowired
    private JdbcTemplate jdbcTemplate;
    
    @Test
    public void test() throws Exception { 
        // 执行操作
        int row = jdbcTemplate.update("insert into account values(?,?)", "tom", 5000);
        System.out.println(row);
    }

### 1.2.3 常用 API ###

`update()`：执行 DML 语句。增、删、改语句  
 `queryForMap()`：查询结果将结果集封装为 map 集合，将列名作为 key，将值作为 value 将这条记录封装为一个 map 集合。注意：这个方法查询的结果集长度只能是 1  
 `queryForList()`：查询结果将结果集封装为 list 集合。注意：将每一条记录封装为一个 Map 集合，再将 Map 集合装载到 List 集合中  
 `query()`：查询结果，将结果封装为 JavaBean 对象。参数：RowMapper，一般我们使用 BeanPropertyRowMapper 实现类。可以完成数据到 JavaBean 的自动封装 `new BeanPropertyRowMapper<T>(T.class)`  
 `queryForObject(sql，T.class)`：查询结果，将结果封装为对象。一般用于聚合函数的查询。  
 `queryForObject(sql,BeanPropertyRowMapper<T>(T.class))`：将一条记录封装为javabean

### 1.2.4 示例 ###

@RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration("classpath:application.xml")
    public class JdbcTemplateCRUDTest { 
    
        @Autowired
        private JdbcTemplate jdbcTemplate;
        
    	// 更新
        @Test
        public void testUpdate(){ 
            jdbcTemplate.update("update account set money = ? where name = ?", 10000, "tom");
        }
        
    	// 删除
        @Test
        public void testDelete(){ 
            jdbcTemplate.update("delete from account where name = ?","tom");
        }
        
    	// 聚合查询
        @Test
        public void testQueryCount(){ 
            Long count = jdbcTemplate.queryForObject("select count(*) from account", Long.class);
            System.out.println(count);
        }
        
    	// 封装为对象
        @Test
        public void testQueryOne(){ 
            Account account = jdbcTemplate.queryForObject("select * from account where name = ?", 
            									new BeanPropertyRowMapper<Account>(Account.class), "tom");
            System.out.println(account);
        }
        
    	// 封装为集合
        @Test
        public void testQueryAll(){ 
            List<Account> accountList = jdbcTemplate.query("select * from account", 
            									new BeanPropertyRowMapper<Account>(Account.class));
            System.out.println(accountList);
        }
    
    }