SpringBoot - JDBC 连接数据库

水深无声 2022-05-29 01:05 184阅读 0赞

> 按照下列顺序即可配置好 SpingBoot 采用 JDBC 方式链接数据库

# 1、配置 Maven 依赖（pom.xml） #

所需的依赖

<dependencies>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <scope>runtime</scope>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>
        </dependencies>

# 2、配置属性文件（application.properties） #

spring.datasource.url=jdbc:mysql://localhost:3306/test
    spring.datasource.username=root
    spring.datasource.password=123456
    spring.datasource.driver-class-name=com.mysql.jdbc.Driver

# 3、代码范例 #

User.java

package com.hsq.test1.bean;
    
    public class User { 
        private int id;
        private String name;
        private int age;
        private int sex;
    
        public User() {
        }
    
        public User(int id, String name, int age, int sex) {
            this.id = id;
            this.name = name;
            this.age = age;
            this.sex = sex;
        }
    
        @Override
        public String toString() {
            return "User{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    ", age=" + age +
                    ", sex=" + sex +
                    '}';
        }
    
        public int getId() {
            return id;
        }
    
        public void setId(int id) {
            this.id = id;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    
        public int getAge() {
            return age;
        }
    
        public void setAge(int age) {
            this.age = age;
        }
    
        public int getSex() {
            return sex;
        }
    
        public void setSex(int sex) {
            this.sex = sex;
        }
    }

UserService.java

package com.hsq.test1.service;
    
    import com.hsq.test1.bean.User;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.jdbc.core.RowMapper;
    import org.springframework.stereotype.Service;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.util.List;
    
    @Service
    public class UserService { 
    
        @Autowired
        private JdbcTemplate jdbcTemplate;
        public List<User> getAllMessage(){
            String sql="SELECT ID,NAME,AGE,SEX FROM USERS";
            return jdbcTemplate.query(sql, new RowMapper<User>() {
                @Override
                public User mapRow(ResultSet resultSet, int rowNum) throws SQLException {
                    return new User(
                            resultSet.getInt("id"),
                            resultSet.getString("name"),
                            resultSet.getInt("age"),
                            resultSet.getInt("sex")
                            );
                }
            });
        }
    }

UserController.java

package com.hsq.test1;
    
    import com.hsq.test1.bean.User;
    import com.hsq.test1.service.UserService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    import java.util.List;
    
    @RestController
    public class UserController { 
        @Autowired
        private UserService service;
        @GetMapping("/getUser")
        public List<User> getUser(){
            List<User> list = service.getAllMessage();
            return list;
        }
    }

# 运行 #

然后启动项目，访问地址： [http://localhost:8080/getUser][http_localhost_8080_getUser]  
结果如下：

[{"id":1,"name":"asdf","age":1,"sex":1},{"id":2,"name":"aswer","age":2,"sex":0},{"id":3,"name":"hty","age":3,"sex":1}]

## [demo下载][demo] ##

[http_localhost_8080_getUser]: http://localhost:8080/getUser
[demo]: https://download.csdn.net/download/qq_34158598/10286766