springBoot操作数据库-springData操作数据库篇

springData说明

springData是啥

Spring Data是一个用于简化数据库的访问，并支持云服务的开源框架。在springBoot中通过配置maven依赖即可实现对数据库的访问与操作管理

常用有哪些

spring data jdbc：数据库操作

spring data redis：redis缓存操作

spring data mongodb：mongodb缓存数据库操作

spring data jpa ：与mybatis类似，基于orm的开源框架

等

操作数据库一般有那几种方式

通过jdbc的方式，也可以基于阿里开源的Druid方式。以下主要是基于此两种方式的介绍

springData基于jdbc配置与使用

1、引入依赖包

2、设置配置文件

3、编写测试代码

package com.zhouyunjian.springdata;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.jdbc.core.JdbcTemplate;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import java.util.List;

import java.util.Map;

@RestController

@RequestMapping("/jdbc")

public class JdbcController {

@Autowired

JdbcTemplate jdbcTemplate;

@RequestMapping("/add")

public void add(){

String sql="INSERT INTO im_customer (id, customer_id, first_name, last_name, gender, email, password, is_delete, version, create_time, update_time) VALUES (3, 'cs10003', 'coding', 'qing', 1, '[email protected]', '[email protected]', 0, 0, 1577627424, 1577627424);\n";

jdbcTemplate.update(sql);

}

@RequestMapping("/update")

public void update(){

String sql="update im_customer set last_name='huahua' where id=?";

Object[] objects={"3"};

jdbcTemplate.update(sql,objects);

}

@RequestMapping("/query")

public void query(){

String sql="select * from im_customer";

Object[] objects={"3"};

List<Map<String, Object>> maps = jdbcTemplate.queryForList(sql);

System.out.println(maps);

}

@RequestMapping("/delete")

public void delete(){

String sql="delete from im_customer where id=?";

Object[] objects={"3"};

jdbcTemplate.update(sql,objects);

}

4.测试访问

http://127.0.0.1:8080/jdbc/xxx xxx分别输入 add、update、delete、update

Druid使用与配置

https://github.com/alibaba/druid/wiki/%E5%B8%B8%E8%A7%81%E9%97%AE%E9%A2%98

介绍

Java程序很大的一部分都是要操作数据库的，为了提高操作数据库的性能，所以一般会使用连接池！

Druid 是阿里巴巴的开源组件之一，结合了C3P0，DBCP的优点，并且自带日志监控！

Druid 可以天然的监控 SQL 和数据库连接池的状况！

配置说明

#Spring Boot 默认是不注入这些属性值的，需要自己绑定

#druid 数据源专有配置

initialSize: 5

minIdle: 5

maxActive: 20

maxWait: 60000

timeBetweenEvictionRunsMillis: 60000

minEvictableIdleTimeMillis: 300000

validationQuery: SELECT 1 FROM DUAL

testWhileIdle: true

testOnBorrow: false

testOnReturn: false

poolPreparedStatements: true

#配置监控统计拦截的filters，stat:监控统计、log4j：日志记录、wall：防御sql注入

#如果允许时报错 java.lang.ClassNotFoundException: org.apache.log4j.Priority

#则导入 log4j 依赖即可，Maven 地址：

https://mvnrepository.com/artifact/log4j/log4j

filters: stat,wall,log4j

maxPoolPreparedStatementPerConnectionSize: 20

useGlobalDataSourceStat: true

connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500

配置	缺省值	说明
name		配置这个属性的意义在于，如果存在多个数据源，监控的时候可以通过名字来区分开来。如果没有配置，将会生成一个名字，格式是："DataSource-" + System.identityHashCode(this). 另外配置此属性至少在1.0.5版本中是不起作用的，强行设置name会出错。详情-点此处。
url		连接数据库的url，不同数据库不一样。例如： mysql : jdbc:mysql://10.20.153.104:3306/druid2 oracle : jdbc:oracle:thin:@10.20.149.85:1521:ocnauto
username		连接数据库的用户名
password		连接数据库的密码。如果你不希望密码直接写在配置文件中，可以使用ConfigFilter。详细看这里
driverClassName	根据url自动识别	这一项可配可不配，如果不配置druid会根据url自动识别dbType，然后选择相应的driverClassName
initialSize	0	初始化时建立物理连接的个数。初始化发生在显示调用init方法，或者第一次getConnection时
maxActive	8	最大连接池数量
maxIdle	8	已经不再使用，配置了也没效果
minIdle		最小连接池数量
maxWait		获取连接时最大等待时间，单位毫秒。配置了maxWait之后，缺省启用公平锁，并发效率会有所下降，如果需要可以通过配置useUnfairLock属性为true使用非公平锁。
poolPreparedStatements	false	是否缓存preparedStatement，也就是PSCache。PSCache对支持游标的数据库性能提升巨大，比如说oracle。在mysql下建议关闭。
maxPoolPreparedStatementPerConnectionSize	-1	要启用PSCache，必须配置大于0，当大于0时，poolPreparedStatements自动触发修改为true。在Druid中，不会存在Oracle下PSCache占用内存过多的问题，可以把这个数值配置大一些，比如说100
validationQuery		用来检测连接是否有效的sql，要求是一个查询语句，常用select 'x'。如果validationQuery为null，testOnBorrow、testOnReturn、testWhileIdle都不会起作用。
validationQueryTimeout		单位：秒，检测连接是否有效的超时时间。底层调用jdbc Statement对象的void setQueryTimeout(int seconds)方法
testOnBorrow	true	申请连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能。
testOnReturn	false	归还连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能。
testWhileIdle	false	建议配置为true，不影响性能，并且保证安全性。申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis，执行validationQuery检测连接是否有效。
keepAlive	false （1.0.28）	连接池中的minIdle数量以内的连接，空闲时间超过minEvictableIdleTimeMillis，则会执行keepAlive操作。
timeBetweenEvictionRunsMillis	1分钟（1.0.14）	有两个含义： 1) Destroy线程会检测连接的间隔时间，如果连接空闲时间大于等于minEvictableIdleTimeMillis则关闭物理连接。 2) testWhileIdle的判断依据，详细看testWhileIdle属性的说明
numTestsPerEvictionRun	30分钟（1.0.14）	不再使用，一个DruidDataSource只支持一个EvictionRun
minEvictableIdleTimeMillis		连接保持空闲而不被驱逐的最小时间
connectionInitSqls		物理连接初始化的时候执行的sql
exceptionSorter	根据dbType自动识别	当数据库抛出一些不可恢复的异常时，抛弃连接
filters		属性类型是字符串，通过别名的方式配置扩展插件，常用的插件有：监控统计用的filter:stat 日志用的filter:log4j 防御sql注入的filter:wall
proxyFilters		类型是List<com.alibaba.druid.filter.Filter>，如果同时配置了filters和proxyFilters，是组合关系，并非替换关系

