1、最主要的代码
Spring 配置文件（beans.xml）
1 <!-- 连接池 --> 2 <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> 3 <!-- 注册驱动 --> 4 <property name="driverClass" value="com.mysql.jdbc.Driver"></property> 5 <!-- 数据库连接 --> 6 <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/school"></property> 7 <!-- 用户 --> 8 <property name="user" value="root"></property> 9 <!-- 密码 --> 10 <property name="password" value="123456"></property> 11 <!--初始化时获取三个连接，取值应在minPoolSize与maxPoolSize之间。Default: 3 --> 12 <property name="initialPoolSize" value="3"></property> 13 <!--连接池中保留的最大连接数。Default: 15 --> 14 <property name="maxPoolSize" value="100"></property> 15 <!--JDBC的标准参数，用以控制数据源内加载的PreparedStatements数量。但由于预缓存的statements 16 属于单个connection而不是整个连接池。所以设置这个参数需要考虑到多方面的因素。 17 如果maxStatements与maxStatementsPerConnection均为0，则缓存被关闭。Default: 0--> 18 <property name="maxStatements" value="200"></property> 19 <!--当连接池中的连接耗尽的时候c3p0一次同时获取的连接数。Default: 3 --> 20 <property name="acquireIncrement" value="2"></property> 21 </bean> 22 23 <!-- Spring提供的，用来代替JDBC连接数据库等操作 --> 24 <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> 25 <property name="dataSource" ref="dataSource"></property> 26 </bean> 27 28 <!-- Dao层 --> 29 <bean id="userDao" class="com.shore.dao.impl.UserDao"> 30 <!-- jdbcTemplate：Spring提供的，用来 在做CRUD操作时，替代打开/获取连接等等（Connection、Statement、ResultSet），固定步骤 --> 31 <property name="jdbcTemplate" ref="jdbcTemplate"></property> 32 </bean>
2、完整代码例子
我用到的jar包：
实例演示：
数据库建表语句
1 create database school; -- 创建数据库 2 use school; -- 使用school数据库3 4 create table user( -- 创建user表 5 id int(4) primary key auto_increment, 6 name varchar(20) not null, 7 age INT(4) not null 8 );
User 实体类
1 package com.shore.entity;
2
3 /**
4 * @author DSHORE/2019-11-9
5 *
6 */
7 public class User {
8 private Integer id;
9 private String name;
10 private Integer age;
11
12 public Integer getId() {
13 return id;
14 }
15 public void setId(Integer id) {
16 this.id = id;
17 }
18
19 public String getName() {
20 return name;
21 }
22 public void setName(String name) {
23 this.name = name;
24 }
25
26 public Integer getAge() {
27 return age;
28 }
29 public void setAge(Integer age) {
30 this.age = age;
31 }
32 }
IUserDao 接口类
1 package com.shore.dao;
2
3 import java.util.List;
4
5 import com.shore.entity.User;
6
7 /**
8 * @author DSHORE/2019-11-9
9 *
10 */
11 public interface IUserDao {
12
13 public void save(User user);//增
14 public void delete(Integer id);//删
15 public void update(User user);//改
16 public User findById(Integer id);//根据id查询
17 public List<User> listAll();//查询所有
18 }
UserDao 接口实现类
1 package com.shore.dao.impl;
2
3 import java.sql.ResultSet;
4 import java.sql.SQLException;
5 import java.util.List;
6
7 import org.springframework.jdbc.core.JdbcTemplate;
8 import org.springframework.jdbc.core.RowMapper;
9
10 import com.shore.dao.IUserDao;
11 import com.shore.entity.User;
12
13 /**
14 * @author DSHORE/2019-11-9
15 *
16 */
17 public class UserDao implements IUserDao {
18 //注入jdbcTemplate（Spring提供的）
19 private JdbcTemplate jdbcTemplate;
20 public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
21 this.jdbcTemplate = jdbcTemplate;
22 }
23
24 @Override //添加
25 public void save(User user) {
26 String sql = "insert into user(name,age) values(?,?)";
27 jdbcTemplate.update(sql, user.getName(),user.getAge());
28 }
29
30 @Override //删除
31 public void delete(Integer id) {
32 jdbcTemplate.update("delete from user where id = ?", id);
33 }
34
35 @Override //修改
36 public void update(User user) {
37 String sql = "update user set age = ? where id = ?";
38 jdbcTemplate.update(sql, user.getAge(), user.getId());
39 }
40
41 @Override //根据id查询
42 public User findById(Integer id) {
43 String sql = "select * from user where id=?";
44 List<User> list = jdbcTemplate.query(sql, new MyResult(), id);
45 if (list != null && list.size() > 0) {
46 return list.get(0);
47 }
48 return null;
49 }
50
51 @Override //查询所有
52 public List<User> listAll() {
53 String sql = "select * from user";
54 List<User> list = jdbcTemplate.query(sql, new MyResult());
55 return list;
56 }
57
58 //内部类 此处的作用：把findById()和listAll()的公共部分代码提出来
59 class MyResult implements RowMapper<User>{
60 @Override
61 // 要把每一行封装成一个User对象
62 public User mapRow(ResultSet rs, int rowNum) throws SQLException {
63 User user = new User();
64 user.setId(rs.getInt("id"));
65 user.setName(rs.getString("name"));
66 return user;
67 }
68 }
69 }
Spring 配置文件（beans.xml）
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xmlns:aop="http://www.springframework.org/schema/aop" 5 xmlns:tx="http://www.springframework.org/schema/tx" 6 xsi:schemaLocation=" 7 http://www.springframework.org/schema/beans 8 http://www.springframework.org/schema/beans/spring-beans.xsd 9 http://www.springframework.org/schema/tx 10 http://www.springframework.org/schema/tx/spring-tx.xsd 11 http://www.springframework.org/schema/aop 12 http://www.springframework.org/schema/aop/spring-aop.xsd"> 13 14 <!-- 连接池 --> 15 <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> 16 <!-- 注册驱动 --> 17 <property name="driverClass" value="com.mysql.jdbc.Driver"></property> 18 <!-- 数据库连接 --> 19 <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/school"></property> 20 <!-- 用户 --> 21 <property name="user" value="root"></property> 22 <!-- 密码 --> 23 <property name="password" value="root"></property> 24 <!--初始化时获取三个连接，取值应在minPoolSize与maxPoolSize之间。Default: 3 --> 25 <property name="initialPoolSize" value="3"></property> 26 <!--连接池中保留的最大连接数。Default: 15 --> 27 <property name="maxPoolSize" value="100"></property> 28 <!--JDBC的标准参数，用以控制数据源内加载的PreparedStatements数量。但由于预缓存的statements 29 属于单个connection而不是整个连接池。所以设置这个参数需要考虑到多方面的因素。 30 如果maxStatements与maxStatementsPerConnection均为0，则缓存被关闭。Default: 0--> 31 <property name="maxStatements" value="200"></property> 32 <!--当连接池中的连接耗尽的时候c3p0一次同时获取的连接数。Default: 3 --> 33 <property name="acquireIncrement" value="2"></property> 34 </bean> 35 36 <!-- Spring提供的，用来代替JDBC连接数据库等操作 --> 37 <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> 38 <property name="dataSource" ref="dataSource"></property> 39 </bean> 40 41 <!-- Dao层 --> 42 <bean id="userDao" class="com.shore.dao.impl.UserDao"> 43 <!-- jdbcTemplate：Spring提供的，用来 在做CRUD操作时，替代打开/获取连接等等（Connection、Statement、ResultSet），固定步骤 --> 44 <property name="jdbcTemplate" ref="jdbcTemplate"></property> 45 </bean> 46 </beans>
测试类
1 package com.shore.test;
2
3 import java.util.List;
4
5 import org.junit.Test;
6 import org.springframework.context.ApplicationContext;
7 import org.springframework.context.support.ClassPathXmlApplicationContext;
8
9 import com.shore.dao.IUserDao;
10 import com.shore.entity.User;
11
12 /**
13 * @author DSHORE/2019-11-9
14 *
15 */
16 public class MyTest {
17
18 private static ApplicationContext context = new ClassPathXmlApplicationContext("beans.xml");
19
20 @Test //添加
21 public void testSaveUser() {
22 User user = new User();
23 user.setName("李四");//插入两条数据：张三，18 和 李四，20
24 user.setAge(20);
25 IUserDao userDao = (IUserDao) context.getBean("userDao");
26 userDao.save(user);
27 }
28
29 @Test //删除
30 public void testDelete() {
31 IUserDao userDao = (IUserDao) context.getBean("userDao");
32 userDao.delete(3);
33 }
34
35 @Test //修改
36 public void testUpdate() {
37 IUserDao userDao = (IUserDao) context.getBean("userDao");
38 User user = userDao.findById(2);
39 user.setAge(26);
40 userDao.update(user);
41 }
42
43 @Test //根据id查询
44 public void testFindById() {
45 IUserDao userDao = (IUserDao) context.getBean("userDao");
46 User user = userDao.findById(2);
47 System.out.println(user); //返回值：[email protected]
48 }
49
50 @Test //查询所有
51 public void testListAll() {
52 IUserDao userDao = (IUserDao) context.getBean("userDao");
53 List<User> users = userDao.listAll();
54 System.out.println(users); //返回值：[[email protected], [email protected]]
55 }
56 }
以上代码，均测试成功。
|
原创作者：DSHORE 作者主页：http://www.cnblogs.com/dshore123/ 原文出自：https://www.cnblogs.com/dshore123/p/11827880.html 欢迎转载，转载务必说明出处。（如果本文对您有帮助，可以点击一下右下角的 推荐，或评论，谢谢！） |
原文地址：https://www.cnblogs.com/dshore123/p/11827880.html
时间： 2024-10-29 17:11:54