Spring Boot 整合JDBC

今天主要讲解一下SpringBoot如何整合JDBC,没啥理论好说的,直接上代码,看项目整体结构

看一下对应的pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <artifactId>spring_boot_jdbc</artifactId>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.2.RELEASE</version>
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>

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


        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.36</version>
            <scope>runtime</scope>
        </dependency>

        <!--阿里巴巴数据源-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.5</version>
        </dependency>

        <!--支持web开发-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

    </dependencies>

</project>

定义User.java

package com.springboot.jdbc.bean;

import java.math.BigDecimal;

/**
* @Author 18011618
* @Date 9:49 2018/7/9
* @Function 用户信息
*/
public class User {

  public User(Long id, String username) {
    super();
    this.id = id;
    this.username = username;
  }

  public User() {
    super();
  }

  private Long id;

  private String username;

  public Long getId() {
    return this.id;
  }

  public void setId(Long id) {
    this.id = id;
  }

  public String getUsername() {
    return this.username;
  }

  public void setUsername(String username) {
    this.username = username;
  }


}

定义数据源配置,这里使用druid,所以需要写一个配置类

package com.springboot.jdbc.config;
 
import java.sql.SQLException;
import javax.sql.DataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
/**
* @Author 18011618
* @Date 17:19 2018/7/16
* @Function druid配置
*/
@Configuration
public class DruidConfig {
	
	@Value("${spring.datasource.url}")
	private String dbUrl;
 
	@Value("${spring.datasource.username}")
	private String username;
 
	@Value("${spring.datasource.password}")
	private String password;
 
	@Value("${spring.datasource.driver-class-name}")
	private String driverClassName;
 
	@Value("${spring.datasource.initialSize}")
	private int initialSize;
 
	@Value("${spring.datasource.minIdle}")
	private int minIdle;
 
	@Value("${spring.datasource.maxActive}")
	private int maxActive;
 
	@Value("${spring.datasource.maxWait}")
	private int maxWait;
 
	@Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
	private int timeBetweenEvictionRunsMillis;
 
	@Value("${spring.datasource.minEvictableIdleTimeMillis}")
	private int minEvictableIdleTimeMillis;
 
	@Value("${spring.datasource.validationQuery}")
	private String validationQuery;
 
	@Value("${spring.datasource.testWhileIdle}")
	private boolean testWhileIdle;
 
	@Value("${spring.datasource.testOnBorrow}")
	private boolean testOnBorrow;
 
	@Value("${spring.datasource.testOnReturn}")
	private boolean testOnReturn;
 
	@Value("${spring.datasource.poolPreparedStatements}")
	private boolean poolPreparedStatements;
 
	@Value("${spring.datasource.filters}")
	private String filters;
	
	@Value("${spring.datasource.logSlowSql}")
	private String logSlowSql;
	
	@Bean
	@Primary //选择默认的数据源
	public DataSource dataSource(){

		DruidDataSource datasource = new DruidDataSource();
		datasource.setUrl(dbUrl);
		datasource.setUsername(username);
		datasource.setPassword(password);
		datasource.setDriverClassName(driverClassName);
		datasource.setInitialSize(initialSize);
		datasource.setMinIdle(minIdle);
		datasource.setMaxActive(maxActive);
		datasource.setMaxWait(maxWait);
		datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
		datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
		datasource.setValidationQuery(validationQuery);
		datasource.setTestWhileIdle(testWhileIdle);
		datasource.setTestOnBorrow(testOnBorrow);
		datasource.setTestOnReturn(testOnReturn);
		datasource.setPoolPreparedStatements(poolPreparedStatements); 
		try {
			datasource.setFilters(filters);
		} catch (SQLException e) {

			e.printStackTrace();
		}
		return datasource;
	}

	/**
	 *
	 * @return 添加登录权限
	 */
	@Bean
	    public ServletRegistrationBean druidServlet() {
	        ServletRegistrationBean reg = new ServletRegistrationBean();
	        reg.setServlet(new StatViewServlet());
	        reg.addUrlMappings("/druid/*");
	        reg.addInitParameter("loginUsername", username);
	        reg.addInitParameter("loginPassword", password);
	        reg.addInitParameter("logSlowSql", logSlowSql);
	        return reg;
	    }

	/**
	 * 过滤规则
	 * @return
	 */
	@Bean
	    public FilterRegistrationBean filterRegistrationBean() {
	        FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
	        filterRegistrationBean.setFilter(new WebStatFilter());
	        filterRegistrationBean.addUrlPatterns("/*");
	        filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
	        filterRegistrationBean.addInitParameter("profileEnable", "true");
	        return filterRegistrationBean;
	    }
}

