Spring-JDBC配置

时间:2023-03-09 17:34:46
Spring-JDBC配置

以C3P0连接池为例:由于C3P0是第三方,我们无法使用注解将其定义为bean,因此需要在applicationContext.xml中配置:

     <!-- 导入配置文件 -->
<context:property-placeholder location="classpath:dataSource.properties"/>
<aop:aspectj-autoproxy proxy-target-class="true"/>
<bean id="dataSourceLocal" name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<!-- 指定连接数据库的驱动-->
<property name="driverClass" value="${jdbc.driverClassName}"/>
<!-- 指定连接数据库的URL-->
<property name="jdbcUrl" value="${jdbc.url}"/>
<!-- 指定连接数据库的用户名-->
<property name="user" value="${jdbc.username}"/>
<!-- 指定连接数据库的密码-->
<property name="password" value="${jdbc.password}"/>
<!-- 指定连接池中保留的最大连接数. Default:15-->
<property name="maxPoolSize" value="${jdbc.maxPoolSize}"/>
<!-- 指定连接池中保留的最小连接数-->
<property name="minPoolSize" value="${jdbc.minPoolSize}"/>
<!-- 指定连接池的初始化连接数 取值应在minPoolSize 与 maxPoolSize 之间.Default:3-->
<property name="initialPoolSize" value="${jdbc.initialPoolSize}"/>
<!-- 最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。 Default:0-->
<property name="maxIdleTime" value="${jdbc.maxIdleTime}"/>
<!-- 当连接池中的连接耗尽的时候c3p0一次同时获取的连接数. Default:3-->
<property name="acquireIncrement" value="${jdbc.acquireIncrement}"/>
<!-- JDBC的标准,用以控制数据源内加载的PreparedStatements数量。
但由于预缓存的statements属于单个connection而不是整个连接池所以设置这个参数需要考虑到多方面的因数.如果maxStatements与maxStatementsPerConnection均为0,则缓存被关闭。Default:0-->
<property name="maxStatements" value="${jdbc.maxStatements}"/>
<!-- 每60秒检查所有连接池中的空闲连接.Default:0 -->
<property name="idleConnectionTestPeriod" value="${jdbc.idleConnectionTestPeriod}"/>
</bean>

c3p0连接池配置

可以看到,连接配置中引用了<context:property-placeholder location="classpath:dataSource.properties"/>标签,这是说从外部配置文件中读取数据库相关的数据,用${}表达式可以读取,因此,我们需要同时配置dataSource.properties文件,内容如下:

 jdbc.driverClassName=oracle.jdbc.driver.OracleDriver
jdbc.url=jdbc:oracle:thin:@localhost:1521:orcl
jdbc.username=scott
jdbc.password=orcl
jdbc.initialPoolSize=20
jdbc.maxPoolSize=100
jdbc.minPoolSize=10
jdbc.maxIdleTime=600
jdbc.acquireIncrement=5
jdbc.maxStatements=5
jdbc.idleConnectionTestPeriod=60

dataSource

只要保证配置文件正确,数据库的连接配置也就完成了,接下来需要配置JDBCTemplate,仍然是在applicationContext.xml中配置:

     <!-- 配置jdbcTemplate -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSourceLocal"></property>
</bean>

JDBCTemplate

JDBCTemplate类中,只有一个参数,那就是dataSource,因此需要注入上面的dateSource。

接下来以Oracle中Scott用户下的dept表为例测试:

 private ApplicationContext ctx=new ClassPathXmlApplicationContext("applicationContext.xml");
private JdbcTemplate jt=(JdbcTemplate) ctx.getBean("jdbcTemplate");

取得bean-JDBCTemplate

     @Test
public void updateTest(){
String sqlUpdate="update emp set ename=? where empno=?";
jt.update(sqlUpdate,"SMITH",7369);
}

单条增删改测试

可以看到,此处在sql语句中使用了?作为占位符,在JDBCTemplate的update方法中一一对应定义即可。

另外,JDBCTemplate同时支持批量操作,代码如下:

     @Test
