本文共 9801 字,大约阅读时间需要 32 分钟。
数据库开发是java的核心内容之一,基础就是jdbc了;
然而直接使用jdbc,需要写大量的try-catch-finally模板代码;
管理系统使用hibernate作为orm框架比较方便,遵循jpa规范;
互联网时代使用Mybatis,因为灵活,方便进行sql优化;
此外spring也提供了jdbcTemplate的访问数据库的模式,不过没有被大量的企业使用;
使用这些ORM框架之前,必须先配置好数据源;
数据连接池,可以复用连接
常见数据库
数据库 | 说明 |
---|---|
h2 | 内存数据库 |
derby | 内存数据库 |
hqldb | 内存数据库 |
mysql | 商用数据库,开源免费 |
oracle | 商用数据库,oracle |
mssql | 即sql server 微软提供 |
引入依赖:(spring-jdbc,mysql驱动)
org.springframework.boot spring-boot-starter-jdbc mysql mysql-connector-java
springboot配置jdbc数据源:
spring.datasource.url = jdbc:mysql:localhost:3306/xxxspring.datasource.username = rootspring.datasource.password = rootspring.datasource.driver-class-name = com.mysql.jdbc.Driverspring.datasource.type = 配置数据连接池(org.apache.commons.dbp2.BasicDataSource)
默认使用的是hikaricp;
代码如下:
@SpringBootApplicationpublic class DemoDatasourceTomcatApplication { public static void main(String[] args) { final ConfigurableApplicationContext applicationContext = SpringApplication.run(DemoDatasourceTomcatApplication.class, args); final DataSource dataSource = applicationContext.getBean(DataSource.class); System.out.println(dataSource.getClass().getName()); }}
常见数据连接池
数据源 | 说明 |
---|---|
tomcat | tomcat内置,springboot自带了 |
dbcp2 | 外部经典数据源 |
druid | 阿里开源的容易监控容易扩展的数据源 |
hikricp | 日本开源的一个超快的数据源 |
验证配置的数据源:
jdbcTemplate提供了标准的接口用来操作数据库;
增删改查都有;
在一条连接中执行多条sql语句,jdbcTemplate提供了两种方式,StatementCallback或者ConnectionCallback;
代码示例如下:
package com.springbootpractice.demo.demo_datasource_tomcat.dao.jdbc.impl;import com.springbootpractice.demo.demo_datasource_tomcat.dao.entity.UserLoginEntity;import com.springbootpractice.demo.demo_datasource_tomcat.dao.entity.enums.SexEnum;import com.springbootpractice.demo.demo_datasource_tomcat.dao.jdbc.IUserJdbcBiz;import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.jdbc.core.RowMapper;import org.springframework.stereotype.Service;import java.sql.ResultSet;import java.util.Collections;import java.util.List;import java.util.Optional;/** * 说明:jdbc样板代码 * @author carter * 创建时间: 2020年01月07日 2:36 下午 **/@Servicepublic class UserJdbcBiz implements IUserJdbcBiz { private final JdbcTemplate jdbcTemplate; public UserJdbcBiz(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } @Override public UserLoginEntity getUserLogin(Long id) { String sql = "SELECT id,user_name,password,sex,note FROM user_login WHERE id=? "; Object[] params = {id}; return jdbcTemplate.queryForObject(sql, params, getUserLoginMapper()); } @Override public ListfindUserLogin(String userName, String note) { String sql = "SELECT id,user_name,password,sex,note FROM user_login WHERE user_name=? and note=?"; Object[] params = {userName, note}; return Optional.ofNullable(jdbcTemplate.query(sql, params, getUserLoginMapper())) .orElse(Collections.emptyList()); } @Override public long createUserLogin(UserLoginEntity entity) { String sql = "INSERT INTO user_login(user_name, password, sex, note) VALUES (?,?,?,?)"; Object[] params = {entity.getUserName(), entity.getPassword(), entity.getSex().getCode(), entity.getNote()}; return jdbcTemplate.update(sql, params); } @Override public long updateUserLogin(UserLoginEntity entity) { String sql = "UPDATE user_login SET user_name=? , password=? , sex=? , note=? WHERE id=? "; Object[] params = {entity.getUserName(), entity.getPassword(), entity.getSex().getCode(), entity.getNote(), entity.getId()}; return jdbcTemplate.update(sql, params); } @Override public long deleteUserLogin(Long id) { String sql = "DELETE FROM user_login WHERE id=? "; Object[] params = {id}; return jdbcTemplate.update(sql, params); } public static RowMapper getUserLoginMapper() { return (ResultSet rs, int rowNum) -> UserLoginEntity.builder() .id(rs.getLong("id")) .userName(rs.getString("user_name")) .password(rs.getString("password")) .sex(SexEnum.getByCode(rs.getInt("sex"))) .note(rs.getString("note")) .build(); }}
package com.springbootpractice.demo.demo_datasource_tomcat;import com.springbootpractice.demo.demo_datasource_tomcat.dao.entity.UserLoginEntity;import com.springbootpractice.demo.demo_datasource_tomcat.dao.entity.enums.SexEnum;import com.springbootpractice.demo.demo_datasource_tomcat.dao.jdbc.IUserJdbcBiz;import com.springbootpractice.demo.demo_datasource_tomcat.dao.jdbc.impl.UserJdbcBiz;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.dao.DataAccessException;import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.jdbc.core.StatementCallback;import org.springframework.util.Assert;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.util.Objects;@SpringBootTestclass DemoDatasourceTomcatApplicationTests { @Autowired private IUserJdbcBiz userJdbcBiz; @Test void crateUserLoginTest() { final long id = userJdbcBiz.createUserLogin(UserLoginEntity.builder() .userName("carter.li") .password("abc123") .sex(SexEnum.MALE) .note("第一个账号") .build()); final UserLoginEntity userLogin = userJdbcBiz.getUserLogin(id); Assert.isTrue(Objects.equals(id,userLogin.getId()),"插入失败"); } @Autowired private JdbcTemplate jdbcTemplate; @Test void twoOperationOneConnectionTest() { final UserLoginEntity result = jdbcTemplate.execute((StatementCallback) statement -> { //先插入 final int i = statement.executeUpdate("INSERT INTO user_login(user_name, password, sex, note) VALUES ('gemini.he','abc123456',2,'我是美女!')"); //然后查询 final ResultSet resultSet = statement.executeQuery("SELECT id,user_name,password,sex,note FROM user_login WHERE user_name='gemini.he'"); UserLoginEntity userLoginEntity =null; while (resultSet.next()){ userLoginEntity = UserJdbcBiz.getUserLoginMapper().mapRow(resultSet, resultSet.getRow()); } return userLoginEntity; }); Assert.isTrue(Objects.equals("gemini.he",result.getUserName()),"先插入后查询失败"); }}
JPA:java persistence API ,定义了对象关系映射以及实体对象持久化接口,不局限于EJB,可以脱离容器独立运行,开发,测试,依赖Hibernate的支持;
JPA所维护的核心是实体(EntityBean),通过一个持久化上下文来使用,持久化上下文包括三个部分;
组件 | 说明 |
---|---|
ORM关系描述 | 支持注解或者xml两种形式描述,springboot中使用注解来描述 |
实体操作API | 通过规范可以实现对实体的CRUD操作 |
JPQL查询语言 | 约定了面向对象的查询语言,可以实现灵活的查询 |
jpaRepository的功能体系如下:
sequenceDiagramJpaReporsitory->>QueryByExampleExecutor: 查询功能?JpaReporsitory-->>PageingAndSortingRepository: 分页和排序功能JpaReporsitory-->>CrudRepository: 增删改查功能
可以灵活的通过注解定义新的查询方法;也可以按照规则直接写一个空方法和签名
org.springframework.boot spring-boot-starter-data-jpa
不屏蔽sql并且提供动态sql,接口式编程和简易sql绑定pojo的半自动化框架;
目前java的持久层技术最为主流的就是mybatis,它比jpa更易用和灵活;
适用于当前互联网环境业务比较简单,但是数据量大,高并发,性能问题敏感;
官方定义:支持定制化的sql,存储过程,高级映射的优秀持久层框架。
几乎避免了所有的jdbc代码和手动设置参数以及获取结果集。
mybatis通过xml或者注解把接口和POJO映射为数据库中的记录。
高性能,灵活,方便
1. 支持驼峰映射,sql跟pojo之间,减少了开发者的工作量;
2. 没有屏蔽sql,提供了灵活性,可以最大限度的优化sql;
3. 支持动态sql,适应需求变化
配置文件
因为注解的功能和可读性限制,实际使用的较多的是xml来进行配置;
1. 基础配置文件;mybatis.config-location指定,里面配置底层的mybatis
2. 映射配置文件;mybatis.mapper-locations=classpath:mapper/*.xml
依赖
社区最新版本
org.mybatis.spring.boot mybatis-spring-boot-starter 2.1.1
核心类:
SqlSessionFactory 应用内部唯一
SqlSession 操作的核心类,一般在应用中做了擦除,即无感,转而使用各种XMapper接口;
Configuration: mybatis的核心配置
配置项目 | 说明 |
---|---|
settings | 设置mybatis的低层行为,比如驼峰映射,执行器类型,缓存等 |
typeAliases | 类型别名,@Alias("aa") |
typeHandlers | 类型处理器,处理支持的类型,比如枚举,LocalDate等 |
plugins | 插件,拦截器,mybatis最强大也是最危险的组件,通过代理和责任链模式完成,可以修改底层的实现功能,见代码 |
mappers | 映射器,核心组件,定义了sql和pojo的映射关系,可以使用生成器生成 |
采用@MapperScan注解
@MapperScan(basePackages = "com.springbootpractice.demo.mybatis.dao", annotationClass = Repository.class)
属性配置:
mybatis.mapper-locations= classpath:mapper/*.xmlmybatis.type-aliases-package= com.springbootpractice.demo.mybatis.dao.entitymybatis.type-handlers-package= com.springbootpractice.demo.mybatis.dao.entity.handlermybatis.config-location= classpath:mybatis.xmlmybatis.executor-type= reuse
实体代码,mapper接口,xml配置比较常见,这里给出作为一个例子:
domain实体
package com.springbootpractice.demo.mybatis.dao.entity;import com.springbootpractice.demo.mybatis.dao.entity.enums.SexEnum;import lombok.Data;import org.apache.ibatis.type.Alias;import java.io.Serializable;/** * 说明:TODO * @author carter * 创建时间: 2020年01月07日 5:06 下午 **/@Data@Alias("userLogin")public class UserLoginEntity implements Serializable { private Long id; private String userName; private String password; private SexEnum sex; private String note;}
mapper接口
package com.springbootpractice.demo.mybatis.dao.mapper;import com.springbootpractice.demo.mybatis.dao.entity.UserLoginEntity;import org.apache.ibatis.annotations.Param;import org.springframework.stereotype.Repository;/** * 说明:TODO * @author carter * 创建时间: 2020年01月07日 5:17 下午 **/@Repositorypublic interface UserLoginMapper { /** * 通过id查询用户信息 * @param id id * @return 用户信息 */ UserLoginEntity getById(@Param("id") Long id);}
sql和domain的映射xml
底层的mybatis配置文件:
代码生成工具很多,可以下一个idea插件或引入maven插件来生成domain,mapper,xml代码;
1. 掌握了常见的数据连接池有哪些?并简单应用了DBCP2;
2. spring-jdbc操作数据库的完整过程;
3. spring-jpa操作数据库的完整过程;
4. spring-mybatis操作数据库的完整过程;
实际工作中可以灵活选择,不过一般一个团队中只选择一个架子,大部分是mybatis;
原创不易,转载请注明出处,欢迎多沟通交流