上面指定druid的属性配置,和用户登录的账号信息以及对应的过滤规则:

下面定义数据访问接口和对应的实现:

package com.springboot.jdbc.resposity;

import com.springboot.jdbc.bean.User;

/**
 * @Author 18011618
 * @Description
 * @Date 13:00 2018/7/13
 * @Modify By
 */
public interface IUserDAO {
    User findUserById(long id);
}
package com.springboot.jdbc.resposity;

import com.springboot.jdbc.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.Repository;

import java.util.List;

/**
 * @Author 18011618
 * @Description 使用JdbcTemplate模板
 * @Date 13:09 2018/7/13
 * @Modify By
 */
@Repository
public class UserDAO implements IUserDAO {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Override
    public User findUserById(long id) {
        List<User> list = jdbcTemplate.query("select * from user where id = ?", new Object[]{id}, new BeanPropertyRowMapper(User.class));
        if(list!=null && list.size()>0){
            User account = list.get(0);
            return account;
        }else{
            return null;
        }
    }
}

数据访问层很简单,直接注入JdbcTemplate模板即可,下面再看对应的service和实现

package com.springboot.jdbc.service;

import com.springboot.jdbc.bean.User;

/**
 * @Author 18011618
 * @Description
 * @Date 13:01 2018/7/13
 * @Modify By
 */
public interface IUserService {
    User findUser(long id);
}
package com.springboot.jdbc.service;

import com.springboot.jdbc.bean.User;
import com.springboot.jdbc.resposity.IUserDAO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * @Author 18011618
 * @Description
 * @Date 13:19 2018/7/13
 * @Modify By
 */
@Service
public class UserService implements IUserService {
    @Autowired
    private IUserDAO userDAO;
    @Override
    public User findUser(long id) {
        return userDAO.findUserById(id);
    }
}

写一个测试的controller:

package com.springboot.jdbc.controller;

import com.springboot.jdbc.bean.User;
import com.springboot.jdbc.service.IUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

/**
 * @Author 18011618
 * @Description
 * @Date 13:00 2018/7/13
 * @Modify By
 */
@RestController
public class UserController {
    @Autowired
    private IUserService userService;
    @GetMapping("/findUser/{id}")
    public User findUser(@PathVariable long id){
        return userService.findUser(id);
    }
}

对应的application.yaml配置文件

server:
  port: 8888

spring:
    datasource:
        driver-class-name: com.mysql.jdbc.Driver #加载数据库的驱动
        filters: stat,wall,log4j #过滤类型
        initialSize: 5 #资源池初始化大小
        maxActive: 20 #资源池最大**数
        maxOpenPreparedStatements: 20
        maxWait: 60000 #最大等待时间
        minEvictableIdleTimeMillis: 300000
        minIdle: 1 #最小空闲数量
        password: 123123
        poolPreparedStatements: true
        testOnBorrow: false
        testOnReturn: false
        testWhileIdle: true
        timeBetweenEvictionRunsMillis: 60000
        type: com.alibaba.druid.pool.DruidDataSource
        url: jdbc:mysql://localhost:3306/emp
        username: root
        validationQuery: select 'x'
        logSlowSql: true

写一个启动应用类:

package com.springboot.jdbc;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * @Author 18011618
 * @Description
 * @Date 13:22 2018/7/13
 * @Modify By
 */
