欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Spring Boot JDBC 连接数据库示例

程序员文章站 2024-03-05 16:05:13
文本将对在spring boot构建的web应用中,基于mysql数据库的几种数据库连接方式进行介绍。 包括jdbc、jpa、mybatis、多数据源和事务。 j...

文本将对在spring boot构建的web应用中,基于mysql数据库的几种数据库连接方式进行介绍。

包括jdbc、jpa、mybatis、多数据源和事务。

jdbc 连接数据库

1、属性配置文件(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

如果使用jndi,则可以替代 spring.datasource 的 url、username、password,如:

spring.datasource.jndi-name=java:tomcat/datasources/example 

值得一提的是,无论是spring boot默认的datasource配置还是你自己的datasource bean,都会引用到外部属性文件中的属性配置。所以假设你自定义的datasource bean,你可以在定义bean时设置属性,也可以在属性文件中,以“spring.datasource.*”的方式使属性配置外部化。

2、pom.xml 配置maven依赖

    <!-- mysql -->
    <dependency>
      <groupid>mysql</groupid>
      <artifactid>mysql-connector-java</artifactid>
     </dependency>
     <!-- spring boot jdbc -->
     <dependency>
      <groupid>org.springframework.boot</groupid>
      <artifactid>spring-boot-starter-jdbc</artifactid>
     </dependency>

3、java代码范例

studentservice.java

package org.springboot.sample.service;

import java.sql.resultset;
import java.sql.sqlexception;
import java.util.list;

import org.springboot.sample.entity.student;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.jdbc.core.jdbctemplate;
import org.springframework.jdbc.core.rowmapper;
import org.springframework.stereotype.service;

/**
 * studeng service
 *
 * @author  单红宇(365384722)
 * @create  2016年1月12日
 */
@service
public class studentservice {

  @autowired
  private jdbctemplate jdbctemplate;

  public list<student> getlist(){
    string sql = "select id,name,score_sum,score_avg, age  from student";
    return (list<student>) jdbctemplate.query(sql, new rowmapper<student>(){

      @override
      public student maprow(resultset rs, int rownum) throws sqlexception {
        student stu = new student();
        stu.setid(rs.getint("id"));
        stu.setage(rs.getint("age"));
        stu.setname(rs.getstring("name"));
        stu.setsumscore(rs.getstring("score_sum"));
        stu.setavgscore(rs.getstring("score_avg"));
        return stu;
      }

    });
  }
}

student.java 实体类

package org.springboot.sample.entity;

import java.io.serializable;

/**
 * 学生实体
 *
 * @author  单红宇(365384722)
 * @create  2016年1月12日
 */
public class student implements serializable{

  private static final long serialversionuid = 2120869894112984147l;

  private int id;
  private string name;
  private string sumscore;
  private string avgscore;
  private int age;

  // 节省文章长度,get set 方法省略
}

studentcontroller.java

package org.springboot.sample.controller;

import java.util.list;

import org.slf4j.logger;
import org.slf4j.loggerfactory;
import org.springboot.sample.entity.student;
import org.springboot.sample.service.studentservice;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.web.bind.annotation.requestmapping;
import org.springframework.web.bind.annotation.restcontroller;

@restcontroller
@requestmapping("/stu")
public class studentcontroller {

  private static final logger logger = loggerfactory.getlogger(studentcontroller.class);

  @autowired
  private studentservice studentservice;

  @requestmapping("/list")
  public list<student> getstus(){
    logger.info("从数据库读取student集合");
    return studentservice.getlist();
  }
}

本文对工程添加文件后工程结构图:

Spring Boot JDBC 连接数据库示例

然后启动项目,访问地址: http://localhost:8080/myspringboot/stu/list 响应结果如下:

[
{
id: 1,
name: "小明",
sumscore: "252",
avgscore: "84",
age: 1
},
{
id: 2,
name: "小王",
sumscore: "187",
avgscore: "62.3",
age: 1
},
{
id: 3,
name: "莉莉",
sumscore: "",
avgscore: "",
age: 0
},
{
id: 4,
name: "柱子",
sumscore: "230",
avgscore: "76.7",
age: 1
},
{
id: 5,
name: "大毛",
sumscore: "",
avgscore: "",
age: 0
},
{
id: 6,
name: "亮子",
sumscore: "0",
avgscore: "0",
age: 1
}
]

连接池说明

tomcat7之前,tomcat本质应用了dbcp连接池技术来实现的jdbc数据源,但在tomcat7之后,tomcat提供了新的jdbc连接池方案,作为dbcp的替换或备选方案,解决了许多之前使用dbcp的不利之处,并提高了性能。

spring boot为我们准备了最佳的数据库连接池方案,只需要在属性文件(例如application.properties)中配置需要的连接池参数即可。

我们使用tomcat数据源连接池,需要依赖tomcat-jdbc,只要应用中添加了spring-boot-starter-jdbc 或 spring-boot-starter-data-jpa依赖,则无需担心这点,因为将会自动添加 tomcat-jdbc 依赖。

假如我们想用其他方式的连接池技术,只要配置自己的datasource bean,即可覆盖spring boot的自动配置。

请看我的数据源配置:

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

spring.datasource.max-idle=10
spring.datasource.max-wait=10000
spring.datasource.min-idle=5
spring.datasource.initial-size=5
spring.datasource.validation-query=select 1
spring.datasource.test-on-borrow=false
spring.datasource.test-while-idle=true
spring.datasource.time-between-eviction-runs-millis=18800
spring.datasource.jdbc-interceptors=connectionstate;slowqueryreport(threshold=0)

配置过连接池的开发人员对这些属性的意义都有所认识。

我们打开debug日志输出,logback.xml 中添加:

<logger name="org.springframework.boot" level="debug"/>

然后启动项目,注意观察日志输出,如下图中会显示自动启用了连接池:

Spring Boot JDBC 连接数据库示例 

我在上面的数据源配置中添加了过滤器,并设置了延迟时间为0(故意设置很低,实际项目中请修改):

复制代码 代码如下:

spring.datasource.jdbc-interceptors=connectionstate;slowqueryreport(threshold=0)

这个时候,我们访问 http://localhost:8080/myspringboot/stu/list 观察日志,会发现框架自动将大于该时间的数据查询进行警告输出,如下:

复制代码 代码如下:

2016-01-12 23:27:06.710  warn 17644 --- [nio-8080-exec-1] o.a.t.j.p.interceptor.slowqueryreport    : slow query report sql=select id,name,score_sum,score_avg, age   from student; time=3 ms;

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。