Spring boot 整合JDBC 【springboot整合持久层技术系列】

淡淡的烟草味﹌ 2022-11-30 01:32 137阅读 0赞

第一步：首先导入Maven依赖：

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-jdbc</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid</artifactId>
        <version>1.1.23</version>
    </dependency>
    <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <scope>runtime</scope>
                <version>8.0.21</version>
     </dependency>

在application.properites文件中配置数据源

spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
    spring.datasource.username=root
    spring.datasource.password=123
    spring.datasource.url=jdbc:mysql://localhost:3306/ssmbuild

创建一个User实体：

package com.example.demo.bean;
    
    public class User {
        private Integer id;
        private String username;
        private String address;
    
        public Integer getId() {
            return id;
        }
    
        public void setId(Integer id) {
            this.id = id;
        }
    
        public String getUsername() {
            return username;
        }
    
        public void setUsername(String username) {
            this.username = username;
        }
    
        public String getAddress() {
            return address;
        }
    
        public void setAddress(String address) {
            this.address = address;
        }
    
    //    public User(Integer id, String username, String address) {
    //        this.id = id;
    //        this.username = username;
    //        this.address = address;
    //    }
    
        @Override
        public String toString() {
            return "User{" +
                    "id=" + id +
                    ", username='" + username + '\'' +
                    ", address='" + address + '\'' +
                    '}';
        }
    }

创建一个业务层

package com.example.demo.service;
    
    import com.example.demo.bean.User;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.jdbc.core.BeanPropertyRowMapper;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.stereotype.Service;
    
    import java.util.List;
    
    @Service
    public class UserService {
    
        @Autowired
        JdbcTemplate jdbcTemplate;
        public Integer addUser(User user){
            return jdbcTemplate.update("insert into user(username,address) values(?,?)",user.getUsername(),user.getAddress());
        }
    
        public Integer updateUsernameByid(User user){
            return jdbcTemplate.update("update user set username=? where id=?",user.getUsername(),user.getId());
        }
    
        public Integer deleteUserById(Integer id){
            System.out.println("hah");
            return jdbcTemplate.update("delete from user where id=?",id);
        }
    
        public List<User> getAllUser(){
            System.out.println("haha");
            System.out.println("jajaj");
            return jdbcTemplate.query("select * from user", new BeanPropertyRowMapper<>(User.class)
            );
        }
    }

最后在单元测试类中进行测试：

package com.example.demo;
    
    import com.example.demo.bean.User;
    import com.example.demo.service.UserService;
    import org.junit.jupiter.api.Test;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    
    import java.util.List;
    
    @SpringBootTest
    public class DemoApplicationTests {
    
        @Autowired
        UserService userservice;
    
        @Test
        void contextLoads() {
            User user=new User();
            user.setAddress("张家口市");
            user.setUsername("家煦");
            userservice.addUser(user);
    
    
        }
    
        @Test
        public void Test1(){
            User user =new User();
            user.setAddress("保定");
            user.setUsername("李四");
            user.setId(1);
            userservice.updateUsernameByid(user);
        }
    
        @Test
        public void Test2(){
            User user=new User();
            user.setId(1);
            userservice.deleteUserById(1);
    //        System.out.println(Test3());
        }
    
        @Test
        public void Test3(){
    //        System.out.println(userservice.getAllUser());
            List<User> userlist=userservice.getAllUser();
            System.out.println(userlist);
            return userlist;
            System.out.println("123");
    
    
        }
    
    }

以上就是JDBC和spring boot的整合