Java：Spring 数据库操作_spring操作数据库

---

Spring 集成 JDBC

Spring 提供了一个工具类 JdbcTemple，该类对 JDBC 的操作进行了轻量级别的封装。

JdbcTemple 简介：
封装了操作数据库的各种方法，该类包含一个 DataSource 属性（数据源），只有在初始化数据源的情况下才能调用 JdbcTemple。

步骤：

1. 导入集成包、连接池包；
2. 初始化连接池数据源对象；
3. 初始化 JdbcTemple 对象；
4. 调用 JdbcTemple 的 API 接口完成数据库操作。

优点：

• 直接使用 SQL 语句操作数据库，效率很高；
• 支持数据库的分区，这是数据量大的项目的实现方案，Hibernate无法实现；
• 使用 Java 语言拼 SQL 语句，效率很高，这是 ibatis 无法达到的。

缺点：

• SQL 语句直接写在 Java 程序中，很难管理，但部分企业进行了封装，实现了 SQL 语句的简单管理；
• 编码量大。

---

初始化连接池数据源对象

第一种方式：不采用配置文件配置，纯java代码连接：

import com.mchange.v2.c3p0.ComboPooledDataSource;
import java.sql.Connection;
public class TestCombo{
    private ComboPooledDataSource dataSource;
    private TestCombo() {
        try {
            dataSource = new ComboPooledDataSource();
            dataSource.setUser(root);
            dataSource.setPassword(123456);
            dataSource.setJdbcUrl(jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf-8");
            dataSource.setDriverClass(com.mysql.jdbc.Driver);
            dataSource.setInitialPoolSize();
            dataSource.setAcquireIncrement();
            dataSource.setMinPoolSize();
            dataSource.setMaxPoolSize();
            dataSource.setMaxStatements();
            dataSource.setMaxIdleTime();
            dataSource.setIdleConnectionTestPeriod();
            dataSource.setAcquireRetryAttempts();

        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
    public Connection getConnection() {
        try {
            return dataSource.getConnection();
        } catch (Exception e) {
            throw new RuntimeException("can not get sms database connection  ", e);
        }
    }
}
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

第二种方式（配置文件）：c3p0-config.xml

<c3p0-config>
    <!-- 默认配置，如果没有指定则使用这个配置 -->
    <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">
            <![CDATA[jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8]]>
        </property>
        <property name="user">root</property>
        <property name="password">1234</property>
        <!-- 初始化池大小 -->
        <property name="initialPoolSize">2</property>
        <!-- 最大空闲时间 -->
        <property name="maxIdleTime">30</property>
        <!-- 最多有多少个连接 -->
        <property name="maxPoolSize">10</property>
        <!-- 最少几个连接 -->
        <property name="minPoolSize">2</property>
        <!-- 每次最多可以执行多少个批处理语句 -->
        <property name="maxStatements">50</property>
    </default-config>
    <!-- 命名的配置 -->
    <named-config name="demo">
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">
            <![CDATA[jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8]]>
        </property>
        <property name="user">root</property>
        <property name="password">1234</property>
        <property name="acquireIncrement">5</property>
        <!-- 如果池中数据连接不够时一次增长多少个 -->
        <property name="initialPoolSize">100</property>
        <property name="minPoolSize">50</property>
        <property name="maxPoolSize">1000</property>
        <property name="maxStatements">0</property>
        <property name="maxStatementsPerConnection">5</property>
        <!-- he's important, but there's only one of him -->
    </named-config>
</c3p0-config> 
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

代码中获取实例

ComboPooledDataSource pool = new ComboPooledDataSource();
// 空参，自动到classpath目录下面加载“c3p0-config.xml”配置文件---配置文件的存储位置和名称必须是这样，且使用“默认配置”。
1
2

---

JdbcTemple 常用 API 接口

execute 方法：可以用于执行任何SQL语句

Object execute(CallableStatementCreator csc, CallableStatementCallback action)
// 执行JDBC数据访问操作，实现为处理JDBC CallableStatement的回调操作。
1
2

query 方法及 queryForXXX 方法：用于执行查询相关语句

// 使用预准备语句进行查询，允许PreparedStatementCreator和PreparedStatementSetter。
Object query(PreparedStatementCreator psc, PreparedStatementSetter pss, ResultSetExtractor rse)
1
2

// 给定静态SQL，执行导致int值的查询。
int queryForInt(String sql) 
// 给定静态SQL，执行结果列表的查询。
List queryForList(String sql) 
// 给定静态SQL，执行导致long值的查询。
long queryForLong(String sql) 
// 给定静态SQL，执行结果Map的查询。
Map queryForMap(String sql) 
// 给定静态SQL，对结果对象执行查询。
Object queryForObject(String sql, Class requiredType)
// 给定静态SQL，执行SqlRowSet的查询。
SqlRowSet queryForRowSet(String sql)
1
2
3
4
5
6
7
8
9
10
11
12