当前位置:   article > 正文

Java:Spring 数据库操作_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
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/我家小花儿/article/detail/792613
推荐阅读
相关标签
  

闽ICP备14008679号