java--使用jdbcTemplate进行增删改查
Posted 郑*杰
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了java--使用jdbcTemplate进行增删改查相关的知识，希望对你有一定的参考价值。
一、设置数据库连接信息
文件名：jdbc.propries
jdbc.url=jdbc:mysql://10.0.2.4:63306/test1111111?useUnicode=true&characterEncoding=utf-8&useSSL=false
jdbc.username=gac_trav
jdbc.password=gac@6666
jdbc.driverClassName=com.mysql.cj.jdbc.Driver二、配置druid数据源信息，获取jdbcTemplate对象
<?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"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">
<!--引入外部属性文件，创建数据源对象-->
<context:property-placeholder location="classpath:jdbc.propries"></context:property-placeholder>
<bean id="druidDataSource" class="com.alibaba.druid.pool.DruidDataSource">
<property name="url" value="$jdbc.url"></property>
<property name="username" value="$jdbc.username"></property>
<property name="password" value="$jdbc.password"></property>
<property name="driverClassName" value="$jdbc.driverClassName"></property>
</bean>
<!--创建jdbcTemplate对象，注入数据源-->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="druidDataSource"></property>
</bean>
</beans>
三、获取jdbcTemplate对象，进行数据相关操作
package com.ruqi.jdbctemplate;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;
import java.util.List;
@SpringJUnitConfig(locations = "classpath:beans.xml")
public class JdbcTemplateTest
@Autowired
private JdbcTemplate jdbcTemplate; //拿到数据连接对象后，就可以进行增删改查
// 增删改操作
@Test
public void testJdbcTemplate()
String sql = "INSERT INTO t_emp VALUES(null,?,?,?);";
int rows = jdbcTemplate.update(sql, "小明", 20, "男");
System.out.println(rows);
//查询结果设置到对象中
@Test
public void testSelectObject()
String sql = "select id, name, age, sex from t_emp where id = ?";
// 写法一
User returnUser1 = jdbcTemplate.queryForObject(sql, (rs, rowNum) ->
User user = new User();
user.setAge(rs.getInt("age"));
user.setName(rs.getString("name"));
user.setId(rs.getInt("id"));
user.setSex(rs.getString("sex"));
return user;
, 1);
System.out.println(returnUser1);
// 写法二，本质上跟写法一是一样的
User returnUser2 = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<>(User.class), 2);
System.out.println(returnUser2);
//返回多条数据放到一个集合
@Test
public void selectObjectList()
String sql = "select id, name, age, sex from t_emp;";
List<User> userList = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(User.class));
System.out.println(userList);
// 返回单个值，第二个参数填写返回的数据类型
@Test
public void selectValueObject()
String sql = "select count(1) from t_emp;";
Integer count = jdbcTemplate.queryForObject(sql, Integer.class);
System.out.println(count);
spring学习spring的jdbcTemplate（增删改查封装）
Spring的jdbcTemplate操作
1、Spring框架一站式框架
（1）针对javaee三层，每一层都有解决技术
（2）到dao 层，使用 jdbcTemplate
2、Spring对不同的持久化都进行了封装
（1）jdbcTemplate 对 jdbc 进行封装
3、jdbcTemplate 使用和 dbutils 使用很相似，都是对数据库进行 crud 操作
4、使用jdbcTemplate 实现增删改查操作
增加：
1、导入 jdbcTemplate 相关jar 包
一定要导入相关数据库驱动的 jar 包
2、创建对象，设置数据库信息
3、创建jdbcTemplate 对象，设置数据源
4、调用 jdbcTemplate 对象里面的方法实现操作
//1、增加操作 @Test public void add(){ //创建对象，设置数据库信息 DriverManagerDataSource dataSource=new DriverManagerDataSource(); dataSource.setDriverClassName("com.mysql.jdbc.Driver"); dataSource.setUrl("jdbc:mysql://localhost:3306/url_data"); dataSource.setUsername("root"); dataSource.setPassword("123"); //创建jdbcTemplate 对象，设置数据源 JdbcTemplate jdbcTemplate=new JdbcTemplate(dataSource); //调用 jdbcTemplate 对象里面的方法实现操作 //c创建sql语句 String sql="insert into user values(?,?)"; int row=jdbcTemplate.update(sql, "zhansan","man"); System.out.println("JdbcTemplateDemo1.add()"+row); }
修改：
// 2、修改操作 @Test public void update() { // 创建对象，设置数据库信息 DriverManagerDataSource dataSource = new DriverManagerDataSource(); dataSource.setDriverClassName("com.mysql.jdbc.Driver"); dataSource.setUrl("jdbc:mysql://localhost:3306/url_data"); dataSource.setUsername("root"); dataSource.setPassword("123"); // 创建jdbcTemplate 对象，设置数据源 JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); // 调用 jdbcTemplate 对象里面的方法实现操作 // c创建sql语句 String sql = "update user set sex=? where name=?"; int row = jdbcTemplate.update(sql, "woman","zhangsan"); System.out.println("JdbcTemplateDemo1.add()=" + row); }
删除：
// 3、删除操作 @Test public void delete() { DriverManagerDataSource dataSource = new DriverManagerDataSource(); dataSource.setDriverClassName("com.mysql.jdbc.Driver"); dataSource.setUrl("jdbc:mysql://localhost:3306/url_data"); dataSource.setUsername("root"); dataSource.setPassword("123"); // 创建jdbcTemplate 对象，设置数据源 JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); // 调用 jdbcTemplate 对象里面的方法实现操作 // c创建sql语句 String sql = "delete from user where name=?"; int row = jdbcTemplate.update(sql, "zhangsan"); System.out.println("JdbcTemplateDemo1.add()=" + row); }
查看：
jdbcutil 用于 jdbcTemplate 的区别 /* * (1)jdbcutils * QueryRunner runner = new QueryRunner(datasource); * * 返回对象 * runner.query(sql, new BeanHandler<User>(User.class)); * * 返回list * runner.query(sql, new BeanListHandler<User>(User.class)); * * (2)jdbcTemplate实现查询，有接口RowMapper * jdbcTemplate针对这个接口没有实现具体的类，得到不同类型的数据需要自己心境数据的封装 */
（1）查询返回某一个值
public void count() { DriverManagerDataSource dataSource = new DriverManagerDataSource(); dataSource.setDriverClassName("com.mysql.jdbc.Driver"); dataSource.setUrl("jdbc:mysql://localhost:3306/url_data"); dataSource.setUsername("root"); dataSource.setPassword("123"); // 创建jdbcTemplate 对象，设置数据源 JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); String sql="select count(*) from user"; //第一个参数是sql 语句 //迭戈参数 返回类型的class int count=jdbcTemplate.queryForObject(sql, Integer.class); System.out.println(count); }
（2）查询返回某一个对象
原始方式：
//原始方式 public void testJdbc() throws SQLException { Connection conn=null; PreparedStatement pstmt=null; ResultSet rs=null; //加载驱动 try { Class.forName("com.mysql.jdbc.Driver"); //创建连接 conn=(Connection) DriverManager.getConnection("jdbc:mysql://localhost/url_data", "root", "123"); String sql="select * from user where username=?"; //预编译 pstmt=(PreparedStatement) conn.prepareStatement(sql); pstmt.setString(1, "lisi"); rs=pstmt.executeQuery(); //遍历结果集 while(rs.next()){ //得到返回的结果值 String name=rs.getString("username"); String sex=rs.getString("sex"); User user=new User(); user.setUsername(name); user.setSex(sex); System.out.println(user); } } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); }finally{ rs.close(); pstmt.close(); conn.close(); } }
jdbc 方式：
@Test public void FindObject() { DriverManagerDataSource dataSource = new DriverManagerDataSource(); dataSource.setDriverClassName("com.mysql.jdbc.Driver"); dataSource.setUrl("jdbc:mysql://localhost:3306/url_data"); dataSource.setUsername("root"); dataSource.setPassword("123"); // 创建jdbcTemplate 对象，设置数据源 JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); String sql="select * from user where name=?"; //调用jdbcTemplate //第一个参数：sql语句 //第二个人参数：类似于 dbutils 中的接口RowMapper,需要自己写实现类，实现具体方法，实现数据封装 //第三个参数： 可变参数（sql中传的值） User user = jdbcTemplate.queryForObject(sql, new MyRowMapper(),"lisi"); System.out.println(user.getName()); }
写一个非public class
class MyRowMapper implements RowMapper<User>{ //num:行号 public User mapRow(ResultSet rs, int index) throws SQLException { //1、从结果集里面把数据得到 String name=rs.getString("name"); String sex=rs.getString("sex"); //2、把没我们得到的数据封装到对象里面 User user=new User(); user.setName(name); user.setSex(sex); return user; } }
匿名内部类
（3）查询返回 list 集合
public void FindList(){ DriverManagerDataSource dataSource = new DriverManagerDataSource(); dataSource.setDriverClassName("com.mysql.jdbc.Driver"); dataSource.setUrl("jdbc:mysql://localhost:3306/url_data"); dataSource.setUsername("root"); dataSource.setPassword("123"); // 创建jdbcTemplate 对象，设置数据源 JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource); String sql="select * from user"; //调用jdbcTemplate //第一个参数：sql 语句 //第二个参数RowMapper 接口 //第三个参数：可变参数,可以省略 List<User> list=jdbcTemplate.query(sql, new MyRowMapperList()); for(int i=0;i<list.size();i++){ System.out.println(list.get(i)); } }
实现RowMapper类
class MyRowMapperList implements RowMapper<User>{ //index:行号 public User mapRow(ResultSet rs, int index) throws SQLException { //1、从结果集里面把数据得到 String name=rs.getString("name"); String sex=rs.getString("sex"); //2、把没我们得到的数据封装到对象里面 User user=new User(); user.setName(name); user.setSex(sex); return user; }
5、Spring 配置 c3p0 连接池 和dao 使用jdbcTemplate
（1）Spring 配置 c3p0 连接池
- 导入 jar 包
原始的 c3p0 写法
ComboPooledDataSource datasource=new ComboPooledDataSource(); datasource.setDriverClass("com.mysql.jdbc.Driver"); datasource.setJdbcUrl("jdbc:mysql://localhost:3306/url_data"); datasource.setUser("root"); datasource.setPassword("123");
在xml中配置 c3p0
<!-- 配置 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://localhost:3306/url_data"></property> <property name="user" value="root"></property> <property name="password" value="123"></property> </bean>
（2）dao 使用jdbcTemplate
1、创建 service 和 dao 对象，配置 service 和 dao 对象
2、创建 JdbcTemplate 对象，把 模板对象注入到 dao 里面
3、在 jdbcTemplate 对象里面注入 dataSource 对象
Service类
package cn.itcast.c3p0; public class UserService { private UserDao userDao; public void setUserDao(UserDao userDao) { this.userDao = userDao; } public void add(){ System.out.println("service add....."); userDao.add(); } }
dao类
package cn.itcast.c3p0; import org.springframework.jdbc.core.JdbcTemplate; public class UserDao { //要得到jdbcTemplate 对象 private JdbcTemplate jdbcTemplate;
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
public void add(){ String sql="insert into user values(?,?)"; jdbcTemplate.update(sql,"大力","man"); } }
c3p0.xml 配置：
<?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:content="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.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd"> <!-- bean definitions here --> <!-- 配置 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://localhost:3306/url_data"></property> <property name="user" value="root"></property> <property name="password" value="123"></property> </bean> <!-- 创建service 和 Dao。在Service 中调用dao --> <bean id="userService" class="cn.itcast.c3p0.UserService"> <!-- 注入Dao --> <property name="userDao" ref="userDao"></property> </bean> <bean id="userDao" class="cn.itcast.c3p0.UserDao"> <!-- 注入jdbctemplate对象 --> <property name="jdbcTemplate" ref="jdbcTemplate"></property> </bean> <!-- 创建JdbcTemplate对象 --> <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <!-- 把dataSource 传到 jdbcTemplate里面--> <property name="dataSource" ref="dataSource"></property> </bean> </beans>
测试：
public void testC(){ ApplicationContext context=new ClassPathXmlApplicationContext("c3p0.xml"); UserService userService=(UserService) context.getBean("userService"); userService.add(); }
测试结果：
在数据库 user 表里添加一条数据
以上是关于java--使用jdbcTemplate进行增删改查的主要内容，如果未能解决你的问题，请参考以下文章