1.application.properties 配置信息
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/datebasenamespring.datasource.username=root
spring.datasource.password=password
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
2.添加pom.xml
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.apache.ibatis</groupId>
<artifactId>ibator</artifactId>
<version>1.2.1.681</version>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.6</version>
</dependency>
<dependency>
<groupId>com.zaxxer</groupId>
<artifactId>HikariCP</artifactId>
<version>3.2.0</version>
</dependency>
3.数据库连接
import com.zaxxer.hikari.HikariDataSource;import org.apache.ibatis.session.SqlSessionFactory;import org.mybatis.spring.SqlSessionFactoryBean;import org.mybatis.spring.annotation.MapperScan;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.beans.factory.annotation.Value;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Primary;import org.springframework.stereotype.Component;import javax.sql.DataSource;//加载com.example.demo.mapper.test目录下的sql，并关联到当前到数据库@Component
@MapperScan(value = "com.example.demo.mapper.test", sqlSessionFactoryRef = "sqlSessionFactoryTest")publicclass TestDateSource {
//读取配置文件信息@Value("${spring.datasource.url}")
private String url;
@Value("${spring.datasource.username}")
private String userName;
@Value("${spring.datasource.password}")
private String password;
@Value("${spring.datasource.driver-class-name}")
private String driverClassName;
@Primary
@Bean(name = "dateSourceTest")
public DataSource dataSource() {
return getDataSource(url, userName, password, driverClassName);
}
//实例化@Bean(name = "sqlSessionFactoryTest")
publicSqlSessionFactory sqlSessionFactory(@Qualifier("dateSourceTest") DataSource ds)throws Exception {
SqlSessionFactoryBean sqlSessionFactoryBean =new SqlSessionFactoryBean();
sqlSessionFactoryBean.setDataSource(ds);
return sqlSessionFactoryBean.getObject();
}
//这里用到了HikariDataSource连接池，定义一个连接池private HikariDataSource getDataSource(String url, String userName, String password, String driverClassName) {
finalHikariDataSource ds =new HikariDataSource();
ds.setJdbcUrl(url);
ds.setUsername(userName);
ds.setPassword(password);
ds.setDriverClassName(driverClassName);
return ds;
}
}
4.在com.example.demo.mapper.test目录下创建mapper接口，直接进行数据库的数据操作
importorg.apache.ibatis.annotations.*;import org.mapstruct.Mapper;import java.util.HashMap;import java.util.List;
@Mapperpublicinterface UserMapper {
@Select("select *from user")
List getUser();
@Select("select *from user where username=#{userName}")
List getuserName(@Param("userName") String userName);
}
5.在service调用对应的mapper接口
@Servicepublicclass TestService {
@Resource
UserMapper userMapper;
public JSONObject getUSer() {
JSONObject mapOfColValues =new JSONObject();
List order = userMapper.getUser();
if (CollectionUtils.isNotEmpty(order)) {
for(inti = 0; i < order.size(); i++) {
mapOfColValues.put("id", order.get(i).get("id"));
mapOfColValues.put("用户名", order.get(i).get("user_name"));
mapOfColValues.put("昵称", order.get(i).get("real_name"));
mapOfColValues.put("手机号", order.get(i).get("mobile"));
mapOfColValues.put("密码", order.get(i).get("password"));
}
} else {
mapOfColValues.put("result", "没有数据");
}
return mapOfColValues;
}
}
