:)
依赖
- starter 依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
-
这个start依赖的其他库
这个库依赖了HikariCP，这是个数据库连接池
关于数据库连接池
- 如果依赖里面存在HikariCP 那就使用这个连接池
- 如果不存在 HikariCP 而 Tomcat pooling的DataSource可以用就使用这个
- 如果上面两个都不可用则使用 DBCP2
配置数据链接信息
- 需要配置的信息有 driverclassname ，url ，username， password
spring.datasource.driverClassName=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/test
spring.datasource.username=root
spring.datasource.password=123456
- 为什么这样配置？ 主要是根据 org.springframework.boot.autoconfigure.jdbc.DataSourceProperties 这个类来的，这个类有个注解 @ConfigurationProperties(prefix = "spring.datasource") 所以前缀都是spring.datasource，后面的url password 之类的值是这个类的变量，当然这个类的其他有set方法的变量也是可以这样配置的
访问数据库
- 配置了链接信息之后spring boot 就会创建 DataSource 和 连接池，所以我们直接将DataSource注入就可以使用了（如果使用 jdbc starter 则默认是使用了连接池的）
@Autowired
private DataSource dataSource;
@RequestMapping("/user")
public List<User> showAllInfo() throws SQLException {
String sql = "select * from sys_user";
Connection connection = dataSource.getConnection();
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery(sql);
List<User> users = new ArrayList<>();
while(resultSet.next()){
String name = resultSet.getString("user_name");
String number = resultSet.getString("user_password");
User user = new User();
user.setName(name);
user.setNumber(number);
users.add(user);
}
return users;
}
控制台报错Establishing SSL connection without server's identity verification is not recommended，这个是因为mysql要求ssl链接，将链接url改成jdbc:mysql://127.0.0.1:3306/test?useSSL=true
使用 JdbcTemplate 访问数据库，org.springframework.boot.autoconfigure.jdbc.JdbcTemplateAutoConfiguration 这个类里面注册了两个Bean，JdbcTemplate 和 NamedParameterJdbcTemplate。我们就可以在代码中直接注入使用
@Autowired
private JdbcTemplate jdbcTemplate;
@RequestMapping("/")
public List<User> showProperInfo(){
String sql = "select * from sys_user";
List<User> query = jdbcTemplate.query(sql, new RowMapper<User>() {
@Override
public User mapRow(ResultSet rs, int rowNum) throws SQLException {
User user = new User();
user.setName(rs.getString("user_name"));
user.setNumber(rs.getString("user_password"));
return user;
}
});
return query;
}
配置自己的数据源
- 有些时候我们想用其他的数据连接池，这个时候就需要自己配置了，配置方法就是定义一个bean
@Configuration
public class DataSourceConfig {
@Value("${spring.datasource.url}")
private String url;
@Value("${spring.datasource.username}")
private String user;
@Value("${spring.datasource.password}")
private String password;
@Bean
public DataSource dataSource(){
MysqlDataSource source = new MysqlDataSource();
source.setURL(url);
source.setPassword(password);
source.setUser(user);
return source;
}
}
End