public void testBatchUpdate(){
//批量修改
String[] s=new String[]{"update emp set ename='SMITH1' where empno=7369","update emp set ename='SMITH' where empno=7369"};
jt.batchUpdate(s);
//批量添加
List<Object[]> addList = new ArrayList<Object[]>();
addList.add(new Object[]{52,"AA","SHANGHAI"});
addList.add(new Object[]{62,"BB","BEIJING"});
addList.add(new Object[]{72,"CC","XI'AN"});
addList.add(new Object[]{82,"DD","HANGZHOU"});
jt.batchUpdate("insert into scott.dept values (?,?,?)",addList);
//批量删除
List<Object[]> delList = new ArrayList<Object[]>();
delList.add(new Integer[]{40});
jt.batchUpdate("delete dept where deptno>?",delList);
}

批量增删改

批量操作需要用到batchUpdate方法,其重载形式如下:

Spring-JDBC配置

我们使用了第一和第三种方法就够用了。

查询分为单条数据查询和多条数据查询,JDBCTemplate支持使用RowMapper类将其对应到相应的实体类,如果是单条数据,可使用queryForObject方法:

     @Test
public void testQueryForObject(){
String sql="select deptno,dname,loc from dept where deptno=?";
RowMapper<Dept> rm=new BeanPropertyRowMapper<Dept>(Dept.class);
Dept d=jt.queryForObject(sql,rm,20);
System.err.println(d);
}

查询单条数据

如果是多条数据,可以用query方法:

     @Test
public void testQueryForList(){
String sql="select * from dept where deptno>?";
RowMapper<Dept> re=new BeanPropertyRowMapper<Dept>(Dept.class);
List<Dept> dept=jt.query(sql, re,20);
System.out.println(dept);
}

查询多条数据

另外,也支持统计查询和单列查询:

     @Test
public void testQueryColumnOrCount(){
//获取统计信息
String sql="select count(empno) from emp";
Long l=jt.queryForObject(sql, Long.class);
System.err.println(l);
//获取单列信息
String sql4Date="select hiredate from emp";
RowMapper<Date> re=new BeanPropertyRowMapper<Date>(Date.class);
List<Date> d=jt.query(sql4Date, re);
System.err.println(d);
}

统计查询和单列查询


从上面的例子中可以看到,参数都是通过?占位符顺序一一对应传递参数的,如果参数位置变动,那么JDBC操作需要同时变更,不安全且工作量大,因此Spring同时提供了NamedParameterJDBCTemplate具名参数:SQL 按名称(以冒号开头)而不是按位置进行指定.。

优势:具名参数更易于维护, 也提升了可读性.

与JDBCTemplate一样,需要在XML中配置:

     <!-- 配置NamedParameterJDBCTemplate -->
<bean id="namedParameterJDBCTemplate" class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">
<constructor-arg><ref bean="dataSourceLocal"/></constructor-arg>
</bean>

NamedParameterJDBCTemplate配置

用法:

在 SQL 语句中使用具名参数时, 可以在一个 Map 中提供参数值, 参数名为键

也可以使用 SqlParameterSource 参数

批量更新时可以提供 Map 或 SqlParameterSource 的数组

代码如下:

     /**
* NamedParameterJDBCTemplate用法测试,以update为例
*/
@Test
public void testNamedParameterJDBCTemplate(){
String sql="insert into dept values (:deptno,:dname,:loc)";//此处参数是可以*命名的
Map<String, Object> map=new HashMap<String, Object>();
map.put("deptno", 94);
map.put("dname", "管理部");
map.put("loc", "金华");
npjt.update(sql, map);
}
/**
* 使用SqlParameterSource类与实体类对应,此时参数命名需与实体类属性名对应
* SqlParameterSource sps = new BeanPropertySqlParameterSource(对象)
*/
@Test
public void testNamedParameterJDBCTemplateByEntity(){
String sql="insert into dept values (:deptno,:dname,:loc)";//此处参数命名需与实体类属性名相同
SqlParameterSource sps=new BeanPropertySqlParameterSource(new Dept(88, "业务部", "北京"));
npjt.update(sql, sps);
}

具名参数测试

高级用法参考:Spring框架笔记(二十五)——NamedParameterJdbcTemplate与具名参数


总结:JDBCTemplate很强大,但毕竟不是ORM框架,比如,并不支持级联操作。