Spring为各种持久化技术都提供了简单操作的模板回调。比如jdbc、hibernate、Mybatis以及JPA等。

这里我们就以JDBC为例，看看JDBC template怎么实现CRUD操作。

JdbcTemplate主要提供以下几类方法：

execute方法：可以用于执行任何SQL语句，一般用于执行DDL语句；update方法及batchUpdate方法：update方法用于执行新增、修改、删除等语句；batchUpdate方法用于执行批处理相关语句；query方法及queryForXXX方法：用于执行查询相关语句；call方法：用于执行存储过程、函数相关语句。

这篇文章我们分别使用DriverManagerDataSource和c3p0来配置dataSource，然后初始化jdbc template进行CRUD。

关于Spring配置dataSource的详细知识，请移步这篇文章spring配置datasource三种方式

使用DriverManagerDataSource配置dataSource

1.导入必要的jar包

记得导入mysql的驱动包

2.创建对象，设置数据库信息

// 创建DriverManagerDataSource对象 DriverManagerDataSource driver = new DriverManagerDataSource(); // 设置数据库信息 driver.setDriverClassName("com.mysql.jdbc.Driver"); driver.setUrl("jdbc:mysql://127.0.0.1:3306/spring?useUnicode=true&characterEncoding=utf-8"); driver.setUsername("root"); driver.setPassword("1311664842");

3.创建jdbc template对象，设置数据源

// 创建jdbc template对象，设置数据源 JdbcTemplate jt = new JdbcTemplate(driver);

4.调用jdbc template对象里面的方法实现增删改的操作

String sql = "insert into user values(?,?,?)"; // 返回影响的行数,增加，修改，删除都是使用update int rows = jt.update(sql, 1, "CodeTiger", 26); System.out.println(rows);

5.调用jdbc template对象里面的方法实现查的操作

关于查的操作，我们可以返回单个结果，或者返回一个对象，或者返回一个List。

@Test /** * 使用jdbc template往数据库查询记录 */ public void testJdbcSelect() { JdbcTemplate jt = JDBCTemplateDemo1.getJdbcTemplate(); String sql1 = "select count(*) from user"; // 1 查询返回单个结果 int count = jt.queryForObject(sql1, Integer.class); System.out.println(count); // 2 查询返回一个对象 String sql2 = "select * from user where name = ?"; // 第二个参数表示实现RowMapper接口的一个类，第三个参数表示sql语句中的参数值 User user = jt.queryForObject(sql2, new RowMapper<User>() { @Override /** * 第一个参数表示执行sql语句后返回的结果集，第二个表示当前的行数 */ public User mapRow(ResultSet rs, int num) throws SQLException { User user = new User(); user.setId(rs.getInt("id")); user.setName(rs.getString("name")); user.setAge(rs.getInt("age")); return user; } }, "CodeTiger"); System.out.println(user); // 3 查询返回一个List集合 String sql3 = "select * from user"; @SuppressWarnings({"unchecked", "rawtypes" }) List<User> list = jt.query(sql3, new RowMapper() { @Override public Object mapRow(ResultSet rs, int rowNum) throws SQLException { User user = new User(); user.setId(rs.getInt("id")); user.setName(rs.getString("name")); user.setAge(rs.getInt("age")); return user; } }); for(User u:list) { System.out.println(u); } }

测试输出

3 User [id=1, name=CodeTiger, age=26] User [id=1, name=CodeTiger, age=26] User [id=2, name=xu, age=22] User [id=3, name=lxp, age=20]

第一行是查询返回数据库的记录总条数。第二行是查询单条记录，后面三行是以List的形式返回数据库中所有的对象。

使用c3p0配置dataSource

Spring一大特色之一就是IoC，所以我们怎么能不用它呢，上面是使用代码获取dataSource，下面就使用DI来进行配置c3p0获取dataSource。

6.Spring使用c3p0连接池

要使用c3p0连接池，首先得导入jar包

之后我们在xml中配置c3p0连接池，以及配置jdbc template

<!-- 配置c3p0连接池 --> <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> <!-- 初始化连接参数 --> <property name="driverClass" value="com.mysql.jdbc.Driver"></property> <property name="jdbcUrl" value="jdbc:mysql://127.0.0.1:3306/spring"></property> <property name="user" value="root"></property> <property name="password" value="1311664842"></property> </bean> <!-- 配置Jdbc template --> <bean id="jt" class="org.springframework.jdbc.core.JdbcTemplate"> <!-- 进行初始化 --> <property name="dataSource" ref="dataSource"></property> </bean>

我们新建一个UserDao，与数据库进行交互，使用注解的方式进行初始化，并注入jdbc template对象

@Repository(value = "userDao") public class UserDao { // 使用注解为jdbc template赋值 @Resource(name = "jt") private JdbcTemplate jt; /** * 往数据库添加数据 */ public void add() { String sql = "insert into user values(?,?,?)"; jt.update(sql, 3, "lxp", 20); } }

接着新建一个UserService

@Service(value = "userService") public class UserService { // 以注入方式赋值 @Resource(name = "userDao") private UserDao userDao; /** * 调用dao层的方法往数据库添加数据 */ public void add() { userDao.add(); } }

也是使用注解的方式进行初始化，并注入UserDao的实例。

接着写一个测试方法

@Test /** * 测试使用c3p0进行数据库的连接 */ public void testC3p0() { @SuppressWarnings("resource") ApplicationContext context = new ClassPathXmlApplicationContext("bean.xml"); UserService service = (UserService)context.getBean("userService"); service.add(); }

往数据库插入数据成功。