SpringBoot 连接数据库

傷城~ 2021-11-09 05:28 439阅读 0赞

### **添加数据库信息** ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzg3NjU0OA_size_16_color_FFFFFF_t_70][]

该数据库下创建名为t\_table的表，并添加模拟字段，脚本如下：

DROP TABLE IF EXISTS `t_table`;
     
    CREATE TABLE `t_table` (
      `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '用户ID',
      `real_name` varchar(32) NOT NULL COMMENT '用户名称',
      `live_address` varchar(32) NOT NULL COMMENT '用户居住地址',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

数据库创建完成，下面开始介绍数据库连接的几种集成方式。

### **配置文件信息（yml / properties）** ###

spring:
      datasource:
        url: jdbc:mysql://127.0.0.1:3306/springboot_db?useUnicode=true&characterEncoding=UTF-8&useSSL=false
        driverClassName: com.mysql.jdbc.Driver
        username: root
        password: root
        type: com.alibaba.druid.pool.DruidDataSource

注意：配置文件会因为依赖的不完整而导致报红，所以建议先添加maven依赖。

### 一 集成JdbcTemplate ###

**添加Maven依赖**

<dependency>
    	<groupId>mysql</groupId>
    	<artifactId>mysql-connector-java</artifactId>
    	<version>5.1.25</version>
    </dependency>
    
    
    <dependency>
    	<groupId>org.springframework.boot</groupId>
    	<artifactId>spring-boot-starter-jdbc</artifactId>
    </dependency>
    
    
    <dependency>
    	<groupId>com.alibaba</groupId>
    	<artifactId>druid</artifactId>
    	<version>1.1.12</version>
    </dependency>

**创建实体类（entity）**

public class TableEntity {
        private Long id;
        private String realName;
        private String liveAddress;
    
        public TableEntity() { }
        public TableEntity(Long id, String realName, String liveAddress) {
            this.id = id;
            this.realName = realName;
            this.liveAddress = liveAddress;
        }
        // get | set
    }

**创建接口（Dao）**

public interface TableDao {
        //添加
        int add(TableEntity tableEntity);
    }

**实现接口（service）**

@Service
    public class TableService implements TableDao {
    
        /**
         *  NamedParameterJdbcTemplate类拓展了JdbcTemplate类，对JdbcTemplate类进行了封装从而支持命名参数特性。
         *  
         *  NamedParameterJdbcTemplate主要提供三类方法：execute方法、query及queryForXXX方法、update及batchUpdate方法。
         */
    
        @Autowired
        private NamedParameterJdbcTemplate jdbcTemplate;
    
        @Override
        public int add(TableEntity tableEntity) {
            String sql = "insert into t_table(id,real_name,live_address) values(:id,:realName,:liveAddress)";
            Map<String, Object> param = new HashMap<>();
            param.put("id",tableEntity.getId());
            param.put("realName", tableEntity.getRealName());
            param.put("liveAddress", tableEntity.getLiveAddress());
            return jdbcTemplate.update(sql, param);
        }
    }

**测试，接口（controller）**

@RestController
    @RequestMapping("table")
    public class TableController {
    
        @Autowired
        private TableService tableService;
    
        @RequestMapping("/add")
        public String add(){
            TableEntity tableEntity = new TableEntity();
            tableEntity.setId(3L);
            tableEntity.setRealName("任千行");
            tableEntity.setLiveAddress("至尊盟");
            tableService.add(tableEntity);
            return "success";
        }
    }

访问：[http://localhost:8080/table/add][http_localhost_8080_table_add]

返回success则插入成功！

![20190805112846251.png][]

### 二 与MyBatis集成（项目中最常用的一种方式） ###

接着上边的数据，来一个查询测试。

**先引入starter**

<dependency>
    	<groupId>org.mybatis.spring.boot</groupId>
    	<artifactId>mybatis-spring-boot-starter</artifactId>
    	<version>1.1.1</version>
    </dependency>

MyBatis 可以使用简单的 XML 或注解来配置和映射原生类型、接口和 Java 的 POJO（Plain Old Java Objects，普通老式 Java 对象）为数据库中的记录。

所以我们首先需要配置xml文件文件的存储路径（mapper目录）

**接下来开始在application.yml中进行配置：**

mybatis:
      #定义xml文件路径，必须保持一致
      mapper-locations: classpath*:com.example.demo.dao/*.xml
      #接口映射路劲
      type-aliases-package: com.example.demo.dao.TableDao

**定义xml文件（这里只做查询）**

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    
    <mapper namespace="com.example.demo.dao.TableDao">
        <resultMap type="com.example.demo.entity.TableEntity" id="tableMap">
            <result property="id" column="id"/>
            <result property="realName" column="real_name"/>
            <result property="liveAddress" column="live_address"/>
        </resultMap>
    
        <select id="queryTable" resultMap="tableMap">
            select id,real_name,live_address from t_table
        </select>
    
    </mapper>

注意：返回值如果不是resultMap的id，则实体类属性名称必须和数据库列命保持一致，

**查询接口（dao）**

@Mapper
    public interface TableDao{
        //添加接口
        int add(TableEntity tableEntity);
        //查询接口
        List<TableEntity> queryTable();
    }

**实现接口（service）**

@Service
    public class TableService implements TableDao {
    
        @Autowired
        private NamedParameterJdbcTemplate jdbcTemplate;
    
        @Autowired
        private  TableDao tableDao;
    
        //添加数据信息
        @Override
        public int add(TableEntity tableEntity) {
            String sql = "insert into t_table(id,real_name,live_address) values(:id,:realName,:liveAddress)";
            Map<String, Object> param = new HashMap<>();
            param.put("id",tableEntity.getId());
            param.put("realName", tableEntity.getRealName());
            param.put("liveAddress", tableEntity.getLiveAddress());
            return jdbcTemplate.update(sql, param);
        }
        //查询table信息
        @Override
        public List<TableEntity> queryTable() {
            return tableDao.queryTable();
        }
    }

访问（controller）

@RestController
    @RequestMapping("table")
    public class TableController {
    
        @Autowired
        private TableService tableService;
        
        //查询信息
        @RequestMapping("/query")
        public List<TableEntity> queryTable(){
            List<TableEntity> list = tableService.queryTable();
            for (TableEntity t : list) {
                System.out.println("标识:" + t.getId() + " 姓名:" +  t.getRealName() + " 住址:" +  t.getLiveAddress());
            }
            return list;
        }
        //添加信息
        @RequestMapping("/add")
        public String add(){
            TableEntity tableEntity = new TableEntity();
            tableEntity.setId(3L);
            tableEntity.setRealName("任千行");
            tableEntity.setLiveAddress("至尊盟");
            tableService.add(tableEntity);
            return "success";
        }
    }

访问：[http://localhost:8080/table/query][http_localhost_8080_table_query]

控制台输出：

![20190805153100297.png][]

### **三 集成 JPA** ###

**老样子，加依赖**

<dependency>
    	<groupId>org.springframework.boot</groupId>
    	<artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>

JPA(java persistence api)，它并不是一个框架，而是一组规范。所以根据JPA规范我们在POJO类增加Entity的注解，并指定表名（如果不指定，默认的表名为类名称），然后指定ID及其生成策略，上代码：

**Entity**

import javax.persistence.Entity;
    import javax.persistence.GeneratedValue;
    import javax.persistence.Id;
    
    @Entity(name = "t_table")
    public class TableJpaEntity {
        @Id  //表明ID
        @GeneratedValue  //JPA要求每一个实体Entity,必须有且只有一个主键,该注解提供了主键生成策略
        private Long id;
        private String realName;
        private String liveAddress;
    
        //get | set 方法
    }

**创建DAO**

@Mapper
    public interface TableJpaDao extends JpaRepository<TableJpaEntity, Long> {
         /**
         *
         * 我们在这里直接继承 JpaRepository
         * 这里面已经有很多现成的方法了，只需要拿来用即可
         * 这也是JPA的一大优点
         *
         * 我们也可以自己实现JPQL（JPA支持的一种类SQL的查询）
         */
    
        // 通过名称获取信息
        @Query("select tab from com.example.demo.entity.TableJpaEntity tab where real_name=:realName")
        List<TableJpaEntity> queryByRealName(@Param("realName") String realName);
    }

想看JpaRepository中的一些方法，直接点进源码就OK了。

**创建service**

@Service
    public class TableJpaService{
        @Autowired
        private TableJpaDao tableJpaDao;
    
        public List<TableJpaEntity> findAll(){
            // 这里我们就可以直接使用 findAll 方法
            return tableJpaDao.findAll();
        }
    
        public List<TableJpaEntity> queryByRealName(@Param("realName") String realName){
          return tableJpaDao.queryByRealName(realName);
        }
    }

**controller**

@RestController
    @RequestMapping("table")
    public class TableController {
    
        @Autowired
        private TableJpaService tableJpaService;
    
        @RequestMapping("/fillAll")
        public List<TableJpaEntity> fillAll(){
            List<TableJpaEntity> list = tableJpaService.findAll();
            for (TableJpaEntity t : list) {
                System.out.println("标识:" + t.getId() + " 姓名:" +  t.getRealName() + " 住址:" +  t.getLiveAddress());
            }
            return list;
        }
    
        @RequestMapping("/queryByRealName")
        public List<TableJpaEntity> queryByRealName(String realName){
            List<TableJpaEntity> list = tableJpaService.queryByRealName(realName);
            for (TableJpaEntity t : list) {
                System.out.println("标识:" + t.getId() + " 姓名:" +  t.getRealName() + " 住址:" +  t.getLiveAddress());
            }
            return list;
        }
    }

访问： [http://localhost:8080/table/fillAll][http_localhost_8080_table_fillAll] \\

![20190805165523408.png][]

访问（自定义）：[http://localhost:8080/table/queryByRealName?realName=][http_localhost_8080_table_queryByRealName_realName]任千行

![20190805173946691.png][]

更多命名查询可访问 [https://www.jianshu.com/p/7f2569db8884][https_www.jianshu.com_p_7f2569db8884]

好了，以上就是连接数据库的三种方式。

最后奉上我测试的项目结构图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzg3NjU0OA_size_16_color_FFFFFF_t_70 1][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzg3NjU0OA_size_16_color_FFFFFF_t_70]: /images/20211109/a43af083cbd54721ba182812f96d9e68.png
[http_localhost_8080_table_add]: http://localhost:8080/table/add
[20190805112846251.png]: /images/20211109/1fe9f091d8314ce88dce60c7536bf526.png
[http_localhost_8080_table_query]: http://localhost:8080/table/query
[20190805153100297.png]: /images/20211109/cb9c0d5d692a41919748d609837962a9.png
[http_localhost_8080_table_fillAll]: http://localhost:8080/table/fillAll
[20190805165523408.png]: /images/20211109/534968e4926c4b68bb8ecfb0fe86eb9b.png
[http_localhost_8080_table_queryByRealName_realName]: http://localhost:8080/table/queryByRealName?realName=%E4%BB%BB%E5%8D%83%E8%A1%8C
[20190805173946691.png]: /images/20211109/67abd0dfc96d477dbaeaf1cded662cf4.png
[https_www.jianshu.com_p_7f2569db8884]: https://www.jianshu.com/p/7f2569db8884
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzg3NjU0OA_size_16_color_FFFFFF_t_70 1]: /images/20211109/29689e7da99f4df2bff04682b38ce54c.png