当前位置 : 主页 > 编程语言 > 其它开发 >

Spring5——JdbcTemplate笔记

来源:互联网 收集:自由互联 发布时间:2022-06-22
Spring5——JdbcTemplate笔记概念 template,翻译过来是模板的意思,顾名思义,JdbcTemplate就是一个JDBC的模板,它对JDBC进行了封装,可以很方便地实现对数据库的CRUD(增、删、改、查)的操作
Spring5——JdbcTemplate笔记 概念

template,翻译过来是模板的意思,顾名思义,JdbcTemplate就是一个JDBC的模板,它对JDBC进行了封装,可以很方便地实现对数据库的CRUD(增、删、改、查)的操作。

JdbcTemplate准备工作 引入相关的依赖
  • druid-1.1.9.jar
  • mysql-connector-java-5.1.7-bin.jar
  • spring-tx-5.2.6.RELEASE.jar
  • spring-orm-5.2.6.RELEASE.jar
  • 在这里要注意相关jar包的版本,比如说Java连接MySQL的驱动包的版本应该与目的数据库的版本一致
配置数据库连接池、在JdbcTemplate对象中注入DataSource(数据源)

这里用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:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       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
                           http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">

<!--    开启注解扫描-->
    <context:component-scan base-package="com.ws.spring"></context:component-scan>

    <!-- 数据库连接池 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          destroy-method="close">
        <property name="url" value="jdbc:mysql:///study" />
        <property name="username" value="root" />
        <property name="password" value="123" />
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    </bean>

    <!-- JdbcTemplate -->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <!-- 注入DataSource -->
        <property name="dataSource" ref="dataSource"></property>
    </bean>
</beans>
JdbcTemplate的使用 创建service类、创建dao类
package com.spring.service;
//	service类
@Service
public class UserService {

}
package com.spring.dao;
//	dao类
public interface UserDao {
}
package com.spring.dao;
//	dao的实现类
@Repository
public class UserDaoImpl implements UserDao {
}
在service类中注入dao类的对象属性
package com.spring.service;

@Service
public class UserService {
    //注入dao对象
    @Autowired
    private UserDao userDao;
}
在dao类中注入JdbcTemplate对象
package com.spring.dao;

