Pom
<!-- 移除 tomcat-jdbc, Spring Boot 将会自动使用 HikariCP -->
<dependency>
<groupId>com.zaxxer</groupId>
<artifactId>HikariCP</artifactId>
<version>2.6.3</version>
</dependency>
<!-- 数据库选用 Mariadb -->
<dependency>
<groupId>org.mariadb.jdbc</groupId>
<artifactId>mariadb-java-client</artifactId>
<version>2.1.0</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.mybatis.spring.boot/mybatis-spring-boot-starter -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.1</version>
<!-- 移除 Tomcat 的jdbc连接池,使用 HikariCP -->
<exclusions>
<exclusion>
<groupId>org.apache.tomcat</groupId>
<artifactId>tomcat-jdbc</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>6.0.6</version>
</dependency>
MyBatis-Spring-Boot-Starter依赖将会:
- 自动检测现有的DataSource
- 将创建并注册SqlSessionFactory的实例,该实例使用SqlSessionFactoryBean将该DataSource作为输入进行传递
- 将创建并注册从SqlSessionFactory中获取的SqlSessionTemplate的实例。
- 自动扫描mappers,将它们链接到SqlSessionTemplate并将其注册到Spring上下文,以便将其注入到你的bean中。
就是说,使用了该Starter之后,只需要定义一个DataSource即可(application.properties中可配置),它会自动创建使用该DataSource的SqlSessionFactoryBean以及SqlSessionTemplate。会自动扫描你的Mappers,连接到SqlSessionTemplate,并注册到Spring上下文中。
自定义数据源
@SpringBootApplication
public class SbmybatisApplication {
@Autowired
Environment environment;
public static void main(String[] args) {
SpringApplication.run(SbmybatisApplication.class, args);
}
@Bean(destroyMethod = "shutdown")
public DataSource dataSource() {
HikariDataSource hikariDataSource = new HikariDataSource();
hikariDataSource.setJdbcUrl(environment.getProperty("spring.datasource.hikari.jdbc-url"));
hikariDataSource.setUsername(environment.getProperty("spring.datasource.hikari.username"));
hikariDataSource.setPassword(environment.getProperty("spring.datasource.hikari.password"));
hikariDataSource.setMaximumPoolSize(Integer.parseInt(environment.getProperty("spring.datasource.hikari.maximum-pool-size")));
hikariDataSource.setMinimumIdle(Integer.parseInt(environment.getProperty("spring.datasource.hikari.minimum-idle")));
hikariDataSource.setConnectionTestQuery(environment.getProperty("spring.datasource.hikari.connection-test-query"));
hikariDataSource.setIdleTimeout(Long.parseLong(environment.getProperty("spring.datasource.hikari.idle-timeout")));
hikariDataSource.setMaxLifetime(Long.parseLong(environment.getProperty("spring.datasource.hikari.max-lifetime")));
hikariDataSource.setConnectionTimeout(Long.parseLong(environment.getProperty("spring.datasource.hikari.connection-timeout")));
return hikariDataSource;
}
}
初始化脚本
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
`id` bigint(11) NOT NULL,
`username` varchar(9) NOT NULL,
`password` varchar(10) NOT NULL,
`uri` varchar(100) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of user
-- ----------------------------
INSERT INTO `user` VALUES ('1', '冀永光', 'jyg0723', 'http://www.jiyongguang.xin/');
INSERT INTO `user` VALUES ('2', '李亚男', 'lyn0723', 'http://www.jiyongguang.xin/');
Model
@Data
@AllArgsConstructor
public class User {
private long id;
private String username;
private String password;
private String uri;
}
Controller
@Controller
@Log4j2
@RequestMapping(path = "/user")
public class UserController {
@Autowired
UserService userService;
@RequestMapping(path = "/query", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
@ResponseBody
public String queryAllUser() {
log.info("UserController -/ queryAllUser");
String userString = userService.queryAllUser().toString();
log.info("userList", userService.queryAllUser());
return JsonUtil.getJsonString(JsonUtil.REQUEST_SUCCESS, userString);
}
@RequestMapping(path = "/add", method = RequestMethod.POST)
@ResponseBody
public String addUser(@RequestParam String username,
@RequestParam String password,
@RequestParam String uri) {
log.info("UserController -/ addUser");
log.info("username:" + username + " - password:" + password + " - uri:" + uri);
return JsonUtil.getJsonString(userService.addUser(username, password, uri));
}
@RequestMapping(path = "/update", method = RequestMethod.POST)
@ResponseBody
public String updateUser(@RequestParam String username,
@RequestParam String password,
@RequestParam String uri,
@RequestParam long id) {
log.info("UserController -/ updateUser");
log.info("username:" + username + " - password:" + password + " - uri:" + uri + " - id:" + id);
return JsonUtil.getJsonString(userService.updateUser(username, password, uri, id));
}
@RequestMapping(path = "/delete", method = RequestMethod.POST)
@ResponseBody
public String deleteUser(@RequestParam String id) {
log.info("UserController -/ deleteUser - id: " + id, id);
return JsonUtil.getJsonString(userService.deleteUser(Long.parseLong(id)));
}
@RequestMapping(path = "/queryone", method = RequestMethod.GET)
public String queryUserById(@RequestParam String id,
Model model) {
log.info("UserController -/ queryUserById - id: " + id, id);
User user = userService.queryUserById(Long.parseLong(id));
model.addAttribute("user", user);
return "update";
}
}
注解方式
@Mapper
@Component
@SuppressWarnings("ALL")
public interface UserDao {
@Select("select * from user where id = #{id}")
User queryUserById(@Param("id") Long id);
@Select("select * from user")
@Results(id = "userList", value = {
@Result(id = true, column = "id", property = "id", javaType = Long.class, jdbcType = JdbcType.BIGINT),
@Result(column = "username", property = "username", javaType = String.class, jdbcType = JdbcType.VARCHAR),
@Result(column = "password", property = "password", javaType = String.class, jdbcType = JdbcType.VARCHAR),
@Result(column = "uri", property = "uri", javaType = String.class, jdbcType = JdbcType.VARCHAR)
})
List<User> queryAllUser();
// 模糊查询
@SelectProvider(type = UserSqlBuilder.class, method = "queryUserByParams")
List<User> queryUserByCondition(Map<String, Object> params);
@Insert("insert into user(username,password,uri) values(#{username},#{password},#{uri}) ")
Integer addUser(@Param("username") String username,
@Param("password") String password, @Param("uri") String uri);
@Update("update user set username=#{username},password=#{password},uri=#{uri} where id = #{id}")
Integer updateUser(@Param("username") String username, @Param("password") String password,
@Param("uri") String uri, @Param("id") Long id);
@Delete("delete from user where id = #{id}")
Integer deleteUser(@Param("id") Long id);
@DeleteProvider(type = UserSqlBuilder.class, method = "deleteUserById")
Integer deleteUserById(@Param("ids") String[] ids);
@Log4j2
class UserSqlBuilder {
public String queryUserByParams(final Map<String, Object> params) {
StringBuilder sql = new StringBuilder("select * from user where 1=1");
if (!StringUtils.isEmpty((String) params.get("username"))) {
sql.append("and username like '%").append((String) params.get("username")).append("'%");
} else if (!StringUtils.isEmpty((String) params.get("uti"))) {
sql.append("and uri like '%").append((String) params.get("uri")).append("%'");
}
log.info("查询的sql语句:" + sql.toString());
return sql.toString();
}
public String deleteUserById(final String[] ids) {
StringBuilder sql = new StringBuilder("delete from user where id in(");
for (int i = 0; i < ids.length; ++i) {
if (i == ids.length - 1) {
sql.append(ids[i]);
} else {
sql.append(ids[i]).append(",");
}
}
sql.append(")");
log.info("删除的sql语句:" + sql.toString());
return sql.toString();
}
}
}