45fan.com - 路饭网

搜索: 您的位置主页 > 网络频道 > 阅读资讯:怎么样使用JdbcTemplate增加一组数据?

怎么样使用JdbcTemplate增加一组数据?

2016-08-27 12:33:42 来源:www.45fan.com 【

怎么样使用JdbcTemplate增加一组数据?

一个使用JdbcTemplate增加一组数据的完整的例子,简单的代码不再解释:

1) 首先来创建一个数据库和表,这里用的是Sql server数据库:
create database Human
go

create table Person
(
id int primary key,
firstName varchar(20),
lastName varchar(20)
)
go

2) 创建一个Person类:
package cn.itcast;

public class Person {
private int id;

private String firstName;

private String lastName;

public String getFirstName() {
return firstName;
}

public void setFirstName(String firstName) {
this.firstName = firstName;
}

public int getId() {
return id;
}

public void setId(int id) {
this.id = id;
}

public String getLastName() {
return lastName;
}

public void setLastName(String lastName) {
this.lastName = lastName;
}
}

3) 创建一个 MyBatchPreparedStatementSetter 类。此类实现 BatchPreparedStatementSetter 接口。
package cn.itcast;

import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;

import org.springframework.jdbc.core.BatchPreparedStatementSetter;

public class MyBatchPreparedStatementSetter implements
BatchPreparedStatementSetter {

//这里用于测试的是一组Person对象。
List<Person> persons;

public void setPersons(List<Person> persons) {
this.persons = persons;
}

//重写 BatchPreparedStatementSetter 的 setValues() 和 getBatchSize() 方法。
//setValues() 方法用于设置 sql 语句里面的参数
public void setValues(PreparedStatement ps, int index) throws SQLException {
Person person = persons.get(index);
ps.setInt(1, person.getId());
ps.setString(2, person.getFirstName());
ps.setString(3, person.getLastName());
}
//getBatchSize()返回这一组数据的大校
public int getBatchSize() {
return persons.size();
}

}

4) 创建一个 MyJdbcTemplate 类:
package cn.itcast;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;

public class MyJdbcTemplate {

//定义一个 JdbcTemplate 对象,用于调用 batchUpdate()方法。
private JdbcTemplate jdbcTemplate;

public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}

public int[] updatePersons() {
//从xml配置文件中读取出注册好的 MyBatchPreparedStatementSetter 对象
ApplicationContext context = new ClassPathXmlApplicationContext(
"applicationContext.xml");
String sql = "insert into Person values (?,?,?)";
MyBatchPreparedStatementSetter setter = (MyBatchPreparedStatementSetter)

context
.getBean("myBatchPreparedStatementSetter");
return jdbcTemplate.batchUpdate(sql, setter);
}
}

5) 一个客户端的类:
package cn.itcast;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Client {

private static Log log = LogFactory.getLog(Client.class);

public static void main(String[] args) {
ApplicationContext context = null;
//从xml文件中读取出已经注册好的MyJdbcTemplate对象:
context = new ClassPathXmlApplicationContext("/applicationContext.xml");
MyJdbcTemplate myJdbcTemplate = (MyJdbcTemplate) context
.getBean("myJdbcTemplate");
//调用MyJdbcTemplate的updatePersons()方法。此方法返回一个整型数组,数组里的每一个数如果是 1

就说明sql语句执行成功。
int[] arr = myJdbcTemplate.updatePersons();
for (int n : arr) {
if (n == 1) {
log.info("增加成功");
}
}
}
}

6) 数据库连接配置信息的属性文件 jdbc.properties:
url=jdbc:sqlserver://127.0.0.1:1433;database=Study
driverClassName=com.microsoft.sqlserver.jdbc.SQLServerDriver
username=sa
password=

7) XML 文件 applicationContext.xml:
<?xml version="1.0" encoding="gb2312"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring

-beans.dtd">

<beans>

//注册一个PropertyPlaceholderConfigurer,此Bean的location属性告诉Spring去哪找配置信息。
<bean id="propertyConfigurer"

class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="location">
<value>jdbc.properties</value>
</property>
</bean>

//注册一个DataSource,此例用的是Spring自带的DriverManagerDataSource
<bean id="dataSource"

class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName">
<value>${driverClassName}</value>
</property>
<property name="url">
<value>${url}</value>
</property>
<property name="username">
<value>${username}</value>
</property>
<property name="password">
<value>${password}</value>
</property>
</bean>

//注册一个JdbcTemplate,此Bean的dataSource属性引用上面的dataSource
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource">
<ref bean="dataSource" />
</property>
</bean>

//注册一个我们自定义的MyJdbcTemplate,此Bean的jdbcTemplate属性引用上面的jdbcTemplate
<bean id="myJdbcTemplate" class="cn.itcast.MyJdbcTemplate">
<property name="jdbcTemplate">
<ref bean="jdbcTemplate" />
</property>
</bean>

//注册5个Person对象
<bean id="person1" class="cn.itcast.Person">
<property name="id">
<value>1</value>
</property>
<property name="firstName">
<value>田</value>
</property>
<property name="lastName">
<value>三</value>
</property>
</bean>
<bean id="person2" class="cn.itcast.Person">
<property name="id">
<value>2</value>
</property>
<property name="firstName">
<value>常</value>
</property>
<property name="lastName">
<value>四</value>
</property>
</bean>
<bean id="person3" class="cn.itcast.Person">
<property name="id">
<value>3</value>
</property>
<property name="firstName">
<value>金</value>
</property>
<property name="lastName">
<value>五</value>
</property>
</bean>
<bean id="person4" class="cn.itcast.Person">
<property name="id">
<value>4</value>
</property>
<property name="firstName">
<value>徐</value>
</property>
<property name="lastName">
<value>六</value>
</property>
</bean>
<bean id="person5" class="cn.itcast.Person">
<property name="id">
<value>5</value>
</property>
<property name="firstName">
<value>张</value>
</property>
<property name="lastName">
<value>七</value>
</property>
</bean>

//注册一个MyBatchPreparedStatementSetter,设置它的persons属性,此属性是一个包含Person的List


//这里的就引用上面注册好的5个Person对象
<bean id="myBatchPreparedStatementSetter"

class="cn.itcast.MyBatchPreparedStatementSetter">
<property name="persons">
<list>
<ref bean="person1" />
<ref bean="person2" />
<ref bean="person3" />
<ref bean="person4" />
<ref bean="person5" />
</list>
</property>
</bean>

</beans>

8) Log4j配置文件log4j.xml:
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
<log4j:configuration debug="false" xmlns:log4j="http://jakarta.apache.org/log4j/">
<appender name="systemout" class="org.apache.log4j.ConsoleAppender">
<layout class="org.apache.log4j.SimpleLayout" />
</appender>
<root>
<level value="info" />
<appender-ref ref="systemout" />
</root>
</log4j:configuration>

9)运行:
INFO - 增加成功
INFO - 增加成功
INFO - 增加成功
INFO - 增加成功
INFO - 增加成功

我们看到输出了5条增加成功的信息,
再来看看数据库中Person表:
select * from Person
1田三
2常四
3金五
4徐六
5张七

 

本文地址:http://www.45fan.com/a/question/68388.html
Tags: 一个 一组 JdbcTemplate
编辑:路饭网
关于我们 | 联系我们 | 友情链接 | 网站地图 | Sitemap | App | 返回顶部