@Repository
public class UserDaoImpl implements UserDao {
    //注入jdbcTemplate对象
    @Autowired
    private JdbcTemplate jdbcTemplate;

}
增删改查
  • 实体类

    package com.spring.entiey;
    
    public class User {
        private Integer id;
        private String name;
        private Integer age;
        private String email;
    
        public User() {
        }
    
        public User(Integer id, String name, Integer age, String email) {
            this.id = id;
            this.name = name;
            this.age = age;
            this.email = email;
        }
    
        @Override
        public String toString() {
            return "User{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    ", age=" + age +
                    ", email='" + email + '\'' +
                    '}';
        }
    
        public Integer getId() {
            return id;
        }
    
        public void setId(Integer id) {
            this.id = id;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    
        public Integer getAge() {
            return age;
        }
    
        public void setAge(Integer age) {
            this.age = age;
        }
    
        public String getEmail() {
            return email;
        }
    
        public void setEmail(String email) {
            this.email = email;
        }
    }
    
    
  • UserDao

    package com.spring.dao;
    
    public interface UserDao {
        //添加的方法
        void add(User user);
    
        //修改的方法
        void updateUser(User user);
    
        //删除的方法
        void deleteUser(int id);
    
        //查询表记录数
        int selectCount();
    
        //查询返回对象
        User findUserInfo(int id);
    
        //查询返回集合
        List<User> findAllUser();
    
        //批量添加数据
        void batchAddUser(List<Object[]> batchArgs);
    }
    
    
  • UserDaoImpl

    package com.spring.dao;
    
    @Repository
    public class UserDaoImpl implements UserDao {
        //注入jdbcTemplate对象
        @Autowired
        private JdbcTemplate jdbcTemplate;
    
        @Override
        public void add(User user) {
            //用jdbcTemplate来操作数据库
            String sql = "insert into userinfo values (?,?,?,?)";
            Object[] args = {user.getId(),user.getName(),user.getAge(),user.getEmail()};
            int update = jdbcTemplate.update(sql,args);
            System.out.println(update);
        }
    
        @Override
        public void updateUser(User user) {
            String sql = "update userinfo set name=? where id=?";
            Object[] args = {user.getName(),user.getId()};
            int update = jdbcTemplate.update(sql, args);
            System.out.println("修改了:"+update);
        }
    
        @Override
        public void deleteUser(int id) {
            String sql = "delete from userinfo where id=?";
            int update = jdbcTemplate.update(sql, id);
            System.out.println("删除了:"+update);
        }
    
        //查询表中的记录数
        @Override
        public int selectCount() {
            String sql = "select count(*) from userinfo";
            Integer count = jdbcTemplate.queryForObject(sql, Integer.class);
            return count;
        }
    
        //查询返回对象
        @Override
        public User findUserInfo(int id) {
            String sql  = "select * from userinfo where id=?";
            User user = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<User>(User.class), id);
            return user;
        }
    
        //查询返回集合
        @Override
        public List<User> findAllUser() {
            String sql = "select * from userinfo";
            List<User> users = jdbcTemplate.query(sql, new BeanPropertyRowMapper<User>(User.class));
            return users;
        }
    
        //批量添加
        @Override
        public void batchAddUser(List<Object[]> batchArgs) {
            String sql = "insert into userinfo values (?,?,?,?)";
            int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);
            System.out.println(Arrays.toString(ints));
        }
    
    
    }
    
    
  • UserService

    package com.spring.service;
    
    @Service
    public class UserService {
        //注入dao对象
        @Autowired
        private UserDao userDao;
    
    
        //添加数据的方法
        public void addUser(User user){
            userDao.add(user);
        }
    
        //修改数据的方法
        public void updateUser(User user){
            userDao.updateUser(user);
        }
    
        //删除数据的方法
        public void deleteUser(int id){
            userDao.deleteUser(id);
        }
    
        //查询表中记录数
        public int findCount(){
            int count = userDao.selectCount();
            return count;
        }
    
        //查询返回对象
        public User findOne(int id){
            User userInfo = userDao.findUserInfo(id);
            return userInfo;
        }
    
        //查询返回集合
        public List<User> findAll(){
            return userDao.findAllUser();
        }
    
        //批量添加数据
        public void batchAdd(List<Object[]> batchArgs){
            userDao.batchAddUser(batchArgs);
        }
    }
    
    
  • 测试类

    package com.spring.testdemo;
    
    @SuppressWarnings({"all"})
    public class TestSpringDemo {
    
      	//添加单条数据
        @Test
        public void testAdd(){
            ApplicationContext context =
                    new ClassPathXmlApplicationContext("bean.xml");
    
            UserService userService = context.getBean("userService", UserService.class);
    
            User user = new User();
            user.setName("111");
            user.setId(10);
            user.setAge(18);
            user.setEmail("shuaiwang2019@126.com");
            System.out.println("user= "+user);
    
            userService.addUser(user);
        }
    
      	//修改单条数据
        @Test
        public void testUpdate(){
            ApplicationContext context =
                    new ClassPathXmlApplicationContext("bean.xml");
    
            UserService userService = context.getBean("userService", UserService.class);
    
            User user = new User();
            user.setName("test");
            user.setId(1);
            System.out.println("user= "+user);
    
            userService.updateUser(user);
        }
    
      	//删除单条数据
        @Test
        public void testDelete(){
            ApplicationContext context =
                    new ClassPathXmlApplicationContext("bean.xml");
    
            UserService userService = context.getBean("userService", UserService.class);
    
            userService.deleteUser(1);
        }
    
    }
    
    
    package com.spring.testdemo;
    
    public class TestJdbcTemplateSelect {
    
        //查询记录数
        @Test
        public void testSelectCount(){
            ApplicationContext context =
                    new ClassPathXmlApplicationContext("bean.xml");
    
            UserService userService = context.getBean("userService", UserService.class);
    
            int count = userService.findCount();
            System.out.println(count);
        }
    
        //查询返回对象
        @Test
        public void testSelectUserInfo(){
            ApplicationContext context =
                    new ClassPathXmlApplicationContext("bean.xml");
    
            UserService userService = context.getBean("userService", UserService.class);
    
            User userInfo = userService.findOne(10);
            System.out.println(userInfo);
        }
    
        //查询返回集合
        @Test
        public void testSelectAll(){
            ApplicationContext context =
                    new ClassPathXmlApplicationContext("bean.xml");
    
            UserService userService = context.getBean("userService", UserService.class);
    
            List<User> users = userService.findAll();
    
            System.out.println(users);
        }
    
        //批量添加
        @Test
        public void testBatchAdd(){
            ApplicationContext context =
                    new ClassPathXmlApplicationContext("bean.xml");
    
            UserService userService = context.getBean("userService", UserService.class);
    
            //要添加的集合
            List<Object[]> batchArgs = new ArrayList<>();
            Object[] o1 = {11,"java",24,"java@126.com"};
            Object[] o2 = {12,"python",30,"python@126.com"};
            Object[] o3 = {13,"c++",40,"c++@126.com"};
            batchArgs.add(o1);
            batchArgs.add(o2);
            batchArgs.add(o3);
            userService.batchAdd(batchArgs);
        }
    
    }
    
    

上一篇:解决opencv在pycharm中代码提示失效
下一篇:没有了
网友评论