导入依赖

<groupId>com.alibaba</groupId>

<artifactId>druid</artifactId>

</dependency>

</dependency>

配置文件编写

package com.zhouyunjian.springdata;

import com.alibaba.druid.pool.DruidDataSource;

import com.alibaba.druid.support.http.StatViewServlet;

import com.alibaba.druid.support.http.WebStatFilter;

import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;

import org.springframework.boot.context.properties.ConfigurationProperties;

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 javax.sql.DataSource;

import java.util.Arrays;

import java.util.HashMap;

import java.util.Map;

@Configuration

@ConditionalOnWebApplication

public class SpringdataConfiguration {

//注册druid测试文件

@ConfigurationProperties(prefix = "spring.datasource")

@Bean

public DataSource dataSource(){

DruidDataSource druidDataSource = new DruidDataSource();

return druidDataSource;

}

@Bean

public ServletRegistrationBean servletRegistrationBean(){

ServletRegistrationBean bean = new ServletRegistrationBean(new StatViewServlet(),"/druid/*");

Map<String, String> map = new HashMap<>();

map.put("loginUsername","admin");

map.put("loginPassword","123456");

// 访问权限 // map.put("allow","localhost"); //只允许本机访问

map.put("allow",""); // 所有人都可以访问

bean.setInitParameters(map); //设置servlet的初始化参数

return bean;

}

// 过滤器的配置，看看哪些请求需要被过滤 // 没有web.xml 的情况配置 Filter 的方法！ FilterRegistrationBean

@Bean

public FilterRegistrationBean webStatFilter() {

FilterRegistrationBean bean = new FilterRegistrationBean();

bean.setFilter(new WebStatFilter());

// 配置内容 // 配置哪些请求可以被过滤！

HashMap<String, String> map = new HashMap<>();

map.put("exclusions", "*.js,*.css,/druid/*");

bean.setInitParameters(map);

bean.setUrlPatterns(Arrays.asList("/*"));

return bean;

}

登录测试

1、http://127.0.0.1:8080/druid/login.html admin/123456

2、输入增、删、改、查测试url,进行测试统计

3、监控测试结果

spring整合mybatis使用实操

1、导入依赖

<groupId>org.mybatis.spring.boot</groupId>

<artifactId>mybatis-spring-boot-starter</artifactId>

</dependency>

2、编写mybatis配置文件

#下划线转驼峰

mybatis.configuration.map-underscore-to-camel-case=true

#扫描实体类

mybatis.type-aliases-package=com.zhouyunjian.pojo

#设置xml扫描路径

mybatis.mapper-locations=classpath:com/zhouyunjian/mapper/*.xml,*.xml

3、编写接口

package com.zhouyunjian.mapper;

import com.zhouyunjian.pojo.Customer;

import org.apache.ibatis.annotations.Mapper;

import org.springframework.stereotype.Repository;

import java.util.List;

@Mapper

@Repository

public interface CustomerDao {

List<Customer> selectInfo();

}

4、编写接口Mapper配置文件

<?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">

select * from im_customer;

</select>

</mapper>

5、编写controller

package com.zhouyunjian.springdata;

import com.zhouyunjian.mapper.CustomerDao;

import com.zhouyunjian.pojo.Customer;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.jdbc.core.JdbcTemplate;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import java.util.List;

import java.util.Map;

@RestController

@RequestMapping("/mybatis")

public class MybatisController {

@Autowired

CustomerDao customerDao;

@RequestMapping("/query")

public List<Customer> query(){

return customerDao.selectInfo();

}

6、测试

http://127.0.0.1:8080/mybatis/query

springBoot操作数据库-springData操作数据库篇

相关推荐