Spring JDBC 的使用
2016-06-07 19:20
561 查看
一、使用示例
(1)springJdbcContext.xml
Java代码
<?xml version=”1.0” encoding=”UTF-8”?>
<beans xmlns=”http://www.springframework.org/schema/beans”
xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance”
xmlns:context=”http://www.springframework.org/schema/context”
xmlns:aop=”http://www.springframework.org/schema/aop”
xmlns:tx=”http://www.springframework.org/schema/tx”
xsi:schemaLocation=”http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd”>
<description>springApp</description>
<!– dataSource for MySQL –>
<bean id=”dataSource”
class=”org.apache.commons.dbcp.BasicDataSource”
destroy-method=”close”>
<property name=”driverClassName”
value=”com.mysql.jdbc.Driver” />
<property name=”url”
value=”jdbc:mysql://localhost:3306/springapp” />
<property name=”username” value=”root” />
<property name=”password” value=”****” />
</bean>
<bean id = ”TransactionManager”
class = ”org.springframework.jdbc.datasource.DataSourceTransactionManager”>
<property name = ”dataSource” ref=”dataSource”/>
</bean>
<!–1:配置一个JdbcTemplate实例,并将这个“共享的”,“安全的”实例注入到不同的DAO类中去–>
<bean id = ”jdbcTemplate”
class = ”org.springframework.jdbc.core.JdbcTemplate”>
<property name = ”dataSource” ref=”dataSource”/>
</bean>
<bean id = ”actorJdbcTemplateDao”
class = ”com.logcd.bo.dao.impl.ActorJdbcTemplateDaoImpl”>
<property name=”jdbcTemplate” ref=”jdbcTemplate”/>
</bean>
<!–2:将共享的DataSource实例注入到DAO中,JdbcTemplate实例在DataSource的setter方法中被创建–>
<bean id = ”actorEventDao”
class = ”com.logcd.bo.dao.impl.ActorEventDaoImpl”>
<property name = ”dataSource” ref=”dataSource”/>
</bean>
<!–利用了拦截器的原理。–>
<bean id=”transactionInterceptor”
class=”org.springframework.transaction.interceptor.TransactionInterceptor”>
<property name=”transactionManager”>
<ref bean=”transactionManager” />
</property>
<!– 配置事务属性 –>
<property name=”transactionAttributes”>
<props>
<prop key=”delete*”>PROPAGATION_REQUIRED</prop>
<prop key=”operate*”>PROPAGATION_REQUIRED,-Exception</prop>
<prop key=”insert*”>PROPAGATION_REQUIRED,-Exception</prop>
<prop key=”update*”>PROPAGATION_REQUIRED,-Exception</prop>
<prop key=”save*”>PROPAGATION_REQUIRED</prop>
<prop key=”find*”>PROPAGATION_REQUIRED,readOnly</prop>
</props>
</property>
</bean>
<bean id=”txProxy”
class=”org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator”>
<property name=”beanNames”>
<list>
<value>*Dao*</value><!–只是为了测试,一般为service–>
</list>
</property>
<property name=”interceptorNames”>
<list>
<value>transactionInterceptor</value>
</list>
</property>
</bean>
</beans>
(2)接口:(以第二种方式定义DAO)
Java代码
package com.logcd.bo.dao;
import java.util.List;
import org.springframework.jdbc.support.KeyHolder;
import com.logcd.bo.Actor;
public interface ActorEventDao {
/**
* 根据SQL建表
* @param sql
*/
public void createTableBySQL(String sql);
/**
* 统计firstName相同的总数
* @param firstName
* @return
*/
public int findCountOfActorsByFirstName(String firstName);
/**
* 插入记录并返回自动生成的主键Id
* @param ps
* @return
*/
public KeyHolder insertActor(final Actor actor);
/**
* 用SimpleJdbcInsert插入一条记录:mysql测试成功
*/
public long inserOneActor(Actor actor);
/**
* 插入/更新/删除数据
* @param sql 有参数语句
* @param obj 参数值数组
*/
public int operateActor(String sql,Object[] obj);
/**
* 根据SQL查询记录总数
* @param sql
* @return
*/
public int findRowCountBySQL(String sql);
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorById(long id);
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorByIdSimple(long id);
/**
* 返回所有对象
* @return
*/
public List findAllActors();
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActors(final List actors);
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActorsSimple(final List<Actor> actors);
}
[java] view plain copy print?package com.logcd.bo.dao; import java.util.List; import org.springframework.jdbc.support.KeyHolder; import com.logcd.bo.Actor; public interface ActorEventDao { /** * 根据SQL建表 * @param sql */ public void createTableBySQL(String sql); /** * 统计firstName相同的总数 * @param firstName * @return */ public int findCountOfActorsByFirstName(String firstName); /** * 插入记录并返回自动生成的主键Id * @param ps * @return */ public KeyHolder insertActor(final Actor actor); /** * 用SimpleJdbcInsert插入一条记录:mysql测试成功 */ public long inserOneActor(Actor actor); /** * 插入/更新/删除数据 * @param sql 有参数语句 * @param obj 参数值数组 */ public int operateActor(String sql,Object[] obj); /** * 根据SQL查询记录总数 * @param sql * @return */ public int findRowCountBySQL(String sql); /** * 根据Id查找指定对象 * @param id * @return */ public Actor findActorById(long id); /** * 根据Id查找指定对象 * @param id * @return */ public Actor findActorByIdSimple(long id); /** * 返回所有对象 * @return */ public List findAllActors(); /** * 批量更新 * @param actors * @return */ public int[] updateBatchActors(final List actors); /** * 批量更新 * @param actors * @return */ public int[] updateBatchActorsSimple(final List<Actor> actors); }
(3)接口实现
Java代码
package com.logcd.bo.dao.impl;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.PreparedStatementCreator;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.support.GeneratedKeyHolder;
import org.springframework.jdbc.support.KeyHolder;
import com.logcd.bo.Actor;
import com.logcd.bo.dao.ActorEventDao;
public class ActorEventDaoImpl implements ActorEventDao{
private JdbcTemplate jdbcTemplate;
//NamedParameterJdbcTemplate对JdbcTemplate封装,增加了命名参数特性
private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
//SimpleJdbcTemplate对JdbcTemplate封装,某些特性要在java5以上才工作
private SimpleJdbcTemplate simpleJdbcTemplate;
//简化插入数据操作
private SimpleJdbcInsert inserActor;
public void setDataSource(DataSource dataSource){
this.jdbcTemplate = new JdbcTemplate(dataSource);
this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
this.simpleJdbcTemplate = new SimpleJdbcTemplate(dataSource);
this.inserActor = new SimpleJdbcInsert(dataSource)
.withTableName(”actors”)
.usingColumns(”first_name”,”last_name”)//插入这些字段
.usingGeneratedKeyColumns(”id”);//带回生成的id
}
/**
* 用SimpleJdbcInsert插入一条记录
*/
public long inserOneActor(Actor actor){
Map<String,Object> parameters = new HashMap<String,Object>();
parameters.put(”first_name”,actor.getFirstName());
parameters.put(”last_name”,actor.getLastName());
return inserActor.executeAndReturnKey(parameters).longValue();
}
/**
* 统计firstName相同的总数
* @param firstName
* @return
*/
public int findCountOfActorsByFirstName(String firstName){
String sql=”select count(0) from actors where first_name = :first_name”;
SqlParameterSource namedParameters = new MapSqlParameterSource(”first_name”,firstName);
//Map namedParameter = Collections.singletonMap(“first_name”,firstName);
//还有一种Bean封装的方式
//SqlParameterSource namedParameters = new BeanPropertySqlParameterSource(exampleActor);
return this.namedParameterJdbcTemplate.queryForInt(sql, namedParameters);
}
/**
* 根据SQL建表
* @param sql
*/
public void createTableBySQL(String sql) {
this.jdbcTemplate.execute(sql);
}
/**
* 插入记录并返回自动生成的主键Id(MySQL中不行,Oracle可以)
* @param ps
* @return
*/
public KeyHolder insertActor(final Actor actor){
final String addSql = ”insert into actors(first_name,last_name) values (?,?)”;
KeyHolder keyHolder = new GeneratedKeyHolder();
this.jdbcTemplate.update(new PreparedStatementCreator(){
public PreparedStatement createPreparedStatement(Connection conn) throws SQLException {
PreparedStatement ps =
conn.prepareStatement(addSql, new String[]{”id”});//返回id
ps.setString(1, actor.getFirstName());
ps.setString(2, actor.getLastName());
return ps;
}
});
System.out.println(keyHolder.getKey());
return keyHolder;
}
/**
* 插入/更新/删除数据
* @param sql 有参数语句
* @param obj 参数值数组
*/
public int operateActor(String sql,Object[] obj){
return this.jdbcTemplate.update(sql, obj);
}
/**
* 根据SQL查询记录总数
* @param sql
* @return
*/
public int findRowCountBySQL(String sql){
return this.jdbcTemplate.queryForInt(sql);
}
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorById(long id){
Actor actor = (Actor) this.jdbcTemplate.queryForObject(
”select id,first_name,last_name from actors where id = ?”,
new Object[]{new Long(id)},
new RowMapper(){
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
});
return actor;
}
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorByIdSimple(long id){
String sql = ”select id,first_name,last_name from actors where id = ?”;
ParameterizedRowMapper<Actor> mapper = new ParameterizedRowMapper<Actor>(){
//notice the return type with respect to java 5 covariant return types
public Actor mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
};
return this.simpleJdbcTemplate.queryForObject(sql, mapper, id);
}
/**
* 返回所有对象
* @return
*/
public List findAllActors(){
return this.jdbcTemplate.query(
”select id,first_name,last_name from actors”,
new ActorMapper());
}
/**
* 定义一个静态内部类,在Dao的方法中被共享
* @author logcd
*/
private static final class ActorMapper implements RowMapper{
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
}
}
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActors(final List actors){
int[] updateCounts =this.jdbcTemplate.batchUpdate(
”update actors set first_name = ?, last_name = ? where id =? ”,
new BatchPreparedStatementSetter(){
public int getBatchSize() {
return actors.size();
}
public void setValues(PreparedStatement ps, int i) throws SQLException {
ps.setString(1, ((Actor)actors.get(i)).getFirstName());
ps.setString(2, ((Actor)actors.get(i)).getLastName());
ps.setLong(3, ((Actor)actors.get(i)).getId());
}
});
return updateCounts;
}
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActorsSimple(final List<Actor> actors){
//如果对象数组与占位符出现位置一一对应
//SqlParameterSource[] batch = SqlParameterSourceUtils.createBatch(actors.toArray());
List<Object[]> batch = new ArrayList<Object[]>();
for(Actor actor:actors){
Object[] values = new Object[]{//注意顺序
actor.getFirstName(),
actor.getLastName(),
actor.getId()};
batch.add(values);
}
int[] updateCounts = this.simpleJdbcTemplate.batchUpdate(
”update actors set first_name = ?, last_name = ? where id =? ”,
batch);
return updateCounts;
}
[java] view plain copy print?package com.logcd.bo.dao.impl;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.PreparedStatementCreator;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.support.GeneratedKeyHolder;
import org.springframework.jdbc.support.KeyHolder;
import com.logcd.bo.Actor;
import com.logcd.bo.dao.ActorEventDao;
public class ActorEventDaoImpl implements ActorEventDao{
private JdbcTemplate jdbcTemplate;
//NamedParameterJdbcTemplate对JdbcTemplate封装,增加了命名参数特性
private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
//SimpleJdbcTemplate对JdbcTemplate封装,某些特性要在java5以上才工作
private SimpleJdbcTemplate simpleJdbcTemplate;
//简化插入数据操作
private SimpleJdbcInsert inserActor;
public void setDataSource(DataSource dataSource){
this.jdbcTemplate = new JdbcTemplate(dataSource);
this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
this.simpleJdbcTemplate = new SimpleJdbcTemplate(dataSource);
this.inserActor = new SimpleJdbcInsert(dataSource)
.withTableName(”actors”)
.usingColumns(”first_name”,“last_name”)//插入这些字段
.usingGeneratedKeyColumns(”id”);//带回生成的id
}
/**
* 用SimpleJdbcInsert插入一条记录
*/
public long inserOneActor(Actor actor){
Map<String,Object> parameters = new HashMap<String,Object>();
parameters.put(”first_name”,actor.getFirstName());
parameters.put(”last_name”,actor.getLastName());
return inserActor.executeAndReturnKey(parameters).longValue();
}
/**
* 统计firstName相同的总数
* @param firstName
* @return
*/
public int findCountOfActorsByFirstName(String firstName){
String sql=”select count(0) from actors where first_name = :first_name”;
SqlParameterSource namedParameters = new MapSqlParameterSource(“first_name”,firstName);
//Map namedParameter = Collections.singletonMap(“first_name”,firstName);
//还有一种Bean封装的方式
//SqlParameterSource namedParameters = new BeanPropertySqlParameterSource(exampleActor);
return this.namedParameterJdbcTemplate.queryForInt(sql, namedParameters);
}
/**
* 根据SQL建表
* @param sql
*/
public void createTableBySQL(String sql) {
this.jdbcTemplate.execute(sql);
}
/**
* 插入记录并返回自动生成的主键Id(MySQL中不行,Oracle可以)
* @param ps
* @return
*/
public KeyHolder insertActor(final Actor actor){
final String addSql = “insert into actors(first_name,last_name) values (?,?)”;
KeyHolder keyHolder = new GeneratedKeyHolder();
this.jdbcTemplate.update(new PreparedStatementCreator(){
public PreparedStatement createPreparedStatement(Connection conn) throws SQLException {
PreparedStatement ps =
conn.prepareStatement(addSql, new String[]{“id”});//返回id
ps.setString(1, actor.getFirstName());
ps.setString(2, actor.getLastName());
return ps;
}
});
System.out.println(keyHolder.getKey());
return keyHolder;
}
/**
* 插入/更新/删除数据
* @param sql 有参数语句
* @param obj 参数值数组
*/
public int operateActor(String sql,Object[] obj){
return this.jdbcTemplate.update(sql, obj);
}
/**
* 根据SQL查询记录总数
* @param sql
* @return
*/
public int findRowCountBySQL(String sql){
return this.jdbcTemplate.queryForInt(sql);
}
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorById(long id){
Actor actor = (Actor) this.jdbcTemplate.queryForObject(
”select id,first_name,last_name from actors where id = ?”,
new Object[]{new Long(id)},
new RowMapper(){
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
});
return actor;
}
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorByIdSimple(long id){
String sql = ”select id,first_name,last_name from actors where id = ?”;
ParameterizedRowMapper<Actor> mapper = new ParameterizedRowMapper<Actor>(){
//notice the return type with respect to java 5 covariant return types
public Actor mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
};
return this.simpleJdbcTemplate.queryForObject(sql, mapper, id);
}
/**
* 返回所有对象
* @return
*/
public List findAllActors(){
return this.jdbcTemplate.query(
”select id,first_name,last_name from actors”,
new ActorMapper());
}
/**
* 定义一个静态内部类,在Dao的方法中被共享
* @author logcd
*/
private static final class ActorMapper implements RowMapper{
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
}
}
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActors(final List actors){
int[] updateCounts =this.jdbcTemplate.batchUpdate(
”update actors set first_name = ?, last_name = ? where id =? ”,
new BatchPreparedStatementSetter(){
public int getBatchSize() {
return actors.size();
}
public void setValues(PreparedStatement ps, int i) throws SQLException {
ps.setString(1, ((Actor)actors.get(i)).getFirstName());
ps.setString(2, ((Actor)actors.get(i)).getLastName());
ps.setLong(3, ((Actor)actors.get(i)).getId());
}
});
return updateCounts;
}
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActorsSimple(final List<Actor> actors){
//如果对象数组与占位符出现位置一一对应
//SqlParameterSource[] batch = SqlParameterSourceUtils.createBatch(actors.toArray());
List<Object[]> batch = new ArrayList<Object[]>();
for(Actor actor:actors){
Object[] values = new Object[]{//注意顺序
actor.getFirstName(),
actor.getLastName(),
actor.getId()};
batch.add(values);
}
int[] updateCounts = this.simpleJdbcTemplate.batchUpdate(
”update actors set first_name = ?, last_name = ? where id =? ”,
batch);
return updateCounts;
}
(4)测试
Java代码
/**
*
*/
package com.logcd.test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.support.KeyHolder;
import com.logcd.bo.Actor;
import com.logcd.bo.dao.ActorEventDao;
import com.logcd.bo.dao.ActorJdbcTemplateDao;
import junit.framework.TestCase;
/**
* @author logcd
*/
public class SpringJdbcTest extends TestCase {
private ActorEventDao actorEventDao;
private ActorJdbcTemplateDao actorJdbcTemplateDao;
protected void setUp() throws Exception {
super.setUp();
ApplicationContext context = new ClassPathXmlApplicationContext(”springJdbcContext.xml”);
actorEventDao = (ActorEventDao)context.getBean(”actorEventDao”);
actorJdbcTemplateDao = (ActorJdbcTemplateDao)context.getBean(”actorJdbcTemplateDao”);
}
protected void tearDown() throws Exception {
super.tearDown();
}
public void testActorEventDao(){
String creatSql = ”create table ACTORS(“ +
”ID int not null auto_increment,” +
”FIRST_NAME varchar(15),” +
”LAST_NAME varchar(15),” +
”primary key (ID)” +
”);” ;
//建表
actorEventDao.createTableBySQL(creatSql);
String addSql = ”insert into actors(first_name,last_name) values(?,?);”;
Object[] obj = new Object[]{”wang”,”jinming”};
//新增
System.out.println(actorEventDao.operateActor(addSql, obj));
String countSql = ”select count(0) from actors”;
System.out.println(”Count:”+actorEventDao.findRowCountBySQL(countSql));
System.out.println(”Count:”+actorJdbcTemplateDao.findRowCountBySQL(countSql));
//根据id查找
Actor actor = actorEventDao.findActorById(1);
System.out.println(”id:”+actor.getId()+” first_name:”+actor.getFirstName()+” last_name:”+actor.getLastName());
//输出所有
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+” first_name:”+act.getFirstName()+” last_name:”+act.getLastName());
}
Actor newAct=new Actor();
newAct.setFirstName(”jin”);
newAct.setLastName(”ming”);
KeyHolder keyHold =actorEventDao.insertActor(newAct);
System.out.println(keyHold.getKey());//mysql得不到id
List<Actor> list = new ArrayList<Actor>();
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+” first_name:”+act.getFirstName()+” last_name:”+act.getLastName());
act.setLastName(”www”);
list.add(act);
}
actorEventDao.batchUpdateActors(list);
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+” first_name:”+act.getFirstName()+” last_name:”+act.getLastName());
}
}
}
[java] view plain copy print?/**
*
*/
package com.logcd.test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.support.KeyHolder;
import com.logcd.bo.Actor;
import com.logcd.bo.dao.ActorEventDao;
import com.logcd.bo.dao.ActorJdbcTemplateDao;
import junit.framework.TestCase;
/**
* @author logcd
*/
public class SpringJdbcTest extends TestCase {
private ActorEventDao actorEventDao;
private ActorJdbcTemplateDao actorJdbcTemplateDao;
protected void setUp() throws Exception {
super.setUp();
ApplicationContext context = new ClassPathXmlApplicationContext(“springJdbcContext.xml”);
actorEventDao = (ActorEventDao)context.getBean(”actorEventDao”);
actorJdbcTemplateDao = (ActorJdbcTemplateDao)context.getBean(”actorJdbcTemplateDao”);
}
protected void tearDown() throws Exception {
super.tearDown();
}
public void testActorEventDao(){
String creatSql = ”create table ACTORS(“ +
”ID int not null auto_increment,” +
”FIRST_NAME varchar(15),” +
”LAST_NAME varchar(15),” +
”primary key (ID)” +
”);” ;
//建表
actorEventDao.createTableBySQL(creatSql);
String addSql = ”insert into actors(first_name,last_name) values(?,?);”;
Object[] obj = new Object[]{“wang”,“jinming”};
//新增
System.out.println(actorEventDao.operateActor(addSql, obj));
String countSql = ”select count(0) from actors”;
System.out.println(”Count:”+actorEventDao.findRowCountBySQL(countSql));
System.out.println(”Count:”+actorJdbcTemplateDao.findRowCountBySQL(countSql));
//根据id查找
Actor actor = actorEventDao.findActorById(1);
System.out.println(”id:”+actor.getId()+“ first_name:”+actor.getFirstName()+“ last_name:”+actor.getLastName());
//输出所有
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+“ first_name:”+act.getFirstName()+“ last_name:”+act.getLastName());
}
Actor newAct=new Actor();
newAct.setFirstName(”jin”);
newAct.setLastName(”ming”);
KeyHolder keyHold =actorEventDao.insertActor(newAct);
System.out.println(keyHold.getKey());//mysql得不到id
List<Actor> list = new ArrayList<Actor>();
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+“ first_name:”+act.getFirstName()+“ last_name:”+act.getLastName());
act.setLastName(”www”);
list.add(act);
}
actorEventDao.batchUpdateActors(list);
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+“ first_name:”+act.getFirstName()+“ last_name:”+act.getLastName());
}
}
}
二、关于操作Blob和Clob问题
spring定义了一个以统一的方式操作各种数据库的Lob类型数据的LobCreator(保存的时候用),同时提供了一个LobHandler为操作二进制字段和大文本字段提供统一接口访问。
(1)配置文件
Xml代码
<bean id=”nativeJdbcExtractor”
class=”org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor”
lazy-init=”true”/>
<bean id=”lobHandler”
class=”org.springframework.jdbc.support.lob.OracleLobHandler”
lazy-init=”true”
p:nativeJdbcExtractor-ref=”nativeJdbcExtractor”/>
<bean id=”defaultLobHandler”
class=”org.springframework.jdbc.support.lob.DefaultLobHandler”
lazy-init=”true” />
<bean id=”jdbcTemplate”
class=”org.springframework.jdbc.core.JdbcTemplate”
p:dataSource-ref=”appDS”
p:nativeJdbcExtractor-ref=”nativeJdbcExtractor”/>
<bean id=”txMangager”
class=”org.springframework.jdbc.datasource.DataSourceTransactionManager”
p:dataSource-ref=”appDS”/>
<tx:annotation-driven transaction-manager=”txMangager” proxy-target-class=”true”/>
[xml] view plain copy print?<bean id=“nativeJdbcExtractor”
class=“org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor”
lazy-init=“true”/>
<bean id=“lobHandler”
class=“org.springframework.jdbc.support.lob.OracleLobHandler”
lazy-init=“true”
p:nativeJdbcExtractor-ref=“nativeJdbcExtractor”/>
<bean id=“defaultLobHandler”
class=“org.springframework.jdbc.support.lob.DefaultLobHandler”
lazy-init=“true” />
<bean id=“jdbcTemplate”
class=“org.springframework.jdbc.core.JdbcTemplate”
p:dataSource-ref=“appDS”
p:nativeJdbcExtractor-ref=“nativeJdbcExtractor”/>
<bean id=“txMangager”
class=“org.springframework.jdbc.datasource.DataSourceTransactionManager”
p:dataSource-ref=“appDS”/>
<tx:annotation-driven transaction-manager=“txMangager” proxy-target-class=“true”/>
(2)读写
Java代码
@Resource(name = ”lobHandler”)
private LobHandler lobHandler;
@Resource(name = ”jdbcTemplate”)
private JdbcTemplate jdbcTemplate;
public void savePost(final Post post) {
String sql = ” INSERT INTO t_post(post_id,user_id,post_text,post_attach)”
+ ” VALUES(?,?,?,?)”;
jdbcTemplate().execute(sql,
new AbstractLobCreatingPreparedStatementCallback(this.lobHandler) {
protected void setValues(PreparedStatement ps,
LobCreator lobCreator) throws SQLException {
ps.setInt(1, incre.nextIntValue());
ps.setInt(2, post.getUserId());
lobCreator.setClobAsString(ps, 3, post.getPostText());
lobCreator.setBlobAsBytes(ps, 4, post.getPostAttach());
}
});
}
public List findAttachs(final int userId){
String sql = ”SELECT post_id,post_attach FROM t_post where user_id =? and post_attach is not null”;
return jdbcTemplate().query( sql, new Object[] {userId},
new RowMapper() {
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
Post post = new Post();
int postId = rs.getInt(1);
byte[] attach = lobHandler.getBlobAsBytes(rs, 2);
post.setPostId(postId);
post.setPostAttach(attach);
return post;
}
});
}
(1)springJdbcContext.xml
Java代码
<?xml version=”1.0” encoding=”UTF-8”?>
<beans xmlns=”http://www.springframework.org/schema/beans”
xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance”
xmlns:context=”http://www.springframework.org/schema/context”
xmlns:aop=”http://www.springframework.org/schema/aop”
xmlns:tx=”http://www.springframework.org/schema/tx”
xsi:schemaLocation=”http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd”>
<description>springApp</description>
<!– dataSource for MySQL –>
<bean id=”dataSource”
class=”org.apache.commons.dbcp.BasicDataSource”
destroy-method=”close”>
<property name=”driverClassName”
value=”com.mysql.jdbc.Driver” />
<property name=”url”
value=”jdbc:mysql://localhost:3306/springapp” />
<property name=”username” value=”root” />
<property name=”password” value=”****” />
</bean>
<bean id = ”TransactionManager”
class = ”org.springframework.jdbc.datasource.DataSourceTransactionManager”>
<property name = ”dataSource” ref=”dataSource”/>
</bean>
<!–1:配置一个JdbcTemplate实例,并将这个“共享的”,“安全的”实例注入到不同的DAO类中去–>
<bean id = ”jdbcTemplate”
class = ”org.springframework.jdbc.core.JdbcTemplate”>
<property name = ”dataSource” ref=”dataSource”/>
</bean>
<bean id = ”actorJdbcTemplateDao”
class = ”com.logcd.bo.dao.impl.ActorJdbcTemplateDaoImpl”>
<property name=”jdbcTemplate” ref=”jdbcTemplate”/>
</bean>
<!–2:将共享的DataSource实例注入到DAO中,JdbcTemplate实例在DataSource的setter方法中被创建–>
<bean id = ”actorEventDao”
class = ”com.logcd.bo.dao.impl.ActorEventDaoImpl”>
<property name = ”dataSource” ref=”dataSource”/>
</bean>
<!–利用了拦截器的原理。–>
<bean id=”transactionInterceptor”
class=”org.springframework.transaction.interceptor.TransactionInterceptor”>
<property name=”transactionManager”>
<ref bean=”transactionManager” />
</property>
<!– 配置事务属性 –>
<property name=”transactionAttributes”>
<props>
<prop key=”delete*”>PROPAGATION_REQUIRED</prop>
<prop key=”operate*”>PROPAGATION_REQUIRED,-Exception</prop>
<prop key=”insert*”>PROPAGATION_REQUIRED,-Exception</prop>
<prop key=”update*”>PROPAGATION_REQUIRED,-Exception</prop>
<prop key=”save*”>PROPAGATION_REQUIRED</prop>
<prop key=”find*”>PROPAGATION_REQUIRED,readOnly</prop>
</props>
</property>
</bean>
<bean id=”txProxy”
class=”org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator”>
<property name=”beanNames”>
<list>
<value>*Dao*</value><!–只是为了测试,一般为service–>
</list>
</property>
<property name=”interceptorNames”>
<list>
<value>transactionInterceptor</value>
</list>
</property>
</bean>
</beans>
(2)接口:(以第二种方式定义DAO)
Java代码
package com.logcd.bo.dao;
import java.util.List;
import org.springframework.jdbc.support.KeyHolder;
import com.logcd.bo.Actor;
public interface ActorEventDao {
/**
* 根据SQL建表
* @param sql
*/
public void createTableBySQL(String sql);
/**
* 统计firstName相同的总数
* @param firstName
* @return
*/
public int findCountOfActorsByFirstName(String firstName);
/**
* 插入记录并返回自动生成的主键Id
* @param ps
* @return
*/
public KeyHolder insertActor(final Actor actor);
/**
* 用SimpleJdbcInsert插入一条记录:mysql测试成功
*/
public long inserOneActor(Actor actor);
/**
* 插入/更新/删除数据
* @param sql 有参数语句
* @param obj 参数值数组
*/
public int operateActor(String sql,Object[] obj);
/**
* 根据SQL查询记录总数
* @param sql
* @return
*/
public int findRowCountBySQL(String sql);
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorById(long id);
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorByIdSimple(long id);
/**
* 返回所有对象
* @return
*/
public List findAllActors();
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActors(final List actors);
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActorsSimple(final List<Actor> actors);
}
[java] view plain copy print?package com.logcd.bo.dao; import java.util.List; import org.springframework.jdbc.support.KeyHolder; import com.logcd.bo.Actor; public interface ActorEventDao { /** * 根据SQL建表 * @param sql */ public void createTableBySQL(String sql); /** * 统计firstName相同的总数 * @param firstName * @return */ public int findCountOfActorsByFirstName(String firstName); /** * 插入记录并返回自动生成的主键Id * @param ps * @return */ public KeyHolder insertActor(final Actor actor); /** * 用SimpleJdbcInsert插入一条记录:mysql测试成功 */ public long inserOneActor(Actor actor); /** * 插入/更新/删除数据 * @param sql 有参数语句 * @param obj 参数值数组 */ public int operateActor(String sql,Object[] obj); /** * 根据SQL查询记录总数 * @param sql * @return */ public int findRowCountBySQL(String sql); /** * 根据Id查找指定对象 * @param id * @return */ public Actor findActorById(long id); /** * 根据Id查找指定对象 * @param id * @return */ public Actor findActorByIdSimple(long id); /** * 返回所有对象 * @return */ public List findAllActors(); /** * 批量更新 * @param actors * @return */ public int[] updateBatchActors(final List actors); /** * 批量更新 * @param actors * @return */ public int[] updateBatchActorsSimple(final List<Actor> actors); }
package com.logcd.bo.dao; import java.util.List; import org.springframework.jdbc.support.KeyHolder; import com.logcd.bo.Actor; public interface ActorEventDao { /** * 根据SQL建表 * @param sql */ public void createTableBySQL(String sql); /** * 统计firstName相同的总数 * @param firstName * @return */ public int findCountOfActorsByFirstName(String firstName); /** * 插入记录并返回自动生成的主键Id * @param ps * @return */ public KeyHolder insertActor(final Actor actor); /** * 用SimpleJdbcInsert插入一条记录:mysql测试成功 */ public long inserOneActor(Actor actor); /** * 插入/更新/删除数据 * @param sql 有参数语句 * @param obj 参数值数组 */ public int operateActor(String sql,Object[] obj); /** * 根据SQL查询记录总数 * @param sql * @return */ public int findRowCountBySQL(String sql); /** * 根据Id查找指定对象 * @param id * @return */ public Actor findActorById(long id); /** * 根据Id查找指定对象 * @param id * @return */ public Actor findActorByIdSimple(long id); /** * 返回所有对象 * @return */ public List findAllActors(); /** * 批量更新 * @param actors * @return */ public int[] updateBatchActors(final List actors); /** * 批量更新 * @param actors * @return */ public int[] updateBatchActorsSimple(final List<Actor> actors); }
(3)接口实现
Java代码
package com.logcd.bo.dao.impl;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.PreparedStatementCreator;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.support.GeneratedKeyHolder;
import org.springframework.jdbc.support.KeyHolder;
import com.logcd.bo.Actor;
import com.logcd.bo.dao.ActorEventDao;
public class ActorEventDaoImpl implements ActorEventDao{
private JdbcTemplate jdbcTemplate;
//NamedParameterJdbcTemplate对JdbcTemplate封装,增加了命名参数特性
private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
//SimpleJdbcTemplate对JdbcTemplate封装,某些特性要在java5以上才工作
private SimpleJdbcTemplate simpleJdbcTemplate;
//简化插入数据操作
private SimpleJdbcInsert inserActor;
public void setDataSource(DataSource dataSource){
this.jdbcTemplate = new JdbcTemplate(dataSource);
this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
this.simpleJdbcTemplate = new SimpleJdbcTemplate(dataSource);
this.inserActor = new SimpleJdbcInsert(dataSource)
.withTableName(”actors”)
.usingColumns(”first_name”,”last_name”)//插入这些字段
.usingGeneratedKeyColumns(”id”);//带回生成的id
}
/**
* 用SimpleJdbcInsert插入一条记录
*/
public long inserOneActor(Actor actor){
Map<String,Object> parameters = new HashMap<String,Object>();
parameters.put(”first_name”,actor.getFirstName());
parameters.put(”last_name”,actor.getLastName());
return inserActor.executeAndReturnKey(parameters).longValue();
}
/**
* 统计firstName相同的总数
* @param firstName
* @return
*/
public int findCountOfActorsByFirstName(String firstName){
String sql=”select count(0) from actors where first_name = :first_name”;
SqlParameterSource namedParameters = new MapSqlParameterSource(”first_name”,firstName);
//Map namedParameter = Collections.singletonMap(“first_name”,firstName);
//还有一种Bean封装的方式
//SqlParameterSource namedParameters = new BeanPropertySqlParameterSource(exampleActor);
return this.namedParameterJdbcTemplate.queryForInt(sql, namedParameters);
}
/**
* 根据SQL建表
* @param sql
*/
public void createTableBySQL(String sql) {
this.jdbcTemplate.execute(sql);
}
/**
* 插入记录并返回自动生成的主键Id(MySQL中不行,Oracle可以)
* @param ps
* @return
*/
public KeyHolder insertActor(final Actor actor){
final String addSql = ”insert into actors(first_name,last_name) values (?,?)”;
KeyHolder keyHolder = new GeneratedKeyHolder();
this.jdbcTemplate.update(new PreparedStatementCreator(){
public PreparedStatement createPreparedStatement(Connection conn) throws SQLException {
PreparedStatement ps =
conn.prepareStatement(addSql, new String[]{”id”});//返回id
ps.setString(1, actor.getFirstName());
ps.setString(2, actor.getLastName());
return ps;
}
});
System.out.println(keyHolder.getKey());
return keyHolder;
}
/**
* 插入/更新/删除数据
* @param sql 有参数语句
* @param obj 参数值数组
*/
public int operateActor(String sql,Object[] obj){
return this.jdbcTemplate.update(sql, obj);
}
/**
* 根据SQL查询记录总数
* @param sql
* @return
*/
public int findRowCountBySQL(String sql){
return this.jdbcTemplate.queryForInt(sql);
}
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorById(long id){
Actor actor = (Actor) this.jdbcTemplate.queryForObject(
”select id,first_name,last_name from actors where id = ?”,
new Object[]{new Long(id)},
new RowMapper(){
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
});
return actor;
}
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorByIdSimple(long id){
String sql = ”select id,first_name,last_name from actors where id = ?”;
ParameterizedRowMapper<Actor> mapper = new ParameterizedRowMapper<Actor>(){
//notice the return type with respect to java 5 covariant return types
public Actor mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
};
return this.simpleJdbcTemplate.queryForObject(sql, mapper, id);
}
/**
* 返回所有对象
* @return
*/
public List findAllActors(){
return this.jdbcTemplate.query(
”select id,first_name,last_name from actors”,
new ActorMapper());
}
/**
* 定义一个静态内部类,在Dao的方法中被共享
* @author logcd
*/
private static final class ActorMapper implements RowMapper{
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
}
}
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActors(final List actors){
int[] updateCounts =this.jdbcTemplate.batchUpdate(
”update actors set first_name = ?, last_name = ? where id =? ”,
new BatchPreparedStatementSetter(){
public int getBatchSize() {
return actors.size();
}
public void setValues(PreparedStatement ps, int i) throws SQLException {
ps.setString(1, ((Actor)actors.get(i)).getFirstName());
ps.setString(2, ((Actor)actors.get(i)).getLastName());
ps.setLong(3, ((Actor)actors.get(i)).getId());
}
});
return updateCounts;
}
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActorsSimple(final List<Actor> actors){
//如果对象数组与占位符出现位置一一对应
//SqlParameterSource[] batch = SqlParameterSourceUtils.createBatch(actors.toArray());
List<Object[]> batch = new ArrayList<Object[]>();
for(Actor actor:actors){
Object[] values = new Object[]{//注意顺序
actor.getFirstName(),
actor.getLastName(),
actor.getId()};
batch.add(values);
}
int[] updateCounts = this.simpleJdbcTemplate.batchUpdate(
”update actors set first_name = ?, last_name = ? where id =? ”,
batch);
return updateCounts;
}
[java] view plain copy print?package com.logcd.bo.dao.impl;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.PreparedStatementCreator;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.support.GeneratedKeyHolder;
import org.springframework.jdbc.support.KeyHolder;
import com.logcd.bo.Actor;
import com.logcd.bo.dao.ActorEventDao;
public class ActorEventDaoImpl implements ActorEventDao{
private JdbcTemplate jdbcTemplate;
//NamedParameterJdbcTemplate对JdbcTemplate封装,增加了命名参数特性
private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
//SimpleJdbcTemplate对JdbcTemplate封装,某些特性要在java5以上才工作
private SimpleJdbcTemplate simpleJdbcTemplate;
//简化插入数据操作
private SimpleJdbcInsert inserActor;
public void setDataSource(DataSource dataSource){
this.jdbcTemplate = new JdbcTemplate(dataSource);
this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
this.simpleJdbcTemplate = new SimpleJdbcTemplate(dataSource);
this.inserActor = new SimpleJdbcInsert(dataSource)
.withTableName(”actors”)
.usingColumns(”first_name”,“last_name”)//插入这些字段
.usingGeneratedKeyColumns(”id”);//带回生成的id
}
/**
* 用SimpleJdbcInsert插入一条记录
*/
public long inserOneActor(Actor actor){
Map<String,Object> parameters = new HashMap<String,Object>();
parameters.put(”first_name”,actor.getFirstName());
parameters.put(”last_name”,actor.getLastName());
return inserActor.executeAndReturnKey(parameters).longValue();
}
/**
* 统计firstName相同的总数
* @param firstName
* @return
*/
public int findCountOfActorsByFirstName(String firstName){
String sql=”select count(0) from actors where first_name = :first_name”;
SqlParameterSource namedParameters = new MapSqlParameterSource(“first_name”,firstName);
//Map namedParameter = Collections.singletonMap(“first_name”,firstName);
//还有一种Bean封装的方式
//SqlParameterSource namedParameters = new BeanPropertySqlParameterSource(exampleActor);
return this.namedParameterJdbcTemplate.queryForInt(sql, namedParameters);
}
/**
* 根据SQL建表
* @param sql
*/
public void createTableBySQL(String sql) {
this.jdbcTemplate.execute(sql);
}
/**
* 插入记录并返回自动生成的主键Id(MySQL中不行,Oracle可以)
* @param ps
* @return
*/
public KeyHolder insertActor(final Actor actor){
final String addSql = “insert into actors(first_name,last_name) values (?,?)”;
KeyHolder keyHolder = new GeneratedKeyHolder();
this.jdbcTemplate.update(new PreparedStatementCreator(){
public PreparedStatement createPreparedStatement(Connection conn) throws SQLException {
PreparedStatement ps =
conn.prepareStatement(addSql, new String[]{“id”});//返回id
ps.setString(1, actor.getFirstName());
ps.setString(2, actor.getLastName());
return ps;
}
});
System.out.println(keyHolder.getKey());
return keyHolder;
}
/**
* 插入/更新/删除数据
* @param sql 有参数语句
* @param obj 参数值数组
*/
public int operateActor(String sql,Object[] obj){
return this.jdbcTemplate.update(sql, obj);
}
/**
* 根据SQL查询记录总数
* @param sql
* @return
*/
public int findRowCountBySQL(String sql){
return this.jdbcTemplate.queryForInt(sql);
}
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorById(long id){
Actor actor = (Actor) this.jdbcTemplate.queryForObject(
”select id,first_name,last_name from actors where id = ?”,
new Object[]{new Long(id)},
new RowMapper(){
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
});
return actor;
}
/**
* 根据Id查找指定对象
* @param id
* @return
*/
public Actor findActorByIdSimple(long id){
String sql = ”select id,first_name,last_name from actors where id = ?”;
ParameterizedRowMapper<Actor> mapper = new ParameterizedRowMapper<Actor>(){
//notice the return type with respect to java 5 covariant return types
public Actor mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
};
return this.simpleJdbcTemplate.queryForObject(sql, mapper, id);
}
/**
* 返回所有对象
* @return
*/
public List findAllActors(){
return this.jdbcTemplate.query(
”select id,first_name,last_name from actors”,
new ActorMapper());
}
/**
* 定义一个静态内部类,在Dao的方法中被共享
* @author logcd
*/
private static final class ActorMapper implements RowMapper{
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
Actor act = new Actor();
act.setId(rs.getLong(”id”));
act.setFirstName(rs.getString(”first_name”));
act.setLastName(rs.getString(”last_Name”));
return act;
}
}
}
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActors(final List actors){
int[] updateCounts =this.jdbcTemplate.batchUpdate(
”update actors set first_name = ?, last_name = ? where id =? ”,
new BatchPreparedStatementSetter(){
public int getBatchSize() {
return actors.size();
}
public void setValues(PreparedStatement ps, int i) throws SQLException {
ps.setString(1, ((Actor)actors.get(i)).getFirstName());
ps.setString(2, ((Actor)actors.get(i)).getLastName());
ps.setLong(3, ((Actor)actors.get(i)).getId());
}
});
return updateCounts;
}
/**
* 批量更新
* @param actors
* @return
*/
public int[] updateBatchActorsSimple(final List<Actor> actors){
//如果对象数组与占位符出现位置一一对应
//SqlParameterSource[] batch = SqlParameterSourceUtils.createBatch(actors.toArray());
List<Object[]> batch = new ArrayList<Object[]>();
for(Actor actor:actors){
Object[] values = new Object[]{//注意顺序
actor.getFirstName(),
actor.getLastName(),
actor.getId()};
batch.add(values);
}
int[] updateCounts = this.simpleJdbcTemplate.batchUpdate(
”update actors set first_name = ?, last_name = ? where id =? ”,
batch);
return updateCounts;
}
package com.logcd.bo.dao.impl; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.List; import javax.sql.DataSource; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.PreparedStatementCreator; import org.springframework.jdbc.core.RowMapper; import org.springframework.jdbc.support.GeneratedKeyHolder; import org.springframework.jdbc.support.KeyHolder; import com.logcd.bo.Actor; import com.logcd.bo.dao.ActorEventDao; public class ActorEventDaoImpl implements ActorEventDao{ private JdbcTemplate jdbcTemplate; //NamedParameterJdbcTemplate对JdbcTemplate封装,增加了命名参数特性 private NamedParameterJdbcTemplate namedParameterJdbcTemplate; //SimpleJdbcTemplate对JdbcTemplate封装,某些特性要在java5以上才工作 private SimpleJdbcTemplate simpleJdbcTemplate; //简化插入数据操作 private SimpleJdbcInsert inserActor; public void setDataSource(DataSource dataSource){ this.jdbcTemplate = new JdbcTemplate(dataSource); this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource); this.simpleJdbcTemplate = new SimpleJdbcTemplate(dataSource); this.inserActor = new SimpleJdbcInsert(dataSource) .withTableName("actors") .usingColumns("first_name","last_name")//插入这些字段 .usingGeneratedKeyColumns("id");//带回生成的id } /** * 用SimpleJdbcInsert插入一条记录 */ public long inserOneActor(Actor actor){ Map<String,Object> parameters = new HashMap<String,Object>(); parameters.put("first_name",actor.getFirstName()); parameters.put("last_name",actor.getLastName()); return inserActor.executeAndReturnKey(parameters).longValue(); } /** * 统计firstName相同的总数 * @param firstName * @return */ public int findCountOfActorsByFirstName(String firstName){ String sql="select count(0) from actors where first_name = :first_name"; SqlParameterSource namedParameters = new MapSqlParameterSource("first_name",firstName); //Map namedParameter = Collections.singletonMap("first_name",firstName); //还有一种Bean封装的方式 //SqlParameterSource namedParameters = new BeanPropertySqlParameterSource(exampleActor); return this.namedParameterJdbcTemplate.queryForInt(sql, namedParameters); } /** * 根据SQL建表 * @param sql */ public void createTableBySQL(String sql) { this.jdbcTemplate.execute(sql); } /** * 插入记录并返回自动生成的主键Id(MySQL中不行,Oracle可以) * @param ps * @return */ public KeyHolder insertActor(final Actor actor){ final String addSql = "insert into actors(first_name,last_name) values (?,?)"; KeyHolder keyHolder = new GeneratedKeyHolder(); this.jdbcTemplate.update(new PreparedStatementCreator(){ public PreparedStatement createPreparedStatement(Connection conn) throws SQLException { PreparedStatement ps = conn.prepareStatement(addSql, new String[]{"id"});//返回id ps.setString(1, actor.getFirstName()); ps.setString(2, actor.getLastName()); return ps; } }); System.out.println(keyHolder.getKey()); return keyHolder; } /** * 插入/更新/删除数据 * @param sql 有参数语句 * @param obj 参数值数组 */ public int operateActor(String sql,Object[] obj){ return this.jdbcTemplate.update(sql, obj); } /** * 根据SQL查询记录总数 * @param sql * @return */ public int findRowCountBySQL(String sql){ return this.jdbcTemplate.queryForInt(sql); } /** * 根据Id查找指定对象 * @param id * @return */ public Actor findActorById(long id){ Actor actor = (Actor) this.jdbcTemplate.queryForObject( "select id,first_name,last_name from actors where id = ?", new Object[]{new Long(id)}, new RowMapper(){ public Object mapRow(ResultSet rs, int rowNum) throws SQLException { Actor act = new Actor(); act.setId(rs.getLong("id")); act.setFirstName(rs.getString("first_name")); act.setLastName(rs.getString("last_Name")); return act; } }); return actor; } /** * 根据Id查找指定对象 * @param id * @return */ public Actor findActorByIdSimple(long id){ String sql = "select id,first_name,last_name from actors where id = ?"; ParameterizedRowMapper<Actor> mapper = new ParameterizedRowMapper<Actor>(){ //notice the return type with respect to java 5 covariant return types public Actor mapRow(ResultSet rs, int rowNum) throws SQLException { Actor act = new Actor(); act.setId(rs.getLong("id")); act.setFirstName(rs.getString("first_name")); act.setLastName(rs.getString("last_Name")); return act; } }; return this.simpleJdbcTemplate.queryForObject(sql, mapper, id); } /** * 返回所有对象 * @return */ public List findAllActors(){ return this.jdbcTemplate.query( "select id,first_name,last_name from actors", new ActorMapper()); } /** * 定义一个静态内部类,在Dao的方法中被共享 * @author logcd */ private static final class ActorMapper implements RowMapper{ public Object mapRow(ResultSet rs, int rowNum) throws SQLException { Actor act = new Actor(); act.setId(rs.getLong("id")); act.setFirstName(rs.getString("first_name")); act.setLastName(rs.getString("last_Name")); return act; } } } /** * 批量更新 * @param actors * @return */ public int[] updateBatchActors(final List actors){ int[] updateCounts =this.jdbcTemplate.batchUpdate( "update actors set first_name = ?, last_name = ? where id =? ", new BatchPreparedStatementSetter(){ public int getBatchSize() { return actors.size(); } public void setValues(PreparedStatement ps, int i) throws SQLException { ps.setString(1, ((Actor)actors.get(i)).getFirstName()); ps.setString(2, ((Actor)actors.get(i)).getLastName()); ps.setLong(3, ((Actor)actors.get(i)).getId()); } }); return updateCounts; } /** * 批量更新 * @param actors * @return */ public int[] updateBatchActorsSimple(final List<Actor> actors){ //如果对象数组与占位符出现位置一一对应 //SqlParameterSource[] batch = SqlParameterSourceUtils.createBatch(actors.toArray()); List<Object[]> batch = new ArrayList<Object[]>(); for(Actor actor:actors){ Object[] values = new Object[]{//注意顺序 actor.getFirstName(), actor.getLastName(), actor.getId()}; batch.add(values); } int[] updateCounts = this.simpleJdbcTemplate.batchUpdate( "update actors set first_name = ?, last_name = ? where id =? ", batch); return updateCounts; }
(4)测试
Java代码
/**
*
*/
package com.logcd.test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.support.KeyHolder;
import com.logcd.bo.Actor;
import com.logcd.bo.dao.ActorEventDao;
import com.logcd.bo.dao.ActorJdbcTemplateDao;
import junit.framework.TestCase;
/**
* @author logcd
*/
public class SpringJdbcTest extends TestCase {
private ActorEventDao actorEventDao;
private ActorJdbcTemplateDao actorJdbcTemplateDao;
protected void setUp() throws Exception {
super.setUp();
ApplicationContext context = new ClassPathXmlApplicationContext(”springJdbcContext.xml”);
actorEventDao = (ActorEventDao)context.getBean(”actorEventDao”);
actorJdbcTemplateDao = (ActorJdbcTemplateDao)context.getBean(”actorJdbcTemplateDao”);
}
protected void tearDown() throws Exception {
super.tearDown();
}
public void testActorEventDao(){
String creatSql = ”create table ACTORS(“ +
”ID int not null auto_increment,” +
”FIRST_NAME varchar(15),” +
”LAST_NAME varchar(15),” +
”primary key (ID)” +
”);” ;
//建表
actorEventDao.createTableBySQL(creatSql);
String addSql = ”insert into actors(first_name,last_name) values(?,?);”;
Object[] obj = new Object[]{”wang”,”jinming”};
//新增
System.out.println(actorEventDao.operateActor(addSql, obj));
String countSql = ”select count(0) from actors”;
System.out.println(”Count:”+actorEventDao.findRowCountBySQL(countSql));
System.out.println(”Count:”+actorJdbcTemplateDao.findRowCountBySQL(countSql));
//根据id查找
Actor actor = actorEventDao.findActorById(1);
System.out.println(”id:”+actor.getId()+” first_name:”+actor.getFirstName()+” last_name:”+actor.getLastName());
//输出所有
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+” first_name:”+act.getFirstName()+” last_name:”+act.getLastName());
}
Actor newAct=new Actor();
newAct.setFirstName(”jin”);
newAct.setLastName(”ming”);
KeyHolder keyHold =actorEventDao.insertActor(newAct);
System.out.println(keyHold.getKey());//mysql得不到id
List<Actor> list = new ArrayList<Actor>();
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+” first_name:”+act.getFirstName()+” last_name:”+act.getLastName());
act.setLastName(”www”);
list.add(act);
}
actorEventDao.batchUpdateActors(list);
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+” first_name:”+act.getFirstName()+” last_name:”+act.getLastName());
}
}
}
[java] view plain copy print?/**
*
*/
package com.logcd.test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.support.KeyHolder;
import com.logcd.bo.Actor;
import com.logcd.bo.dao.ActorEventDao;
import com.logcd.bo.dao.ActorJdbcTemplateDao;
import junit.framework.TestCase;
/**
* @author logcd
*/
public class SpringJdbcTest extends TestCase {
private ActorEventDao actorEventDao;
private ActorJdbcTemplateDao actorJdbcTemplateDao;
protected void setUp() throws Exception {
super.setUp();
ApplicationContext context = new ClassPathXmlApplicationContext(“springJdbcContext.xml”);
actorEventDao = (ActorEventDao)context.getBean(”actorEventDao”);
actorJdbcTemplateDao = (ActorJdbcTemplateDao)context.getBean(”actorJdbcTemplateDao”);
}
protected void tearDown() throws Exception {
super.tearDown();
}
public void testActorEventDao(){
String creatSql = ”create table ACTORS(“ +
”ID int not null auto_increment,” +
”FIRST_NAME varchar(15),” +
”LAST_NAME varchar(15),” +
”primary key (ID)” +
”);” ;
//建表
actorEventDao.createTableBySQL(creatSql);
String addSql = ”insert into actors(first_name,last_name) values(?,?);”;
Object[] obj = new Object[]{“wang”,“jinming”};
//新增
System.out.println(actorEventDao.operateActor(addSql, obj));
String countSql = ”select count(0) from actors”;
System.out.println(”Count:”+actorEventDao.findRowCountBySQL(countSql));
System.out.println(”Count:”+actorJdbcTemplateDao.findRowCountBySQL(countSql));
//根据id查找
Actor actor = actorEventDao.findActorById(1);
System.out.println(”id:”+actor.getId()+“ first_name:”+actor.getFirstName()+“ last_name:”+actor.getLastName());
//输出所有
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+“ first_name:”+act.getFirstName()+“ last_name:”+act.getLastName());
}
Actor newAct=new Actor();
newAct.setFirstName(”jin”);
newAct.setLastName(”ming”);
KeyHolder keyHold =actorEventDao.insertActor(newAct);
System.out.println(keyHold.getKey());//mysql得不到id
List<Actor> list = new ArrayList<Actor>();
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+“ first_name:”+act.getFirstName()+“ last_name:”+act.getLastName());
act.setLastName(”www”);
list.add(act);
}
actorEventDao.batchUpdateActors(list);
for(Object o:actorEventDao.findAllActors()){
Actor act = (Actor) o;
System.out.println(”id:”+act.getId()+“ first_name:”+act.getFirstName()+“ last_name:”+act.getLastName());
}
}
}
/** * */ package com.logcd.test; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.jdbc.support.KeyHolder; import com.logcd.bo.Actor; import com.logcd.bo.dao.ActorEventDao; import com.logcd.bo.dao.ActorJdbcTemplateDao; import junit.framework.TestCase; /** * @author logcd */ public class SpringJdbcTest extends TestCase { private ActorEventDao actorEventDao; private ActorJdbcTemplateDao actorJdbcTemplateDao; protected void setUp() throws Exception { super.setUp(); ApplicationContext context = new ClassPathXmlApplicationContext("springJdbcContext.xml"); actorEventDao = (ActorEventDao)context.getBean("actorEventDao"); actorJdbcTemplateDao = (ActorJdbcTemplateDao)context.getBean("actorJdbcTemplateDao"); } protected void tearDown() throws Exception { super.tearDown(); } public void testActorEventDao(){ String creatSql = "create table ACTORS(" + "ID int not null auto_increment," + "FIRST_NAME varchar(15)," + "LAST_NAME varchar(15)," + "primary key (ID)" + ");" ; //建表 actorEventDao.createTableBySQL(creatSql); String addSql = "insert into actors(first_name,last_name) values(?,?);"; Object[] obj = new Object[]{"wang","jinming"}; //新增 System.out.println(actorEventDao.operateActor(addSql, obj)); String countSql = "select count(0) from actors"; System.out.println("Count:"+actorEventDao.findRowCountBySQL(countSql)); System.out.println("Count:"+actorJdbcTemplateDao.findRowCountBySQL(countSql)); //根据id查找 Actor actor = actorEventDao.findActorById(1); System.out.println("id:"+actor.getId()+" first_name:"+actor.getFirstName()+" last_name:"+actor.getLastName()); //输出所有 for(Object o:actorEventDao.findAllActors()){ Actor act = (Actor) o; System.out.println("id:"+act.getId()+" first_name:"+act.getFirstName()+" last_name:"+act.getLastName()); } Actor newAct=new Actor(); newAct.setFirstName("jin"); newAct.setLastName("ming"); KeyHolder keyHold =actorEventDao.insertActor(newAct); System.out.println(keyHold.getKey());//mysql得不到id List<Actor> list = new ArrayList<Actor>(); for(Object o:actorEventDao.findAllActors()){ Actor act = (Actor) o; System.out.println("id:"+act.getId()+" first_name:"+act.getFirstName()+" last_name:"+act.getLastName()); act.setLastName("www"); list.add(act); } actorEventDao.batchUpdateActors(list); for(Object o:actorEventDao.findAllActors()){ Actor act = (Actor) o; System.out.println("id:"+act.getId()+" first_name:"+act.getFirstName()+" last_name:"+act.getLastName()); } } }
二、关于操作Blob和Clob问题
spring定义了一个以统一的方式操作各种数据库的Lob类型数据的LobCreator(保存的时候用),同时提供了一个LobHandler为操作二进制字段和大文本字段提供统一接口访问。
(1)配置文件
Xml代码
<bean id=”nativeJdbcExtractor”
class=”org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor”
lazy-init=”true”/>
<bean id=”lobHandler”
class=”org.springframework.jdbc.support.lob.OracleLobHandler”
lazy-init=”true”
p:nativeJdbcExtractor-ref=”nativeJdbcExtractor”/>
<bean id=”defaultLobHandler”
class=”org.springframework.jdbc.support.lob.DefaultLobHandler”
lazy-init=”true” />
<bean id=”jdbcTemplate”
class=”org.springframework.jdbc.core.JdbcTemplate”
p:dataSource-ref=”appDS”
p:nativeJdbcExtractor-ref=”nativeJdbcExtractor”/>
<bean id=”txMangager”
class=”org.springframework.jdbc.datasource.DataSourceTransactionManager”
p:dataSource-ref=”appDS”/>
<tx:annotation-driven transaction-manager=”txMangager” proxy-target-class=”true”/>
[xml] view plain copy print?<bean id=“nativeJdbcExtractor”
class=“org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor”
lazy-init=“true”/>
<bean id=“lobHandler”
class=“org.springframework.jdbc.support.lob.OracleLobHandler”
lazy-init=“true”
p:nativeJdbcExtractor-ref=“nativeJdbcExtractor”/>
<bean id=“defaultLobHandler”
class=“org.springframework.jdbc.support.lob.DefaultLobHandler”
lazy-init=“true” />
<bean id=“jdbcTemplate”
class=“org.springframework.jdbc.core.JdbcTemplate”
p:dataSource-ref=“appDS”
p:nativeJdbcExtractor-ref=“nativeJdbcExtractor”/>
<bean id=“txMangager”
class=“org.springframework.jdbc.datasource.DataSourceTransactionManager”
p:dataSource-ref=“appDS”/>
<tx:annotation-driven transaction-manager=“txMangager” proxy-target-class=“true”/>
<bean id="nativeJdbcExtractor" class="org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor" lazy-init="true"/> <bean id="lobHandler" class="org.springframework.jdbc.support.lob.OracleLobHandler" lazy-init="true" p:nativeJdbcExtractor-ref="nativeJdbcExtractor"/> <bean id="defaultLobHandler" class="org.springframework.jdbc.support.lob.DefaultLobHandler" lazy-init="true" /> <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate" p:dataSource-ref="appDS" p:nativeJdbcExtractor-ref="nativeJdbcExtractor"/> <bean id="txMangager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager" p:dataSource-ref="appDS"/> <tx:annotation-driven transaction-manager="txMangager" proxy-target-class="true"/>
(2)读写
Java代码
@Resource(name = ”lobHandler”)
private LobHandler lobHandler;
@Resource(name = ”jdbcTemplate”)
private JdbcTemplate jdbcTemplate;
public void savePost(final Post post) {
String sql = ” INSERT INTO t_post(post_id,user_id,post_text,post_attach)”
+ ” VALUES(?,?,?,?)”;
jdbcTemplate().execute(sql,
new AbstractLobCreatingPreparedStatementCallback(this.lobHandler) {
protected void setValues(PreparedStatement ps,
LobCreator lobCreator) throws SQLException {
ps.setInt(1, incre.nextIntValue());
ps.setInt(2, post.getUserId());
lobCreator.setClobAsString(ps, 3, post.getPostText());
lobCreator.setBlobAsBytes(ps, 4, post.getPostAttach());
}
});
}
public List findAttachs(final int userId){
String sql = ”SELECT post_id,post_attach FROM t_post where user_id =? and post_attach is not null”;
return jdbcTemplate().query( sql, new Object[] {userId},
new RowMapper() {
public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
Post post = new Post();
int postId = rs.getInt(1);
byte[] attach = lobHandler.getBlobAsBytes(rs, 2);
post.setPostId(postId);
post.setPostAttach(attach);
return post;
}
});
}
相关文章推荐
- jdbc中的Statement和PreparedStatement接口对象
- 使用C++实现JNI接口需要注意的事项
- SQL中的三值逻辑
- SQL Server 作业批量停止
- 结束SQL阻塞的进程
- 动态生成SQL Server视图作业
- 一个jar包里的网站
- 一个jar包里的网站之文件上传
- 一个jar包里的网站之返回对媒体类型
- Spring和ThreadLocal
- Spring Boot 开发微服务
- Spring AOP动态代理-切面
- SQL Server 语句操纵数据库
- SQL(结构化查询语句)
- oracle sql日期比较
- linux快速部署mysql服务器
- Spring整合Quartz(JobDetailBean方式)