@SpringBootApplication
@EnableAutoConfiguration
public class JdbcTemplateApplication {
    public static void main(String[] args) {
        SpringApplication.run(JdbcTemplateApplication.class,args);
    }
}
到此为止代码和配置文件都讲解完了,接下来进行创建数据库和数据表:
SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for `user`
-- ----------------------------
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `username` varchar(255) DEFAULT NULL,
  UNIQUE KEY `id_x` (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8;

-- ----------------------------
-- Records of user
-- ----------------------------
INSERT INTO `user` VALUES ('1', 'jiahp');
INSERT INTO `user` VALUES ('2', 'wangli');
INSERT INTO `user` VALUES ('3', 'guoyanbin');
INSERT INTO `user` VALUES ('4', 'yaodong');

这里加了一个新注解:

@EnableAutoConfiguration:它是为了自动检查依赖的配置

等应用成功启动成功之后,在浏览器端访问 http://localhost:8888/findUser/1 对应结果如下:

当然可以都访问几个id,然后再访问druid的监控页面 在浏览器端访问  http://localhost:8888/druid/login.html

会弹出登录对话框,输入配置文件里面的用户名和密码就会登录成功,然后跳转到下面这样的页面

这上面的功能很多,比如sql监控:可以看到查询了哪些sql语句

还有url监控 可以查询对应sql调用的api:

还有其他功能,可以自己都点点看,还是蛮强大的,好了到此为止springboot和jdbc的整合就介绍完了..

版权声明:转载请标明博客地址,谢谢!

版权声明:本文为qq_18603599原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/qq_18603599/article/details/81169198

智能推荐

fluent-ffmpeg在electron框架中实现推流

需要准备这几个东西 electron框架 ffmpeg.exe应用程序 链接:https://pan.baidu.com/s/1TyzYlWG0p7cxpqrzziVRCA  提取码:ofd2(也可自行去官网下载) fluent-ffmpeg插件 一个rtmp流地址 首先要做以下几步操作 1.将ffmpeg.exe文件放到electron项目文件夹中 2.安装插件和electron框架并...

bireme数据源同步工具--debezium+kafka+bireme

1、介绍 Bireme 是一个 Greenplum / HashData 数据仓库的增量同步工具。目前支持 MySQL、PostgreSQL 和 MongoDB 数据源 官方介绍文档:https://github.com/HashDataInc/bireme/blob/master/README_zh-cn.md 1、数据流 Bireme 采用 DELETE + COPY 的方式,将数据源的修改记...

一致性hash算法

散列(hash)在我看来就是一个数组,而与数组不同的点在于数组是按顺序写入的,而hash是按照一定的hash算法确定元素在数组中的位置的。hash最难的问题在于会有冲突出现,如果两个object根据相应的hash算法得出的值一样便产生了hash冲突。在所有解决hash冲突的方法中,我最欣赏的是链式解决法,即将hash到同一位置的元素用链表连接。当然还有其它几种处理hash冲突的算法,比如建立公共溢...

OpenCV-Python learning-1.安装,图片读取显示

1. OpenCV与OpenGL区别 https://www.zhihu.com/question/20212016 一个是让机器识别东西的,OpenCV是给电脑做眼睛的。 一个是让机器计算出更好画面的,OpenGL用在游戏渲染方面很多。 OpenCV(Open Source Computer Vision Library)是一个基于(开源)发行的跨平台计算机视觉库,OpenGL(全写Open G...

Mycat+Mysql分布式架构改造和性能压力测试

架构实现 Mycat作为数据库高可用中间件具备很多的功能,如负载均衡,分库分表,读写分离,故障迁移等。结合项目的实际情况,分库分表功能对于关联查询有很高的要求,需要从业务角度考虑分库分表后的关联查询SQL的分析,业务代码动作较大,所以在此方案中我们不考虑分库分表。主要应用Mycat的负载均衡及故障迁移的功能即可。 整个架构改造包括两个部分,第一是单例Mysql改为多个Mysql,同时负载均衡,并且...

猜你喜欢

人脸识别之疲劳检测(二)阈值法、KNN分类和K-means聚类

Table of Contents 1、均值法 2、中值法 3、KNN 4、K-means 结合上一节在获得人眼特征点后需要对睁眼闭眼状态做出判断,方法的选择需要经验结合公平的评价方法,使用大量测试集得到不同方法下的精确度并做出比较: 1、均值法 50帧睁眼数据取均值,得到不同阈值下精确度。 2、中值法 50帧睁眼数据取中值,得到不同阈值下精确度。 3、KNN KNN是一种ML常用分类算法,通过测...

CodeForce Tic-Tac-Toe

Two bears are playing tic-tac-toe via mail. It's boring for them to play usual tic-tac-toe game, so they are a playing modified version of this game. Here are its rules. The game is played on the foll...

Python雾里看花-抽象类ABC (abstract base class)

首先认识模块 abc,python中没有提供抽象类与抽象方法,然而提供了内置模块abc来模拟实现抽象类,例如提供泛映射类型的抽象类 abc.MutableMapping 继承abc.MutableMapping构造一个泛映射类型(类似python中的dict) 当然继承abc.Mapping 也可以,毕竟MutableMapping是其子类 dict是python中典型的映射类型数据结构,其接口的...

python 文件操作

2, with open (‘xx.txt’,‘w’,encoding=‘utf-8’) as f: f.write(‘文件内容或对象’)...

【Python基础】使用统计函数绘制简单图形

机器学习算法与自然语言处理出品 @公众号原创专栏作者 冯夏冲 学校 | 哈工大SCIR实验室在读博士生 2.1 函数bar 用于绘制柱状图 2.2 函数barh 用于绘制条形图 2.3 函数hist 用于绘制直方图 直方图与柱状图的区别 函数pie 用于绘制饼图 2.5 函数polor 用于绘制极线图 极线图是在极坐标系上绘出的一种图。在极坐标系中,要确定一个点,需要指明这个点距原点的角...